广播交换机的特定是: 将消息交给所有绑定到交换机的队列
在广播模式下，消息发送流程是这样的：
1） 可以有多个队列
2） 每个队列都要绑定到 Exchange（交换机）
3） 生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法决定
4） 广播类型的交换机会把消息发送给绑定过的所有队列
5） 订阅队列的消费者都能拿到消息
我们的计划是这样的：
- 创建一个交换机 test2024.fanoutExchange，类型是Fanout
- 创建两个队列 test2024.fanout.queue1 和 test2024.fanout.queue2 ，绑定到交换机 test2024.fanoutExchange
声明交换机
Spring提供了一个接口Exchange，来表示所有不同类型的交换机：
首先我们在配置类 声明处我们所需要的交换机和队列 并绑定其关系
// 声明一个广播类型的交换机/ 广播交换机特点 : 将消息交给所有绑定到交换机的队列 @Bean public FanoutExchange testFanoutExchange() { return new FanoutExchange("test2024.fanoutExchange"); } /** 声明两个队列 和 广播交换机绑定 */ @Bean public Queue testQueue1() { return new Queue("test2024.fanout.queue1"); } @Bean public Queue testQueue2() { return new Queue("test2024.fanout.queue2");} @Bean public Binding bindingTestQueue1FanoutExchange(Queue testQueue1, FanoutExchange testFanoutExchange) { return BindingBuilder.bind(testQueue1).to(testFanoutExchange); } @Bean public Binding bindingTestQueue2FanoutExchange(Queue testQueue2, FanoutExchange testFanoutExchange) { return BindingBuilder.bind(testQueue2).to(testFanoutExchange); } /** 声明两个队列 和 广播交换机绑定 */
消息接收
@RabbitListener(queues = "test2024.fanout.queue1") public void rabbitListener3(String message) { System.out.println("监听广播类型交换机的1-接收到消息:" + message); } @RabbitListener(queues = "test2024.fanout.queue2") public void rabbitListener4(String message) { System.out.println("监听广播类型交换机的2-接收到消息:" + message); }
消息发送
// 测试广播交换机 @Test public void test02(){ rabbitTemplate.convertAndSend("test2024.fanoutExchange", "", "this is a message from fanout!"); }
效果
至此 就实现了 Fanout 交换机的演示.
