/* * 聲明主題交換機(jī)及相關(guān)隊(duì)列 * 消費(fèi)者C1 * */ public class ReceiveLogsTopic01 {//交換機(jī)名稱(chēng)public static final String EXCHANGE_NAME = "topic_logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();//聲明交換機(jī)channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);//聲明隊(duì)列String queueName = "Q1";channel.queueDeclare(queueName,false,false,false,null);//隊(duì)列捆綁channel.queueBind(queueName,EXCHANGE_NAME,"*.orange.*");System.out.println("等待接收消息......");DeliverCallback deliverCallback = (consumerTag,message) -> {System.out.println(new String(message.getBody()));System.out.println("接收隊(duì)列："+ queueName + "綁定鍵：" + message.getEnvelope().getRoutingKey());};//接收消息channel.basicConsume(queueName,true,deliverCallback,consumerTag -> {});} }

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ Topic交换机（生产者）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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