activeMQ学习(与springboot集成)

Posted 学霸王先森

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了activeMQ学习(与springboot集成)相关的知识,希望对你有一定的参考价值。

POOM文件

首先导入activemq所需的jar包

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
    </dependencies>

 

生产者

application.yml

server:
  port: 8090
  servlet:
    context-path: /activemqProducer
spring:
  activemq:
    broker-url: tcp://127.0.0.1:61616
    user: 123
    password: 123

ActiveMqConfig

package com.example.activemqtest.config;

import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.jms.Queue;
import javax.jms.Topic;

@Configuration
public class ActiveMQConfig {

    @Bean
    public Queue queue(){
        return new ActiveMQQueue("queue2");
    }

    @Bean
    public Topic topic(){
        return new ActiveMQTopic("topic2");
    }

}

配置生产者要发送消息的队列或者主题,注入spring中

ProducterController

package com.example.activemqtest.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.Queue;
import javax.jms.Topic;


@RestController
public class ProducterController {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Queue queue;

    @Autowired
    private Topic topic;


    @GetMapping("/sendMsgByQueue")
    public String sendMsgByQueue(String msg){
        jmsMessagingTemplate.convertAndSend(queue,msg);
        return msg;
    }

    @GetMapping("/sendMsgByTopic")
    public String sendMsgByTopic(String msg){
        jmsMessagingTemplate.convertAndSend(topic,msg);
        return msg;
    }
}

消费者

@JmsListener(destination = "queue2")
    //方法返回发送给queue3
    @SendTo("queue3")
    public String handleMessage(String msg){
        System.out.println("接收到的返回是:" + msg);
        return "返回:"+ msg;
    }

以上是消费者接收队列queue2的方式

若要接收topic,需要增加配置

server:
  port: 8091
  servlet:
    context-path: /activemqConsumer
spring:
  activemq:
    broker-url: tcp://127.0.0.1:61616
    user: 123
    password: 123
  jms:
    pub-sub-domain: true

 

@JmsListener(destination = "topic2")
    public void topicConsumer1(String msg){
        System.out.println("消费者1接收为:"+msg);
    }

    @JmsListener(destination = "topic2")
    public void topicConsumer2(String msg){
        System.out.println("消费者2接收为:"+msg);
    }

 

以上是关于activeMQ学习(与springboot集成)的主要内容,如果未能解决你的问题,请参考以下文章

Springboot 2.2.1 与activeMq 集成2 queue 消息

Web项目容器集成ActiveMQ & SpringBoot整合ActiveMQ

24springboot集成ActiveMQ

spring boot集成ActiveMQ

本篇文章主要是讲SpringBoot集成activeMQ实现Queue模式点对点通信

activemq 学习系列 activemq 与 spring boot 整合