/** 消息接收* */public class ReceiveLogs01 {//交換機(jī)名稱public static final String EXCHANGE_NAME = "logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();//聲明一個隊列,名稱隨機(jī)，當(dāng)消費(fèi)者斷開與隊列的連接時，隊列自動刪除String queueName = channel.queueDeclare().getQueue();//綁定交換機(jī)與隊列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 {//交換機(jī)名稱public static final String EXCHANGE_NAME = "logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();//聲明一個隊列,名稱隨機(jī)，當(dāng)消費(fèi)者斷開與隊列的連接時，隊列自動刪除String queueName = channel.queueDeclare().getQueue();//綁定交換機(jī)與隊列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)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。