RabbitMQ Topic交换机（结果成功）
生活随笔
收集整理的這篇文章主要介紹了
RabbitMQ Topic交换机（结果成功）
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
public class EmitLogTopic {//交換機(jī)的名稱public static final String EXCHANGE_NAME = "topic_logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();HashMap<String, String> map = new HashMap<>();map.put("quick.orange.rabbit","被隊列Q1Q2接收到");map.put("quick.orange.fox","被隊列Q1接收到");map.put("lazy.brown.fox","被隊列Q2接收到 ");map.put("lazy.pink.rabbit","雖然滿足隊列Q2的兩個綁定但是只會被接收一次");map.put("quick.orange.male.rabbit","四個單詞不匹配任何綁定會被丟棄");for (Map.Entry<String, String> bindingKeyEntry : map.entrySet()) {String routingKey = bindingKeyEntry.getKey();String message = bindingKeyEntry.getValue();channel.basicPublish(EXCHANGE_NAME,routingKey,null,message.getBytes(StandardCharsets.UTF_8));System.out.println("生產(chǎn)者發(fā)送消息："+ message );}}
}
總結(jié)
以上是生活随笔為你收集整理的RabbitMQ Topic交换机（结果成功）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： RabbitMQ Topic交换机（生产
- 下一篇： RabbitMQ死信队列代码架构图