Spring Boot 整合 JMS-ActiveMQ，并安装 ActiveMQ

1. 安装 ActiveMQ

1.1 下载 ActiveMQ

访问 ActiveMQ 官方下载页面，根据你的操纵体系选择符合的版本举行下载。这里以 Linux 体系，Java情况1.8版本为例，下载 apache-activemq-5.16.7-bin.tar.gz。
1.2 解压文件

将下载的压缩包解压到指定目次，比方 /opt：

1. tar -zxvf apache-activemq-5.16.7-bin.tar.gz -C /opt

复制代码

1.3 启动 ActiveMQ

进入解压后的目次，启动 ActiveMQ：

1. cd /opt/apache-activemq-5.16.7
2. ./bin/activemq start

复制代码

1.4 验证 ActiveMQ 是否启动乐成

打开欣赏器，访问 http://localhost:8161，使用默认用户名 admin 和暗码 admin 登录 ActiveMQ 的管理控制台。假如能乐成登录，阐明 ActiveMQ 已经启动乐成。

1.4 进入ActiveMQ 管理员控制台

ActiveMQ 启动乐成后，单击 Manage ActiveMQ broker 超链接进入管理员控制台。

2. 创建 Spring Boot 项目并整合 JMS - ActiveMQ

2.1 添加依靠

在 pom.xml 中添加 Spring Boot 集成 ActiveMQ 的依靠：

1. <dependencies>
2.     <!-- Spring Boot Web -->
3.     <dependency>
4.         <groupId>org.springframework.boot</groupId>
5.         <artifactId>spring-boot-starter-web</artifactId>
6.     </dependency>
8.     <!-- Spring Boot JMS -->
9.     <dependency>
10.         <groupId>org.springframework.boot</groupId>
11.         <artifactId>spring-boot-starter-activemq</artifactId>
12.     </dependency>
13. </dependencies>

复制代码

2.2 设置 ActiveMQ

在 application.properties 中设置 ActiveMQ 的毗连信息：

1. server.port=8080
2. # ActiveMQ 服务器地址，默认端口 61616
3. spring.activemq.broker-url=tcp://localhost:61616
4. # 配置信任所有的包，这个配置是为了支持发送对象消息
5. spring.activemq.packages.trust-all=true
6. # ActiveMQ 用户名
7. spring.activemq.user=admin
8. # ActiveMQ 密码
9. spring.activemq.password=admin

复制代码

2.3 创建消息生产者

创建一个消息生产者类，用于发送消息到 ActiveMQ 的队列：

1. import org.springframework.beans.factory.annotation.Autowired;
2. import org.springframework.jms.core.JmsTemplate;
3. import org.springframework.stereotype.Service;
5. import javax.jms.Queue;
7. @Service
8. public class JmsProducer {
10.     @Autowired
11.     private JmsTemplate jmsTemplate;
13.     @Autowired
14.     private Queue queue;
16.     public void sendMessage(String message) {
17.         jmsTemplate.convertAndSend(queue, message);
18.         System.out.println("Sent message: " + message);
19.     }
20. }

复制代码

2.4 创建消息消耗者

创建一个消息消耗者类，用于罗致 ActiveMQ 队列中的消息：

1. import org.springframework.jms.annotation.JmsListener;
2. import org.springframework.stereotype.Component;
4. @Component
5. public class JmsConsumer {
7.     @JmsListener(destination = "test-queue")
8.     public void receiveMessage(String message) {
9.         System.out.println("Received message: " + message);
10.     }
11. }

复制代码

2.5 设置 Queue Bean

在 ActiveMqConfig.java 中界说 队列：

1. import org.apache.activemq.command.ActiveMQQueue;
2. import org.springframework.context.annotation.Bean;
3. import org.springframework.context.annotation.Configuration;
5. import javax.jms.Queue;
7. @Configuration
8. public class ActiveMqConfig {
10.     @Bean
11.     public Queue queue() {
12.         return new ActiveMQQueue("test-queue");
13.     }
14. }

复制代码

2.6 创建 API 测试发送消息

1. import com.weigang.producer.JmsProducer;
2. import org.springframework.beans.factory.annotation.Autowired;
3. import org.springframework.web.bind.annotation.*;
5. @RestController
6. @RequestMapping("/message")
7. public class MessageController {
9.     @Autowired
10.     private JmsProducer producer;
12.     @GetMapping("/send")
13.     public String sendMessage(@RequestParam String msg) {
14.         producer.sendMessage(msg);
15.         return "Message sent: " + msg;
16.     }
17. }

