微信公眾號：趣編程ACE
關注可了解更多的.NET日常實戰開發技巧，如需源碼 請公眾號后臺留言 源碼;
[如果覺得本公眾號對您有幫助，歡迎關注]

前文回顧

【微服務專題之】.Net6下集成消息隊列上-RabbitMQ

【微服務專題之】.Net6下集成消息隊列2-RabbitMQ

---

RabbitMQ中直接路由模式

路由模式就是生產者與消費者之間基于交換機通信的時候，生產者指定路由發送數據，消費者綁定路由接收數據。這個與前文講解的發布/訂閱模式有一定的區分，發布訂閱模式只要綁定了交換機的隊列（queue）都會收到生產者通過交換機發送過來的數據，而路由模式增加了一個指定路由的設置，會聲明發送到交換機下的哪個路由，而接受的消費者只有綁定了隊列并且聲明了該路由才會接受到數據。

代碼演示

生產者代碼：

1public?static?void?Send(IModel?channel)2????????{3????????????channel.ExchangeDeclare(?"hello-direct-exchange",ExchangeType.Direct);4????????????var?count?=?0;5????????????while?(true)6????????????{7????????????????Thread.Sleep(1000);8????????????????//?發送的消息9????????????????string?message?=?$"Hello?World?{count}";
10????????????????var?body?=?Encoding.UTF8.GetBytes(message);
11????????????????var?body2?=?Encoding.UTF8.GetBytes(message+"body2");
12
13????????????????//?基本發布?不指定交換
14????????????????channel.BasicPublish(exchange:?"hello-direct-exchange",
15?????????????????????????????????????//?路由鍵???就是隊列名稱
16?????????????????????????????????????routingKey:?"route1",
17?????????????????????????????????????//?基礎屬性
18?????????????????????????????????????basicProperties:?null,
19?????????????????????????????????????//?傳遞的消息體
20?????????????????????????????????????body:?body);
21
22????????????????channel.BasicPublish(exchange:?"hello-direct-exchange",
23?????????????????????????????????????//?路由鍵???就是隊列名稱
24?????????????????????????????????????routingKey:?"route2",
25?????????????????????????????????????//?基礎屬性
26?????????????????????????????????????basicProperties:?null,
27?????????????????????????????????????//?傳遞的消息體
28?????????????????????????????????????body:?body2);
29????????????????count++;
30????????????????Console.WriteLine("?[x]?sent?{0}",?message);
31????????????}
32????????}

消費者代碼

1public?static?void?Receive(IModel?channel)2????????{3????????????channel.ExchangeDeclare("hello-direct-exchange",?ExchangeType.Direct);4????????????channel.QueueDeclare(queue:?"hello-direct-queue",5????????????????????????durable:?true,6????????????????????????exclusive:?false,7????????????????????????autoDelete:?false,8????????????????????????arguments:?null);9????????????channel.QueueBind("hello-direct-queue",?"hello-direct-exchange",?"route1");
10????????????channel.QueueBind("hello",?"hello-direct-exchange",?"route2");
11
12????????????//?創建一個消費者基本事件
13????????????var?consumer?=?new?EventingBasicConsumer(channel);
14????????????consumer.Received?+=?(model,?ea)?=>
15????????????{
16????????????????var?body?=?ea.Body.ToArray();
17????????????????var?message?=?Encoding.UTF8.GetString(body);
18????????????????Console.WriteLine("?[x]?Received?{0}",?message);
19????????????};
20????????????channel.BasicConsume(queue:?"hello-direct-queue",
21?????????????????????????????????//?自動確認
22?????????????????????????????????autoAck:?true,
23?????????????????????????????????consumer:?consumer);
24
25????????????channel.BasicConsume(queue:?"hello",
26?????????????????????????????????//?自動確認
27?????????????????????????????????autoAck:?true,
28?????????????????????????????????consumer:?consumer);
29
30????????????Console.WriteLine("?Press?[enter]?to?exit.");
31????????????Console.ReadLine();
32????????}

效果展示

---

PS:代碼詳解見視頻~