技术宅必备：揭秘C#下的RabbitMQ-3_发布订阅模式（扇形交换机）

2023-11-28 06:23:26

使用 RabbitMQ-3_ 发布订阅模式构建分布式系统

在现代分布式系统开发中，发布订阅模式因其灵活性、可扩展性和松耦合性而备受青睐。它允许发布者向多个订阅者广播消息，而无需了解每个订阅者的具体信息。

扇形交换机：消息广播的利器

在 RabbitMQ 中，扇形交换机 是一种特殊的交换机，它将所有收到的消息广播给与它绑定的所有队列。这意味着，只要有一个订阅者订阅了与扇形交换机绑定的队列，所有发送到该交换机上的消息都会被该订阅者接收。扇形交换机非常适合用于构建广播系统，例如新闻推送、日志收集和事件通知。

在 C# 中使用 RabbitMQ-3_ 发布订阅模式

创建发布者

// 创建连接工厂
var factory = new ConnectionFactory() { HostName = "localhost" };

// 创建连接和通道
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// 创建扇形交换机
channel.ExchangeDeclare("fanout-exchange", ExchangeType.Fanout);

// 发送消息
channel.BasicPublish("fanout-exchange", "", null, Encoding.UTF8.GetBytes("Hello, world!"));

创建订阅者

// 创建连接工厂
var factory = new ConnectionFactory() { HostName = "localhost" };

// 创建连接和通道
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// 创建队列
channel.QueueDeclare("my-queue", false, false, false, null);

// 将队列绑定到扇形交换机
channel.QueueBind("my-queue", "fanout-exchange", "");

// 消费消息
channel.BasicConsume("my-queue", true, (model, ea) =>
{
    var message = Encoding.UTF8.GetString(ea.Body.ToArray());
    Console.WriteLine(// 创建连接工厂
var factory = new ConnectionFactory() { HostName = "localhost" };

// 创建连接和通道
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// 创建队列
channel.QueueDeclare("my-queue", false, false, false, null);

// 将队列绑定到扇形交换机
channel.QueueBind("my-queue", "fanout-exchange", "");

// 消费消息
channel.BasicConsume("my-queue", true, (model, ea) =>
{
    var message = Encoding.UTF8.GetString(ea.Body.ToArray());
    Console.WriteLine($"Received: {message}");
}, consumerTag: "my-consumer");

Console.ReadLine();
quot;Received: {message}");
}, consumerTag: "my-consumer");

Console.ReadLine();