RabbitMQ入门学习系列(六) Exchange的Topic类型

快速阅读

介绍exchange的topic类型，和Direct类型相似，但是增加了".“和”#"的匹配。比Direct类型灵活

Topic消息类型

特点是：topic消息类型不能是任意的routing key, 必须是有点"."组成的单词列表。

和dirct类似，最后也是也相应的key进行匹配

例如：speed.color.sepcies

注意可以用*号和#号出现，和我们日常用的正则表达式含义相近

"*"号代表任意一个单词

"#"号代表0个或多个单词

生产者代码

创建连接和信道
声明exchange类型
设置两个routingkey 各自发送两次。一共发送四条消息

static void Main(string[] args)
{var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){channel.ExchangeDeclare(exchange: "topicType", type: "topic");var list = new List<string>();list.Add("www.baidu.com");list.Add("www.google.com");for (var i = 0; i < 2; i++){var routingKey = list[0];string message = "Hello World!this  message routingkey is  " + routingKey;var body = Encoding.UTF8.GetBytes(message);var properties = channel.CreateBasicProperties();properties.Persistent = true;channel.BasicPublish(exchange: "topicType",routingKey: routingKey,basicProperties: null,body: body);Console.WriteLine(" [x] Sent {0},id={1}", message,i);Thread.Sleep(1000);}for (var i = 0; i < 2; i++){var routingKey = list[1];string message = "Hello World!this  message routingkey is  " + routingKey;var body = Encoding.UTF8.GetBytes(message);var properties = channel.CreateBasicProperties();properties.Persistent = true;channel.BasicPublish(exchange: "topicType",routingKey: routingKey,basicProperties: null,body: body);Console.WriteLine(" [x] Sent {0},id={1}", message, i);Thread.Sleep(1000);}}Console.WriteLine(" Press [enter] to exit.");Console.ReadLine();
}

消费者代码

创建连接和信道
为了测试 topic 类型，限制输入中含有baidu,google两个关键词和发送的routing key相匹配。
声明交换器类型
队列声明
把exchange和队列绑定到信道上
接受消息

static void Main(string[] args)
{bool flag = true;string level = "";while (flag){Console.WriteLine("请选择要查看的消息类型");level = Console.ReadLine();if (level.IndexOf(".baidu.")>0 || level.IndexOf(".google.") > 0 )flag = false;elseConsole.Write("不支持你输入的消息");}var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){channel.ExchangeDeclare(exchange: "topicType", type: "topic");var queueName = channel.QueueDeclare().QueueName;channel.QueueBind(queue: queueName, exchange: "topicType", routingKey: level);//以下是区别生产者的var consumer = new EventingBasicConsumer(channel);consumer.Received += (sender, e) =>{var body = e.Body;var message = Encoding.UTF8.GetString(body);var rk = e.RoutingKey;Console.WriteLine("Received {0},routingKey:{1}", message, rk);Thread.Sleep(3000);//模拟耗时任务 ，Console.WriteLine("Received over");channel.BasicAck(deliveryTag: e.DeliveryTag, multiple: false);};channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer);Console.WriteLine("");Console.ReadLine();}}

测试结果

我们启动消费者以后，输入四个routingkey去测试

分别是

.google.#， #.google. , *.google.com, *.baidu.com

分别监听中间是google 或者baidu的消息

结果符合要求

RabbitMQ入门学习系列(六) Exchange的Topic类型相关推荐

RabbitMQ入门学习系列(五) Exchange的Direct类型
快速阅读利用Exchange的Direct类型,实现对队列的过滤,消费者启动以后,输入相应的key值,攻取该key值对应的在队列中的消息 . 从一节知道Exchange有四种类型 Direct,To ...
RabbitMQ入门学习系列(二)，单生产者消费者
友情提示我对我的文章负责,发现好多网上的文章没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题.可以直接在公众号<爱码农爱生活 >留言.必定会再次 ...
RabbitMQ入门学习系列(四) 发布订阅模式
什么时发布订阅模式把消息发送给多个订阅者.也就是有多个消费端都完整的接收生产者的消息换句话说把消息广播给多个消费者消息模型的核心 RabbitMQ不发送消息给队列,生产者也不知道消息发送到队列 ...
RabbitMQ入门学习系列(三).消息发送接收
快速阅读用Rabitmq的队列管理,以及如何保证消息在队列中不丢失.通过ack的消息确认和持久化进行操作.以及Rabbit中如何用Web面板进行管理队列.消费者如何处理耗时的任务生产者代码创建链接 ...
RabbitMQ（五）：Exchange交换器--topic
内容翻译自:RabbitMQ Tutorials Java版 RabbitMQ(一):Hello World程序 RabbitMQ(二):Work Queues.循环分发.消息确认.持久化.公平分发 ...
Android音视频学习系列(六) — 掌握视频基础知识并使用OpenGL ES 2.0渲染YUV数据
系列文章 Android音视频学习系列(一) - JNI从入门到精通 Android音视频学习系列(二) - 交叉编译动态库.静态库的入门 Android音视频学习系列(三) - Shell脚本入门 ...
Asp.Net MVC5入门学习系列⑤
Asp.Net MVC5入门学习系列⑤ 原文:Asp.Net MVC5入门学习系列⑤ 检查VS生产的编辑方法和编辑窗体前面我们一步使用强类型,然后创建Controller(控制器)的时候,VS默认已 ...
Asp.Net MVC5入门学习系列⑥
Asp.Net MVC5入门学习系列⑥ 原文:Asp.Net MVC5入门学习系列⑥ 接着上次的篇幅,我们这篇手动来写一个查询的流程代码! 搜索/查询流程功能的实现那现在要做搜索(查询)功能我们第 ...
WPF入门学习----系列基础教程
WPF入门教程系列目录 WPF入门教程系列二--Application介绍 WPF入门教程系列三--Application介绍(续) WPF入门教程系列四--Dispatcher介绍 WPF入门教程系 ...