SpringBoot集成RabbitMQ,消息队列
2019-05-12 15:44
405 查看
版权声明:本文为博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yan95520/article/details/90141095
SpringBoot集成RabbitMQ
一、新建SpringBoot项目
File → New Project →Spring Initializr → Next
二、配置文件编写
留意pom.xml文件有无此包,没有要加上去
配置application.properties文件,配置rabbitmq的安装地址、端口以及账户信息
三、生成队列
四、创建生产者
五、创建第一个消费者
六、编写测试类
结果是生成了两个队列,都只有一个队列在工作,因为第一个生产者只路由了”queue1”
七、编写第二个消费者,测试一对多模式
八、测试类中添加方法
//一对多
@Test public void oneToMany() throws Exception {
for (int i=0;i<50;i++){ firstProducer.send(i); Thread.sleep(300); }
}
测试结果
九、注意事项
由于我的包都不是在启动类下,所以需要扫描其他包,不然会注入类失败!!
相关文章推荐
- Spring集成rabbitMQ监听消费队列消息
- SpringBoot:初探 RabbitMQ 消息队列
- SpringBoot利用redis集成消息队列
- springboot 集成rabbitmq 并采用ack模式 以及封装队列定义
- 消息队列RabbitMQ与Spring集成
- Spring集成消息队列RabbitMQ
- SpringBoot的RabbitMQ消息队列: 二、第一模式"Hello World!"
- 消息队列RabbitMQ与Spring集成
- 消息队列RabbitMQ与Spring集成
- Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
- 消息队列RabbitMQ与Spring集成
- SpringBoot的RabbitMQ消息队列: 五、第四模式"Routing"
- Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
- spring boot 自学笔记(五) Rabbitmq集成,延时消息队列实现
- SpringBoot集成RabbitMQ的方法(死信队列)
- SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象
- [2017-10-25]Abp系列——集成消息队列功能(基于Rebus.Rabbitmq)
- SpringBoot的RabbitMQ消息队列: 五、第四模式"Routing"
- Spring集成消息队列RabbitMQ(消息失败处理)
- Spring集成消息队列RabbitMQ