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); }
}
测试结果
九、注意事项
由于我的包都不是在启动类下,所以需要扫描其他包,不然会注入类失败!!
源码:https://download.csdn.net/download/yan95520/11174024