public class EmitLogTopic {//交換機的名稱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("生產者發(fā)送消息："+ message );}} }

總結

以上是生活随笔為你收集整理的RabbitMQ Topic交换机（结果成功）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。