1、簡介
Fanout，英文翻譯是扇出。
2、 特點
1） ?可以有多個隊列
2） ?每個隊列都要綁定到Exchange（交換機）
3） ?生產(chǎn)者發(fā)送的消息，只能發(fā)送到交換機
4） ?交換機把消息發(fā)送給綁定過的所有隊列
5） ?訂閱隊列的消費者都能拿到消息
?3、設置隊列
4、設置交換機
5、綁定隊列
?6、設置生產(chǎn)者
@Test
void testSendFanout() {
String exchangeName = "test.fanout";
String msg = "hello, everyone!";
rabbitTemplate.convertAndSend(exchangeName, null, msg);
}7、設置消費者
@RabbitListener(queues = "fanout.queue1")
public void listenFanoutQueue1(String msg) throws InterruptedException {
System.out.println("消費者1 收到了 fanout.queue1的消息----：【" + msg +"】");
}
@RabbitListener(queues = "fanout.queue2")
public void listenFanoutQueue2(String msg) throws InterruptedException {
System.out.println("消費者2 收到了 fanout.queue2的消息====：【" + msg +"】");
}8、測試
9、總結(jié)
交換機的作用是什么？
接收publisher發(fā)送的消息
將消息按照規(guī)則路由到與之綁定的隊列
不能緩存消息，路由失敗，消息丟失文章來源：http://www.zghlxwxcb.cn/news/detail-823181.html
FanoutExchange會將消息路由到每個綁定的隊列文章來源地址http://www.zghlxwxcb.cn/news/detail-823181.html
到了這里，關(guān)于rabbitmq基礎-java-3、Fanout交換機的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
