springboot整合ActiveMQ1（基本使用）

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

基本使用,https://www.tapme.top/blog/detail/2018-09-05-10-38
主备模式,https://www.tapme.top/blog/detail/2018-09-06-10-38

说明：acitveMQ 版本为：5.9.1，springboot 版本为 2.0.3

一. 下载安装（windows）

官方下载地址:点我跳转,选择 windows 安装包下载,然后解压，解压后运行 bin 目录下的activemq.bat启动服务,无报错即可启动成功。默认管理地址为：localhost:8161/admin,默认管理员账号密码为admin/admin。

二. springboot 整合

1. 创建 springboot 项目

创建 springboot web 项目，加入 spring-boot-starter-activemq 依赖。

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>

然后编辑配合文件，加上一个配置：61616 为 activeMQ 的默认端口，暂时不做其他配置，使用默认值。

spring: activemq: broker-url: tcp://localhost:61616

2. 创建生产者消费者

springboot 中 activeMQ 的默认配置为生产-消费者模式，还有一种模式为发布-订阅模式后面再讲。项目目录如下：

首先编写配置类 Config.java，代码如下

@Configuration public class Config { @Bean(name = "queue2") public Queue queue2(){ return new ActiveMQQueue("active.queue2"); } @Bean(name = "queue1") public Queue queue1(){ return new ActiveMQQueue("active.queue1"); } }

上面的代码建立了两个消息队列 queue1，queue2,分别由 queue1 和 queue2 这两个 Bean 注入到 Spring 容器中。程序运行后会在 activeMQ 的管理页面->queue 中看到如下：

生产者 Producer.java 代码如下：

@RestController public class Producer { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @Autowired() @Qualifier("queue2") private Queue queue2; @Autowired() @Qualifier("queue1") private Queue queue1; @GetMapping("/queue2") public void sendMessage1(String message){ jmsMessagingTemplate.convertAndSend(queue2,"I'm from queue2:"+message); } @GetMapping("/queue1") public void sendMessage2(String message){ jmsMessagingTemplate.convertAndSend(queue1,"I'm from queue1:"+message); } }

上面的类创建了两个 GET 接口，访问这两个接口分别向 queue1 和 queue2 中发送消息。

消费者 Comsumer.java 代码如下：

@Component //将该类注解到Spring 容器中 public class Comsumer { //接受消息队列1消息 @JmsListener(destination = "active.queue1") //监听active.queue1消息队列 public void readActiveQueue11(String message){ System.out.println(1+message); } //接受消息队列1消息 @JmsListener(destination = "active.queue1") public void readActiveQueue12(String message){ System.out.println(2+message); } //接受消息队列2消息 @JmsListener(destination = "active.queue2") public void readActiveQueue21(String message){ System.out.println(1+message); } //接受消息队列2消息 @JmsListener(destination = "active.queue2") public void readActiveQueue22(String message){ System.out.println(2+message); } }