SpringBoot 整合 ActiveMQ
PPG007 ... 2021-12-27 About 1 min
# SpringBoot 整合 ActiveMQ
# 导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
<version>2.4.5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.4.5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
<version>2.4.5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>2.4.5</version>
</dependency>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
# 编写配置文件
server:
port: 8848
spring:
activemq:
broker-url: tcp://150.158.153.216:61616
user: admin
password: admin
jms:
#设置为false表示使用队列，否则表示使用主题
pub-sub-domain: false
queueName: SpringBootQueue
topicName: SpringBootTopic
1
2
3
4
5
6
7
8
9
10
11
12
13
2
3
4
5
6
7
8
9
10
11
12
13
# 启动类修改
在主启动类上添加 @EnableJms 注解。
# 使用队列
SpringBoot中 使用 JmsMessagingTemplate 完成操作。
# 发送端
@SpringBootTest(classes = SpringBootStarter.class)
public class MyTest {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired
private Queue queue;//自定义一个队列对象
@Test
public void sender() {
jmsMessagingTemplate.convertAndSend(queue,"蚌埠住了");
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# 接收端
System.out.println(jmsMessagingTemplate.receiveAndConvert("SpringBootQueue",String.class));
1
# 设置监听器
注册一个组件，在方法上添加 @JmsListener 注解并制定目的地，template 会监听消息。
@Component
public class Receiver {
@JmsListener(destination = "${queueName}")
public void receive(Message message) throws JMSException {
if (message instanceof TextMessage){
TextMessage textMessage = (TextMessage) message;
System.out.println(textMessage.getText());
}
}
}
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
# 使用主题
# 修改配置
jms:
pub-sub-domain: true
1
2
2
# 发送端
与队列用法一致。
public void send(){
jmsMessagingTemplate.convertAndSend(topic,"主题");
}
1
2
3
2
3
# 接收端
接收端同样使用注解创建监听器。
@JmsListener(destination = "${topicName}")
public void topicReceive(Message message) throws JMSException {
if (message instanceof TextMessage){
TextMessage textMessage = (TextMessage) message;
System.out.println(textMessage.getText());
}
}
1
2
3
4
5
6
7
2
3
4
5
6
7