動(dòng)態(tài)路由就是我們可以通過(guò)一定匹配規(guī)則來(lái)綁定交換機(jī)與通道
*表示一個(gè)單詞
#表示一個(gè)或者多個(gè)單詞

生產(chǎn)者

package com.zuoan.topics;import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.zuoan.utils.RabbitMQUtils;import java.io.IOException;/*** @Description: TODO* @Author: 黃石軍* @CreateTime: 2022/4/10 16:15* @Company:*/ public class Provider {public static void main(String[] args) throws IOException {Connection connection = RabbitMQUtils.getConnection("192.168.188.100");Channel channel = connection.createChannel();//參數(shù)一交換機(jī)名稱(chēng)，參數(shù)二，交換機(jī)類(lèi)型channel.exchangeDeclare("topics","topic");//發(fā)送消息String routingKey = "user.save";channel.basicPublish("topics",routingKey,null,("這是topic發(fā)布的routingKey:["+routingKey+"]發(fā)送的消息").getBytes());//關(guān)閉資源RabbitMQUtils.closeChannelAndConnection(channel,connection);} }

消費(fèi)者1

package com.zuoan.topics;import com.rabbitmq.client.*; import com.zuoan.utils.RabbitMQUtils;import java.io.IOException;/*** @Description: TODO* @Author: 黃石軍* @CreateTime: 2022/4/10 16:37* @Company:*/ public class Consumer1 {public static void main(String[] args) throws IOException {Connection connection = RabbitMQUtils.getConnection("192.168.188.100");Channel channel = connection.createChannel();channel.exchangeDeclare("topics","topic");//創(chuàng)建臨時(shí)隊(duì)列String queue = channel.queueDeclare().getQueue();//臨時(shí)隊(duì)列綁定交換機(jī)channel.queueBind(queue,"topics","user.*");//消費(fèi)消息channel.basicConsume(queue,true,new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("消費(fèi)者1"+new String(body));}});} }

消費(fèi)者2

package com.zuoan.topics;import com.rabbitmq.client.*; import com.zuoan.utils.RabbitMQUtils;import java.io.IOException;/*** @Description: TODO* @Author: 黃石軍* @CreateTime: 2022/4/10 16:48* @Company:*/ public class Consumer2 {public static void main(String[] args) throws IOException {Connection connection = RabbitMQUtils.getConnection("192.168.188.100");Channel channel = connection.createChannel();channel.exchangeDeclare("topics","topic");String queue = channel.queueDeclare().getQueue();//隊(duì)列綁定交換機(jī)channel.queueBind(queue,"topics","user.#");//消費(fèi)消息channel.basicConsume(queue,true,new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("消費(fèi)者2"+ new String(body));}});} }

工具類(lèi)在我們博客分類(lèi)MQ中第一章里
https://blog.csdn.net/weixin_45886609/article/details/124064801

總結(jié)

以上是生活随笔為你收集整理的rabbitMQ第五种模型 --topic动态路由的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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