RabbitMQ fanout交换机（消费者）
生活随笔
收集整理的這篇文章主要介紹了
RabbitMQ fanout交换机（消费者）
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
/** 消息接收* */public class ReceiveLogs01 {//交換機名稱public static final String EXCHANGE_NAME = "logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();//聲明一個隊列,名稱隨機，當消費者斷開與隊列的連接時，隊列自動刪除String queueName = channel.queueDeclare().getQueue();//綁定交換機與隊列channel.queueBind(queueName,EXCHANGE_NAME,"");System.out.println("等待接受消息，把接受到的消息打印在屏幕上...");DeliverCallback deliverCallback = (consumerTag,message) -> {System.out.println("ReceiveLogs01控制臺打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume(queueName,true,deliverCallback,consumerTag -> {});}
}
/** 消息接收* */public class ReceiveLogs02 {//交換機名稱public static final String EXCHANGE_NAME = "logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();//聲明一個隊列,名稱隨機，當消費者斷開與隊列的連接時，隊列自動刪除String queueName = channel.queueDeclare().getQueue();//綁定交換機與隊列channel.queueBind(queueName,EXCHANGE_NAME,"");System.out.println("等待接受消息，把接受到的消息打印在屏幕上...");DeliverCallback deliverCallback = (consumerTag,message) -> {System.out.println("ReceiveLogs02控制臺打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume(queueName,true,deliverCallback,consumerTag -> {});}
}
總結(jié)
以上是生活随笔為你收集整理的RabbitMQ fanout交换机（消费者）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： RabbitMQ Fanout
- 下一篇： RabbitMQ fanout交换机（生