spring boot操作rabbitmq的发布订阅队列示例

 

项目基础结构参考:

spring boot操作rabbitmq的简单队列示例

生产者(发布者)源码:https://gitee.com/constfafa/rabbitmq-producer-pub-sub-queue

消费者1源码:https://gitee.com/constfafa/rabbitmq-consumer-pub-sub-queue01

消费者2源码:https://gitee.com/constfafa/rabbitmq-consumer-pub-sub-queue02

工作过程:

生产者每个1秒将消息发送给rabbitmq的fanout类型的Exchange上,fanout不处理路由routingkey,只要与之绑定的队列都能收到消息。

两个消费者声明不同的队列队列,并绑定到Exchange上

注意:exchanger没有存储消息的能力,只有队列有存储消息的能力。所以在测试的时候,要先将两个consumer启动起来,之后再启动producer。

Rabbitmq的效果:

结果:

生产者

消费者1:

 

消费者2:

 

 

 

 


版权声明:本文为u013905744原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。