RabbitMQ入门学习系列(五) Exchange的Direct类型

快速阅读

利用Exchange的Direct类型，实现对队列的过滤，消费者启动以后，输入相应的key值，攻取该key值对应的在队列中的消息。

从一节知道Exchange有四种类型

Direct,Topic,headers,fanout

前面我们说了fanout类型，可以把消息发送给所有的消费者，

在用Fanout类型的时候，我们绑定的时候是没有指定Routing key的【空值】

 channel.BasicPublish(exchange: "logs",routingKey: "",basicProperties: null,body: body);

这次我们说一下Direct类型

Exchange的Direct类型将与队列中的routing key进行精确的匹配。

生产者代码

创建连接和信道
声明交换器名字和指定类型为direct
发送routingkey=rk1 和rk2的消息各五次

static void Main(string[] args)
{var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection())using (var channel = connection.CreateModel()){channel.ExchangeDeclare(exchange: "directType1", type: "direct");for (var i = 0; i < 5; i++){string message = "Hello World!this rk1 message " + i;var body = Encoding.UTF8.GetBytes(message);var properties = channel.CreateBasicProperties();properties.Persistent = true;channel.BasicPublish(exchange: "directType1",routingKey: "rk1",basicProperties: null,body: body);Console.WriteLine(" [x] Sent {0},id={1}", message,i);Thread.Sleep(1000);}for (var i = 0; i < 5; i++){string message = "Hello World!this rk2 message " + i;var body = Encoding.UTF8.GetBytes(message);var properties = channel.CreateBasicProperties();properties.Persistent = true;channel.BasicPublish(exchange: "directType1",routingKey: "rk2",basicProperties: null,body: body);Console.WriteLine(" [x] Sent {0},id={1}", message, i);Thread.Sleep(1000);}}Console.WriteLine(" Press [enter] to exit.");Console.ReadLine();
}

消费者代码

输入要查看的消息类型，支持rk1 和rk2
创建连接和信道
声明交换器名字和指定类型为direct
指定队列名称，并且把routingkey的值赋值给控制台手动需要输入的rk1或者rk2
接收消息并回馈，和fanout类型一样的代码了。

static void Main(string[] args)
{bool flag = true;string level = "";while (flag){Console.WriteLine("请选择要查看的消息类型");level = Console.ReadLine();if (level == "rk1" || level == "rk2" )flag = false;elseConsole.Write("仅支持rk1与rk2");}var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){channel.ExchangeDeclare(exchange: "directType1", type: "direct");var queueName = channel.QueueDeclare().QueueName;channel.QueueBind(queue: queueName, exchange: "directType1", 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();}}

查看结果

我们看到生产者分别生产了五条rk1和五条rk2的消息

消费者1输入只查看rk1的消息，成功获得了rk1的消息

同样的

消费者2输入只查看rk2的消息，成功获得了rk2的消息

要注意的是先把先消费者启动起来

友情提示

我对我的文章负责，发现好多网上的文章没有实践，都发出来的，让人走很多弯路，如果你在我的文章中遇到无法实现，或者无法走通的问题。可以直接在公众号《爱码农爱生活》留言。必定会再次复查原因。让每一篇文章的流程都能顺利实现。

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

RabbitMQ入门学习系列(六) Exchange的Topic类型
快速阅读介绍exchange的topic类型,和Direct类型相似,但是增加了"."和"#"的匹配.比Direct类型灵活 Topic消息类型特点是:to ...
RabbitMQ入门学习系列(二)，单生产者消费者
友情提示我对我的文章负责,发现好多网上的文章没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题.可以直接在公众号<爱码农爱生活 >留言.必定会再次 ...
RabbitMQ入门学习系列(四) 发布订阅模式
什么时发布订阅模式把消息发送给多个订阅者.也就是有多个消费端都完整的接收生产者的消息换句话说把消息广播给多个消费者消息模型的核心 RabbitMQ不发送消息给队列,生产者也不知道消息发送到队列 ...
RabbitMQ入门学习系列(三).消息发送接收
快速阅读用Rabitmq的队列管理,以及如何保证消息在队列中不丢失.通过ack的消息确认和持久化进行操作.以及Rabbit中如何用Web面板进行管理队列.消费者如何处理耗时的任务生产者代码创建链接 ...
RabbitMQ（四）：Exchange交换器--direct
内容翻译自:RabbitMQ Tutorials Java版 RabbitMQ(一):Hello World程序 RabbitMQ(二):Work Queues.循环分发.消息确认.持久化.公平分发 ...
Android音视频学习系列(五) — 掌握音频基础知识并使用AudioTrack、OpenSL ES渲染PCM数据
系列文章 Android音视频学习系列(一) - JNI从入门到精通 Android音视频学习系列(二) - 交叉编译动态库.静态库的入门 Android音视频学习系列(三) - Shell脚本入门 ...
OpenGL入门学习(十五)
OpenGL入门学习[十五] 这次讲的所有内容都装在一个立方体中,呵呵. 呵呵,绘制一个立方体,简单呀,我们学了第一课第二课,早就会了. 先别着急,立方体是很简单,但是这里只是拿立方体做一个例子,来说 ...
React Native小白入门学习路径——五
React Native小白入门学习路径--五序 "哦天呐!" 这句话成了我在实验室的口头禅, 老师可能觉得我们都是大神吧,都还在看着基础就给布置了那么多任务:写一个RN的TDD ...
Asp.Net MVC5入门学习系列⑤
Asp.Net MVC5入门学习系列⑤ 原文:Asp.Net MVC5入门学习系列⑤ 检查VS生产的编辑方法和编辑窗体前面我们一步使用强类型,然后创建Controller(控制器)的时候,VS默认已 ...