社区微信群开通啦，扫一扫抢先加入社区官方微信群
社区微信群
Spring Boot 2整合ActiveMQ案例。文中Spring Boot版本为2.1.4.RELEASE。
利用Spring Initializr快速创建一个Spring Boot项目，主要依赖如下：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
这里需要先安装了ActiveMQ，安装方式请参阅 Linux安装ActiveMQ，并在Queues中添加一条Queue，名称为queue.test
spring:
activemq:
broker-url: tcp://192.168.0.2:61616 # activemq消息组件的连接主机
user: admin
password: admin # 账号密码默认为admin
在主启动类XxxApplication上添加@EnableJms注解启动JMS功能
@SpringBootApplication
@EnableJms
public class SpringBootActivemqApplication {
public static void main(String[] args) {
SpringApplication.run(SpringBootActivemqApplication.class, args);
}
}
新建一个消费者监听器，用于监听MQ消费。用@JmsListener注解标注，主要要加入Spring容器中
@Component
public class ConsumerListener {
@JmsListener(destination = "queue.test")
public void receive(String message) {
System.err.println("消费者接收到消息：" + message);
}
}
编写一个Controller，用于发送MQ测试
@RestController
public class MsgController {
private final JmsTemplate jmsTemplate;
public MsgController(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
@GetMapping("/send")
public String sendMsg(String msg){
jmsTemplate.convertAndSend(new ActiveMQQueue("queue.test"), msg);
return "SUCCESS";
}
}
启动ActiveMQ，启动XxxApplication服务；
发送消息测试，控制台消费监听者打印出了接收到的消息。
至此，实现了简单的点对点的发送接收消息。
完整代码：Github
如果觉得我的文章对您有用，请随意打赏。你的支持将鼓励我继续创作！
