网站建设工具 公司,模型网站,比亚迪新能源汽车报价大全一览表,如何选择安卓app开发工具1.Topic模式
RabbitMQ的Topic模式是一种基于主题的消息传递模式。它允许发送者向一个特定的主题#xff08;topic#xff09;发布消息#xff0c;同时#xff0c;订阅者也可以针对自己感兴趣的主题进行订阅。
在Topic模式中#xff0c; 主题通过一个由单词和点号组成的字…1.Topic模式
RabbitMQ的Topic模式是一种基于主题的消息传递模式。它允许发送者向一个特定的主题topic发布消息同时订阅者也可以针对自己感兴趣的主题进行订阅。
在Topic模式中 主题通过一个由单词和点号组成的字符串来描述。例如“#.china”表示匹配所有以“china”为结尾的主题比如“bj.china”或“china”等。 ‘ # ’ 和 ‘ * ’ 会再后面介绍
当一个消息被发布到Topic交换机Exchange时交换机会将消息转发给所有与该主题匹配的队列。消费者即订阅者可以对队列进行绑定通过指定自己感兴趣的主题进行绑定。
通过使用Topic模式我们可以实现高度灵活的信息交换模式同时确保只有感兴趣的消费者才会收到消息提高了系统的效率和可靠性。
*匹配1个#匹配0个或多个当一个队列绑定键是#那么这个队列将接收所有数据就有点像 fanout 了如果队列绑定键当中没有#和*出现那么该队列绑定类型就是 direct 了
2. 生产者 package com.hong.rabbitmq8;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;/*** Description: Topic模式生产者* Author: hong* Date: 2024-01-16 20:09* Version: 1.0**/
public class TopicSend {private static final String EXCHANGE_NAME topic_logs;public static void main(String[] args) throws Exception {Channel channel RabbitMQUtil.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);MapString, String bindingKeyMap new HashMap();bindingKeyMap.put(quick.orange.rabbit, 被队列 Q1Q2 接收到);bindingKeyMap.put(lazy.orange.elephant, 被队列 Q1Q2 接收到);bindingKeyMap.put(quick.orange.fox, 被队列 Q1 接收到);bindingKeyMap.put(lazy.brown.fox, 被队列 Q2 接收到);bindingKeyMap.put(lazy.pink.rabbit, 虽然满足两个绑定但只被队列 Q2 接收一次);bindingKeyMap.put(quick.brown.fox, 不匹配任何绑定不会被任何队列接收到会被丢弃);bindingKeyMap.put(quick.orange.male.rabbit, 是四个单词不匹配任何绑定会被丢弃);bindingKeyMap.put(lazy.orange.male.rabbit, 是四个单词但匹配 Q2);for (Map.EntryString, String bindingKeyEntry : bindingKeyMap.entrySet()) {String bindingKey bindingKeyEntry.getKey();String message bindingKeyEntry.getValue();channel.basicPublish(EXCHANGE_NAME, bindingKey, null, message.getBytes(StandardCharsets.UTF_8));System.out.println(消息发送完成------ bindingKey message);}}
}3.消费者1
package com.hong.rabbitmq8;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.nio.charset.StandardCharsets;/*** Description: Topic模式接受者1-接收*.orange.** Author: hong* Date: 2024-01-16 20:07* Version: 1.0**/
public class TopicReceiver1 {public static final String EXCHANGE_NAME topic_logs;public static void main(String[] args) throws Exception {Channel channel RabbitMQUtil.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);String queueName Q1;channel.queueDeclare(queueName,false,false,false,null);channel.queueBind(queueName,EXCHANGE_NAME,*.orange.*);DeliverCallback deliverCallback (comsumerTag, message) - {System.out.println(接收队列: queueName ,routingKey: message.getEnvelope().getRoutingKey() ,消息: new String(message.getBody(), StandardCharsets.UTF_8));};CancelCallback cancelCallback var - {};channel.basicConsume(queueName,true,deliverCallback,cancelCallback);}
}4.消费者2
package com.hong.rabbitmq8;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.nio.charset.StandardCharsets;/*** Description: Topic模式接受者1-接收*.*.rabbit和lazy.#* Author: hong* Date: 2024-01-16 20:07* Version: 1.0**/
public class TopicReceiver2 {public static final String EXCHANGE_NAME topic_logs;public static void main(String[] args) throws Exception {Channel channel RabbitMQUtil.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);String queueName Q2;channel.queueDeclare(queueName,false,false,false,null);channel.queueBind(queueName,EXCHANGE_NAME,*.*.rabbit);channel.queueBind(queueName,EXCHANGE_NAME,lazy.#);DeliverCallback deliverCallback (comsumerTag, message) - {System.out.println(接收队列: queueName ,routingKey: message.getEnvelope().getRoutingKey() ,消息: new String(message.getBody(), StandardCharsets.UTF_8));};CancelCallback cancelCallback var - {};channel.basicConsume(queueName,true,deliverCallback,cancelCallback);}
}例子说明quick.orange.rabbit被队列 Q1Q2 接收到lazy.orange.elephant被队列 Q1Q2 接收到quick.orange.fox被队列 Q1 接收到lazy.brown.fox被队列 Q2 接收到lazy.pink.rabbit虽然满足两个绑定但只被队列 Q2 接收一次quick.brown.fox不匹配任何绑定不会被任何队列接收到会被丢弃quick.orange.male.rabbit是四个单词不匹配任何绑定会被丢弃lazy.orange.male.rabbit是四个单词但匹配 Q2
