使用springboot整合

使用 Spring Boot 整合 RabbitMQ 的 Fanout Exchange 分为以下几个步骤：

1. 在 pom.xml 中添加 RabbitMQ 的依赖。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 在 application.properties 或 application.yml 中配置 RabbitMQ 的连接信息。

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建一个 Fanout 类型的 Exchange。

@Configuration
public class RabbitConfig {
    @Bean
    public FanoutExchange myFanoutExchange() {
        return new FanoutExchange("my_fanout_exchange");
    }
}

4. 创建一个队列并绑定到 Fanout Exchange 上。

@Configuration
public class RabbitConfig {
    @Bean
    public Queue myQueue() {
        return new AnonymousQueue();
    }

    @Bean
    public Binding binding(FanoutExchange myFanoutExchange, Queue myQueue) {
        return BindingBuilder.bind(myQueue).to(myFanoutExchange);
    }
}

在绑定队列时，使用 `AnonymousQueue` 创建一个匿名的队列，这样就不需要手动指定队列名称。

5. 发布消息到 Fanout Exchange 上。

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendMessage() {
    rabbitTemplate.convertAndSend("my_fanout_exchange", "", "Hello, World!");
}

在发布消息时，由于 Fanout Exchange 会将消息广播给所有绑定的队列，所以不需要指定 Routing Key。

6. 消费者从队列中消费消息。

@Component
public class MyConsumer {
    @RabbitListener(queues = "#{myQueue.name}")
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在消费消息时，使用 `@RabbitListener` 注解指定队列的名称，这里使用 SpEL 表达式获取到队列的名称。

这样，就可以使用 Spring Boot 整合 RabbitMQ 的 Fanout Exchange 实现消息的广播。