SpringBoot整合ActiveMQ

队列一对一

队列生产者

2pom依赖(最关键的)

 3yml中

 4配置Bean

5 队列生产者编写

这里会调用Spring包下的模板,生成队列

 自动注入即可,再将Bean里面注入进来,再产生消息

6主启动类

 7测试单元

先在配置上开启注解

 

 成功发送

当然除了正常生产之外,还有很多操作只是自己更改方法即可如

 增加了注解然后在主启动类开启注解即可

队列消费者

 pom和yml基本一致,粘贴即可

不过肯定要改一下端口,改成消费者端口

 然后编写队列的消费者(监听)

 主启动类,

 启动之后springboot的监听器注解开始监听工作

 主题

主题生产者

 pub-sub-domain改为true了因为是topic

 配置Bean

 推送消费者的编写

 主启动类

 topic消费者

yml基本也不会变,除了端口

 

消费者的编写和队列一样的

原文地址:https://www.cnblogs.com/yangj-Blog/p/13254290.html