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

<dependency>

     <groupId>org.springframework.boot</groupId>

     <artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

@Bean

     public FanoutExchange myFanoutExchange() {

　 //[my.fanout]仅用于演示，请按自己的项目情况选择合适的、有意义的命名

         return new FanoutExchange( "my.fanout" , true , false );

     }

     @Bean

     public Queue anonymousQueue() {

         //注意：必须使用匿名队列才能达到本文目标，此匿名队列实例的名称在消费端会被使用

         return new AnonymousQueue();

     public Binding bindAnonymousQueue() {

         return BindingBuilder.bind(anonymousQueue()).to(myFanoutExchange());

//构建回调返回的数据

         CorrelationData correlationData = new CorrelationData(UUIDUtils.getUUID());

         Message msg = MessageBuilder.withBody(message.getBytes())

                 .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)

                 .setCorrelationId(correlationData.getId())

                 .build();

         try {

             rabbitTemplate.convertAndSend(exchangeName, null , msg, correlationData);

         } catch (Exception e) {

             logger.error(e.getMessage(), e);

         }

@Service

public class MyListener {

     @RabbitListener (queues = "#{anonymousQueue.name}" )

     public void receive(String message, Message message1, Channel channel) {

         try {

             //your code

         } catch (Exception e) {

             logger.error(e.getMessage(), e);

         } finally {

             long deliverTag = message1.getMessageProperties().getDeliveryTag();

             channel.basicAck(deliverTag, false );

         }

     }

}