發佈/訂閲 (pub-sub)，它允許將消息廣播給多個接收者。在本文中，我們將探討如何在 .NET 中使用 RabbitMQ 實現發佈/訂閲模式。就是RabbitMQ 是一個開源消息代理，它允許應用程序通過交換器向隊列發送消息，從而實現應用程序之間的異步通信。它支撐多種消息傳遞協議，其中之一就是 AMQP（高級消息隊列協議）。在 .NET 生態系統中，可以使用官方的 RabbitMQ .NET 客户端庫來操作 RabbitMQ。RabbitMQ 的一種常見消息傳遞模式

在 C# .NETCore 中使用 RabbitMQ 實現發佈、訂閲示例 - 指南_發送消息

若是您喜歡此文章，請收藏、點贊、評論，謝謝，祝您快樂每一天。

理解發布/訂閲模式

發佈/訂閲模式涉及三個主要組件：

發佈者：向交易所發送消息，但不知道消息的接收者。
交換器：從發佈者接收消息並將其路由到適當的隊列。
訂閲者（消費者）：從隊列接收消息。

發佈者發送的消息是臨時的，除非至少有一個活躍的訂閲者，否則不會被保存。交換器會使用各種交換器類型（例如直接交換器、主題交換器、標頭交換器和扇出交換器）來決定如何將消息路由到隊列。

設置環境

在實現該模式之前，您需要在系統上設置 RabbitMQ。您可以通過其官方網站或採用 Docker 安裝 RabbitMQ 服務器。然後，確保您已準備好 .NET 開發環境，並經過將以下RabbitMQ.Client軟件包添加到您的項目中來安裝適用於 .NET 的 RabbitMQ 客户端：

dotnet add package RabbitMQ.Client

.NET 中的發佈/訂閲實現

Publisher Code

發佈者應用程序創建一個交換器，並向該交換器發送消息：

using RabbitMQ.Client;
using System.Text;class Publisher
 {
public static void Main()
 {
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
 {
using (var channel = connection.CreateModel())
 {
channel.ExchangeDeclare(exchange: "logs", type: "fanout");string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);channel.BasicPublish(exchange: "logs", routingKey: "",
basicProperties: null, body: body);
Console.WriteLine(" [x] Sent {0}", message);
 }
 }
 }
 }

Subscriber Code

訂閲者監聽來自綁定到交換機的特定隊列的消息：

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;class Subscriber
 {
public static void Main()
 {
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
 {
channel.ExchangeDeclare(exchange: "logs", type: "fanout");

var queueName = channel.QueueDeclare().QueueName;
channel.QueueBind(queue: queueName, exchange: "logs", routingKey: "");var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
 {
var body = ea.Body.ToArray();
var message = Encoding.UTF8.GetString(body);
Console.WriteLine(" [x] Received {0}", message);
 };
channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
 }
 }
 }

關鍵考慮因素和最佳實踐

考慮描述

交易所類型根據所需的路由行為選擇正確的交換類型。要向所有消費者進行廣泛廣播，請使用fanout。
消息持久性假如您需要消息持久化，請將消息和隊列都設置為持久的。
錯誤處理在您的消費者應用程序中實施錯誤處理來處理錯誤消息。
消費者確認確定是否需要自動或手動確認以實現更好的消息處理控制。

結論

得益於 RabbitMQ 給予的強大庫，在 .NET 中使用 RabbitMQ 實現發佈/訂閲模式變得非常簡單。應用扇出交換器類型，您可以輕鬆地將消息廣播給多個訂閲者，從而提升應用程序的可擴展性和靈活性。通過理解和利用不同的部署並遵循最佳實踐，您可以使用 RabbitMQ 在 .NET 中構建高效可靠的基於消息的系統。

如果您喜歡此文章，請收藏、點贊、評論，謝謝，祝您快樂每一天。