内容简介:在spring-boot中使用ActiveMQ相当的简单引入依赖添加配置文件
在spring-boot中使用ActiveMQ相当的简单
引入依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
添加配置文件
spring: activemq: broker-url: tcp://localhost:61616
spring-boot里也可以进行数据连接池的配置,这个之前几篇博客已经都配置好了,这里就不做配置了
消息提供者
@Service("producer") public class Producer { @Autowired private JmsMessagingTemplate jmsTemplate; // 发送消息,destination是发送到的队列,message是待发送的消息 public void sendMessage(Destination destination, String message) { jmsTemplate.convertAndSend(destination, message); } }
消息消费者1
@Component public class Consumer1 { // 使用JmsListener配置消费者监听的队列,其中text是接收到的消息 @JmsListener(destination = "amq-demo") public void receiveQueue(String text) { System.out.println("Consumer1: " + text); } }
消息消费者2
@Component public class Consumer2 { // 使用JmsListener配置消费者监听的队列,其中text是接收到的消息 @JmsListener(destination = "amq-demo") public void receiveQueue(String text) { System.out.println("Consumer2: " + text); } }
消息消费者3
@Component public class Consumer3 { @JmsListener(destination = "amq-demo2") public void consumerMessage(String text) { System.out.println("收到来自amq-demo2队列的消息: " + text); } }
test方法
@RunWith(SpringRunner.class) @SpringBootTest public class DemoApplicationTests { @Autowired private Producer producer; @Test public void contextLoads() { Destination destination = new ActiveMQQueue("amq-demo"); for (int i = 1; i <= 5; i++) { producer.sendMessage(destination, "Producer消息" + i); } } }
运行结果
说明
- 提供者发送消息到ActiveMQ服务器里
- 消费者1和消费者2同时消费数据,它们不会重复消费,既有一个消费者把消息消费了,其它消费者就不会再消费这条数据了
- 消费者2消费数据的同时还将消息重新发出(这里的意思应该是消费者2临时充当了消息提供者的角色了,这个功能可以处理一些复杂的,一个消费者处理不完的消息,或者处理一些消息后,还有后续的操作的业务)
- 消费者3监听消费者2发出的消息然后进行消费
注意,运行test方法进行测试前要先启动 ActiveMQ
原文链接:
以上所述就是小编给大家介绍的《ActiveMQ学习-与spring整合,在spring-boot中使用 (5)》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- SpringBoot Kafka 整合使用
- SpringBoot RabbitMQ 整合使用
- SpringBoot ActiveMQ 整合使用
- SpringBoot RabbitMQ 整合使用
- Redis和Lua初步整合使用
- redis与spring整合使用的步骤实例教程
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。