详解Springboot整合ActiveMQ（Queue和Topic两种模式）

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;>

 4.0.0
 
  org.springframework.boot
  spring-boot-starter-parent
  2.2.5.RELEASE
   
 
 com.mcy
 springboot-mq
 0.0.1-SNAPSHOT
 springboot-mq
 Demo project for Spring Boot

 
  1.8
 

 
  
   org.springframework.boot
   spring-boot-starter-web
  

  
  
   org.springframework.boot
   spring-boot-starter-activemq
  

  
   org.springframework.boot
   spring-boot-starter-test
   test
   
    
     org.junit.vintage
     junit-vintage-engine
    
   
  
 

 
  
   
    org.springframework.boot
    spring-boot-maven-plugin
   
  
 

server.port=8080
server.servlet.context-path=/mq

#MQ服务器地址
spring.activemq.broker-url=tcp://localhost:61616
#用户名
spring.activemq.user=admin
#密码
spring.activemq.password=admin
#设置是Queue队列还是Topic，false为Queue，true为Topic，默认false-Queue
spring.jms.pub-sub-domain=false
#spring.jms.pub-sub-domain=true

#变量，定义队列和topic的名称
myqueue: activemq-queue
mytopic: activemq-topic

import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.stereotype.Component;
import javax.jms.Topic;

/**
 1. MQ配置类
 */
@Component
@EnableJms
public class ConfigBean {
 @Value("${myqueue}")
 private String myQueue;
 @Value("${mytopic}")
 private String topicName;

 //队列
 @Bean
 public ActiveMQQueue queue(){
  return new ActiveMQQueue(myQueue);
 }

 //topic
 @Bean
 public Topic topic(){
  return new ActiveMQTopic(topicName);
 }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.jms.Queue;

/*
 * 队列消息生产者
 */
@RestController
public class QueueProducerController {
 @Autowired
 private JmsMessagingTemplate jmsMessagingTemplate;

 @Autowired
 private Queue queue;

 /*
  * 消息生产者
  */
 @RequestMapping("/sendmsg")
 public void sendmsg(String msg) {
  System.out.println("发送消息到队列：" + msg);
  // 指定消息发送的目的地及内容
  this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
 }
}

import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.web.bind.annotation.RestController;

/*
 1. 队列queue消费者控制器
 */
@RestController
public class QueueConsumerController {
 /*
  * 消费者接收消息
  */
 @JmsListener(destination="${myqueue}")
 public void readActiveQueue(String message) {
  System.out.println("接受到：" + message);
 }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.jms.Queue;
import javax.jms.Topic;

/*
* topic消息生产者
*/
@RestController
public class TopicProducerController {
 @Autowired
 private JmsMessagingTemplate jmsMessagingTemplate;

 @Autowired
 private Topic topic;

 /*
 * 消息生产者
 */
 @RequestMapping("/topicsendmsg")
 public void sendmsg(String msg) {
  System.out.println("发送消息到MQ：" + msg);
  // 指定消息发送的目的地及内容
  this.jmsMessagingTemplate.convertAndSend(this.topic, msg);
 }
}

import org.springframework.jms.annotation.JmsListener;
import org.springframework.web.bind.annotation.RestController;

/*
 1. topic消费者控制器
 */
@RestController
public class TopicConsumerController {
 /*
  * 消费者接收消息
  */
 @JmsListener(destination="${mytopic}")
 public void readActiveQueue(String message) {
  System.out.println("接受到：" + message);
 }

 @JmsListener(destination="${mytopic}")
 public void readActiveQueue1(String message) {
  System.out.println("接受到：" + message);
 }
}