前言
RabbitMQ 是一个流行的开源消息中间件，它基于 AMQP（高级消息队列协议）实现，广泛用于分布式系统中异步消息传递、解耦服务之间的通信、提高系统的可伸缩性和可靠性。RabbitMQ 是一种消息代理，负责接收、存储并转发消息，它支持多种协议、可靠性机制以及多种客户端语言，包括 C#。
在本篇文章中，我们将深入探讨如何在 C# 中使用 RabbitMQ，介绍其基本概念、核心特性以及实际操作。
1. 安装 RabbitMQ
1.1 本地安装 RabbitMQ
首先，确保你已经安装了 RabbitMQ。你可以从 RabbitMQ 官网下载并安装。RabbitMQ 依赖 Erlang，因此在安装 RabbitMQ 前需要先安装 Erlang。
安装完成后，RabbitMQ 会自动启动，管理界面默认运行在 http://localhost:15672，用户名和密码均为 guest。
1.2 安装 C# 客户端库
在 C# 项目中使用 RabbitMQ，通常会使用 RabbitMQ.Client 包。你可以通过 NuGet 安装：
Install-Package RabbitMQ.Client
RabbitMQ 中有几个核心概念，理解这些概念对你使用 RabbitMQ 非常重要：
- Producer（生产者）
- Consumer（消费者）
- Queue（队列）
- Exchange（交换机）：决定消息如何路由到队列的规则，RabbitMQ 支持四种交换机类型：
direct、topic、fanout、headers。 - Binding（绑定）
- Routing Key（路由键）
3. C# 实现 RabbitMQ 消息队列
3.1 发送消息（生产者）
以下代码演示了如何创建一个简单的生产者，它将消息发送到一个队列中：
using RabbitMQ.Client;using System;using System.Text;class Producer{ static void Main(string[] args) { var factory = new ConnectionFactory() { HostName = "localhost" }; using (var connection = factory.CreateConnection()) using (var channel = connection.CreateModel()) { channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null); string message = "Hello, RabbitMQ!"; var body = Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: null, body: body); Console.WriteLine(" [x] Sent {0}", message); } Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); }}
3.2 接收消息（消费者）
接下来，我们编写一个简单的消费者，它将从队列中接收并处理消息：
using RabbitMQ.Client;using RabbitMQ.Client.Events;using System;using System.Text;class Consumer{ static void Main(string[] args) { var factory = new ConnectionFactory() { HostName = "localhost" }; using (var connection = factory.CreateConnection()) using (var channel = connection.CreateModel()) { channel.QueueDeclare(queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null); Console.WriteLine(" [*] Waiting for messages. To exit press [Ctrl+C]"); 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: "hello", autoAck: true, consumer: consumer); Console.ReadLine(); } }}
3.3 运行示例
- 启动生产者：运行
Producer 程序，生产者将消息发送到 RabbitMQ 队列。 - 启动消费者：运行
Consumer 程序，消费者将从队列中接收并处理消息。
4. 高级特性
4.1 消息确认（Message Acknowledgment）
默认情况下，RabbitMQ 会在消费者接收到消息后自动确认。但是，在某些情况下，你可能希望显式确认消息，以确保消息已被成功处理。
channel.BasicConsume(queue: "您好《编程光年》", autoAck: false, // 设置为 false 手动确认 consumer: consumer);
consumer.Received += (model, ea) =>{ var body = ea.Body.ToArray(); var message = Encoding.UTF8.GetString(body); Console.WriteLine(" [x] Received {0}", message);
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);};
4.2 消息持久化
如果你希望消息在 RabbitMQ 重启后不丢失，可以设置消息持久化：
channel.QueueDeclare(queue: "您好《编程光年》", durable: true, // 消息队列持久化 exclusive: false, autoDelete: false, arguments: null);
channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: new BasicProperties { DeliveryMode = 2 }, // 消息持久化 body: body);
4.3 发布/订阅模式（Fanout Exchange）
RabbitMQ 支持多种交换机类型，fanout 交换机会将消息广播到所有绑定的队列，适合实现发布/订阅模式。
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
channel.BasicPublish(exchange: "logs", routingKey: "", basicProperties: null, body: Encoding.UTF8.GetBytes("Hello World!"));
总结
RabbitMQ 是一种强大的消息中间件，广泛应用于分布式系统中异步消息传递。通过它，你可以实现系统解耦、提高可伸缩性、保证消息的可靠传递。使用 C# 与 RabbitMQ 客户端，你可以轻松构建高效的消息队列系统。
希望这篇文章能帮助你更好地理解和使用 RabbitMQ。
该文章在 2025/9/20 11:18:12 编辑过
400 186 1886
