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);
        }
    }
}