Spring Boot+RabbitMQ 通过fanout模式实现消息接收(支持消费者多实例部署)

Spring Boot+RabbitMQ 通过fanout模式实现消息接收(支持消费者多实例部署)

  本文章适用的场景:同一条消息可以被多个消费者同时消费。注意:当消费者多实例部署时,会轮询消费消息。网上有大量的的案例展示:P生产一条消息,消费者服务C中建立Q1和Q2两个队列共同消费。但极少的材料展示:P生产一条消息后M1,消费者C1和C2可以同时消费M1,如下图所示。案例基于Spring Boot以及RabbitMQ的“fanout”类型exchange。已经实测可放心使用。

 

 1、引入基本依赖,项目不同请您按自己的情况引入合适的依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
hmoban主题是根据ripro二开的主题,极致后台体验,无插件,集成会员系统
自学咖网 » Spring Boot+RabbitMQ 通过fanout模式实现消息接收(支持消费者多实例部署)