前言

上一章节，我们说了两个类型，本章我们说一下其三:Topic Exchange

Topic Exchange

Topic Exchange – 将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。因此“audit.#”能够匹配到“audit.irs.corporate”，但是“audit.*” 只会匹配到“audit.irs”。我在RedHat的朋友做了一张不错的图，来表明topic交换机是如何工作的：

情景进入

Topic解决了我们另一个需求。举个例子，有一个做资讯的公司，他们会收集各种科技公司的动态并且第一时间转发出来。小编A负责小米公司，小编B负责华为公司，手工去搜索文章并且看标题是否匹配再进行转发是非常的低效的，可能小编们想要偷懒，写一个程序去各大网站进行爬数据，对于标题中含有小米的交给小编A，对于标题中含有华为的交给小编B。

代码块

发布者：

         /// <summary>/// Topic实现   模拟场景： 对于标题中含有小米的交给小编A，对于标题中含有华为的交给小编B。 /// </summary>/// <param name="args"></param>static void Main(string[] args){var flag = true;while (flag){Console.WriteLine("请输入要发布的消息key|msg");var msg = Console.ReadLine();if (msg != null && msg != "")using (var channel = HelpConnection.GetConnection().CreateModel()){channel.ExchangeDeclare("TopicExchange", ExchangeType.Topic, true, false, null);var msgs = msg.Split('|');var body = Encoding.UTF8.GetBytes(msgs[1]);Console.WriteLine("发布内容:键" + msgs[0]);Console.WriteLine("发布内容:值" + msgs[1]);channel.BasicPublish("TopicExchange", msgs[0], null, body);Console.WriteLine("发布成功");}else {flag = true;}}Console.ReadKey();}

消费端

  /// <summary>/// Topic实现   模拟场景： 对于标题中含有小米的交给小编A，对于标题中含有华为的交给小编B。 /// </summary>/// <param name="args"></param>static void Main(string[] args){bool flag = true;var key = "";while (flag){Console.WriteLine("请输入路由正则, .代表字符，*代表零到多个字符");key = Console.ReadLine();if (string.IsNullOrWhiteSpace(key)){Console.Write("请输入路由");flag = true;}else{//  flag = false;using (var channel = HelpConnection.GetConnection().CreateModel()){var queueName = key + "Queue";channel.ExchangeDeclare("TopicExchange", ExchangeType.Topic, true, false, null);channel.QueueDeclare(queueName, true, false, false, null);channel.QueueBind(queueName, "TopicExchange", key, null);var consumer = new EventingBasicConsumer(channel);consumer.Received += (mode, e) =>{var body = Encoding.UTF8.GetString(e.Body);Console.WriteLine("显示内容:" + body);};channel.BasicConsume(queueName, true, consumer);Console.ReadKey();}}}}

效果图

博主是利用读书、参考、引用、抄袭、复制和粘贴等多种方式打造成自己的纯镀 24k 文章，请原谅博主成为一个无耻的文档搬运工！
小弟刚迈入博客编写，文中如有不对，欢迎用板砖扶正，希望给你有所帮助。

转载于:https://www.cnblogs.com/lrzr/p/7365731.html

RabbitMQ八：交换机类型Exchange Types--Topic介绍相关推荐

RabbitMQ的交换机类型和工作模式
RabbitMQ的交换机类型有四种 1.direct 直流交换机: 根据消息的路由键routingkey,将消息以完全匹配的方式路由到指定的队列中. 这里的匹配指的是消息本身携带的路由键和队列与交换机 ...
RabbitMQ交换机类型
RabbitMQ交换机类型一.Direct Exchange(直连交换机) 二. Fanout Exchange(扇型交换机) 三.Topic Exchange(主题交换机) 四.Headers E ...
RabbitMQ入门学习系列(六) Exchange的Topic类型
快速阅读介绍exchange的topic类型,和Direct类型相似,但是增加了"."和"#"的匹配.比Direct类型灵活 Topic消息类型特点是:to ...
RabbitMq系列(九)：主题交换Topic Exchange
系列文章 RabbitMq系列(一):服务器搭建 RabbitMq系列(二):最简单的例子 RabbitMq系列(三):工作队列 RabbitMq系列(四):消息确认和持久性 RabbitMq系列(五 ...
#rabbitMQ #重复消费 #可靠投递 #延时投递 #rabbitMQ交换机类型#重复消费#消息积压#消息丢失
exchange类型: 1, direct 指定direct后, 消息会根据你设置的routeing key(路由键), 发送到对应的队列中 1,新建direct交换机 2,添加队列, 并且绑定路由键 ...
RabbitMQ（五）：Exchange交换器--topic
内容翻译自:RabbitMQ Tutorials Java版 RabbitMQ(一):Hello World程序 RabbitMQ(二):Work Queues.循环分发.消息确认.持久化.公平分发 ...
java实现rabbitmq动态路由/话题模型（topic queues），生产者消费者交换机消息队列
在routing路由模型中,我们实现了可以根据routingKey来选择性地将消息发送到对应的消息队列中,但是,这种模型不够灵活,比如最开始只有warn.info.error.三种类型的日志,但后面如 ...
RabbitMQ之交换机的四种类型和属性
交换机主要包括如下4种类型: Direct exchange(直连交换机) Fanout exchange(扇型交换机) Topic exchange(主题交换机) Headers exchange( ...
RabbitMQ 四种类型发送接收数据方式
1.基本用法生产者 1 import pika 2 import sys 3 4 username = 'wt' #指定远程rabbitmq的用户名密码 5 pwd = '111111' 6 use ...
RabbitMQ之交换机
目录一.RabbitMQ交换机 1.交换机的由来 2.交换机类型 2.1直连交换机(Direct Exchange) 2.2主题交换机(Topic Exchange) 2.3扇形交换机 ...

RabbitMQ八：交换机类型Exchange Types--Topic介绍

前言

代码块

发布者：

消费端

RabbitMQ八：交换机类型Exchange Types--Topic介绍相关推荐

最新文章

热门文章