可以在公司局域网做网站吗,做网站都需要哪些软件,苏州画廊网站建设,1688官网app下载rabbitmq一共有三种交换机#xff1a;
fanout--广播direct--定向topic--话题
rabbitmq-web端
首先我们需要建立一个名叫cybg.fanout交换机与两个自定义的队列用于测试广播效果
我这里就起名字叫做fanout_queue1fanout_queue2
项目中#xff1a;
首先对我们的Liste…rabbitmq一共有三种交换机
fanout--广播direct--定向topic--话题
rabbitmq-web端
首先我们需要建立一个名叫cybg.fanout交换机与两个自定义的队列用于测试广播效果
我这里就起名字叫做fanout_queue1fanout_queue2
项目中
首先对我们的Listener加入对上面两个队列的监听
RabbitListener(queues fanout_queue1)
public void fanoutQ1(String msg) throws InterruptedException {System.out.println(fanout1接收到的msgmsg);Thread.sleep(20);
}RabbitListener(queues fanout_queue2)
public void fanoutQ2(String msg) throws InterruptedException {System.out.println(fanout2接收到的msgmsg);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接收到的msgfanout everyone
fanout2接收到的msgfanout everyone