复制代码

然后访问：http://localhost:8080/message/send?msg=HelloActiveMQ
控制台应输出：

1. Sent message: HelloActiveMQ
2. Received message: HelloActiveMQ

复制代码

3. 使用 ActiveMQ Web 界面检察消息

访问 http://localhost:8161/admin/queues.jsp，可以看到 test-queue 队列以及发送的消息。

4. 发送对象消息

在 JmsProducer 发送 对象：

1. import com.weigang.model.CustomMessage;
2. import org.springframework.beans.factory.annotation.Autowired;
3. import org.springframework.jms.core.JmsTemplate;
4. import org.springframework.stereotype.Service;
6. import javax.jms.Queue;
8. @Service
9. public class JmsProducer {
11.     @Autowired
12.     private JmsTemplate jmsTemplate;// 仍然使用 test-queue
14.     @Autowired
15.     private Queue queue;
17.     public void sendMessage(CustomMessage customMessage) {
18.         jmsTemplate.convertAndSend(queue, customMessage);
19.         System.out.println("Sent message----> id：" + customMessage.getId() + ",content：" + customMessage.getContent());
20.     }
21. }

复制代码

创建消息对象：

1. import java.io.Serializable;
3. public class CustomMessage implements Serializable {
5.     private static final long serialVersionUID = 1L; // 推荐添加，避免序列化问题
7.     private String content;
8.     private int id;
10.     // 必须有默认构造方法（JMS 反序列化需要）
11.     public CustomMessage() {}
13.     // 构造方法
14.     public CustomMessage(String content, int id) {
15.         this.content = content;
16.         this.id = id;
17.     }
19.     public String getContent() {
20.         return content;
21.     }
23.     public void setContent(String content) {
24.         this.content = content;
25.     }
27.     public int getId() {
28.         return id;
29.     }
31.     public void setId(int id) {
32.         this.id = id;
33.     }
35.     @Override
36.     public String toString() {
37.         return "CustomMessage{" +
38.                 "content='" + content + '\'' +
39.                 ", id=" + id +
40.                 '}';
41.     }
43. }

复制代码

消耗者处置惩罚对象消息：

1. import com.weigang.model.CustomMessage;
2. import org.springframework.jms.annotation.JmsListener;
3. import org.springframework.stereotype.Component;
5. @Component
6. public class JmsConsumer {
8.     @JmsListener(destination = "test-queue")
9.     public void receiveMessage(String message) {
10.         System.out.println("Received message: " + message);
11.     }
13.     @JmsListener(destination = "test-queue")
14.     public void receiveMessage(CustomMessage message) {
15.         System.out.println("Received object message: " + message.toString());
16.     }
17. }

复制代码

通过 API 发送对象：

1. import com.weigang.model.CustomMessage;
2. import com.weigang.producer.JmsProducer;
3. import org.springframework.beans.factory.annotation.Autowired;
4. import org.springframework.web.bind.annotation.*;
6. @RestController
7. @RequestMapping("/message")
8. public class MessageController {
10.     @Autowired
11.     private JmsProducer producer;
13.     @GetMapping("/send")
14.     public String sendMessage(@RequestParam String msg) {
15.         producer.sendMessage(msg);
16.         return "Message sent: " + msg;
17.     }
19.     @GetMapping("/sendObj")
20.     public String sendMessage(@RequestParam Integer id,@RequestParam String content) {
21.         CustomMessage customMessage = new CustomMessage(content, id);
22.         producer.sendMessage(customMessage);
23.         return "Message sent: " + customMessage;
24.     }
25. }

复制代码

然后访问：http://localhost:8080/message/sendObj?id=1&content=HelloActiveMQ
控制台应输出：

1. Sent message----> id：1,content：HelloActiveMQ
2. Received object message: CustomMessage{content='HelloActiveMQ', id=1}

复制代码

注意事项

• 确保 ActiveMQ 服务器正常运行，而且 application.properties 中的毗连信息精确。
  
• 假如必要使用主题（Topic）举行消息转达，可以在设置中设置 spring.jms.pub-sub-domain=true，并相应地修改消息生产者和消耗者的代码。
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

继续阅读请点击广告