德阳市网站建设品牌建设典型案例材料

rabbitmq一共有三种交换机：

1. fanout--广播
2. direct--定向
3. topic--话题

rabbitmq-web端

首先我们需要建立一个名叫cybg.fanout交换机与两个自定义的队列用于测试广播效果

我这里就起名字叫做fanout_queue1&fanout_queue2

项目中：

首先对我们的Listener加入对上面两个队列的监听

@RabbitListener(queues = "fanout_queue1")
public void fanoutQ1(String msg) throws InterruptedException {System.out.println("fanout1接收到的msg："+msg);Thread.sleep(20);
}@RabbitListener(queues = "fanout_queue2")
public void fanoutQ2(String msg) throws InterruptedException {System.out.println("fanout2接收到的msg："+msg);Thread.sleep(20);
}

然后我们可以在springtest中添加对于发消息的demo

@Test
void testSendMsgToFanout(){String exchangeName = "cybg.fanout";String msg = "fanout everyone";rabbitTemplate.convertAndSend(exchangeName,null,msg);
}

这里和直接发送到队列不同的是，此处的参数变为了交换机名字、routeKey、message

运行listener服务可以发现我们的队列已经可以拿到我们对交换机发送的消息

fanout1接收到的msg：fanout everyone
fanout2接收到的msg：fanout everyone