一、基本介绍
RabbitMQ——Rabbit Message Queue的简写，但不能仅仅理解其为消息队列，消息代理更合适。
RabbitMQ 是一个由 Erlang 语言开发的AMQP（高级消息队列协议）的开源实现，其内部结构如下：
RabbitMQ作为一个消息代理，主要和消息打交道，负责接收并转发消息。
RabbitMQ提供了可靠的消息机制、跟踪机制和灵活的消息路由，支持消息集群和分布式部署。
适用于排队算法、秒杀活动、消息分发、异步处理、数据同步、处理耗时任务、CQRS等应用场景。
下面我们就来学习下RabbitMQ。
二、简单应用
在C#中使用RabbitMQ通常涉及到RabbitMQ.Client这个库，它是RabbitMQ的官方.NET客户端，允许开发者通过C#代码与RabbitMQ服务器进行交互。以下是一些基本的代码示例，展示了如何在C#应用程序中使用RabbitMQ。
1. 创建ConnectionFactory和Connection
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
var factory = new ConnectionFactory() { HostName = "localhost" };
using(var connection = factory.CreateConnection())
{
// 后续操作
}2. 创建Channel
using(var channel = connection.CreateModel())
{
// 使用channel进行队列声明、消息发布等操作
}3. 声明队列
channel.QueueDeclare(queue: "myqueue",
durable: false, // 队列是否持久化
exclusive: false, // 是否排他
autoDelete: false, // 无消费者时是否自动删除
arguments: null);4. 发布消息
string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
routingKey: "myqueue", // 队列名作为路由键
basicProperties: null,
body: body);5. 订阅消息
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
var body = ea.Body.ToArray();
var receivedMessage = Encoding.UTF8.GetString(body);
Console.WriteLine($"Received: {receivedMessage}");
// 确认消息
channel.BasicAck(ea.DeliveryTag, false);
};
channel.BasicConsume(queue: "myqueue",
autoAck: false,
consumer: consumer);6. 消息确认
在消费者中，可以通过调用BasicAck方法来手动确认消息，告知RabbitMQ消息已被成功处理。
7. 异常处理
在使用RabbitMQ时，需要考虑异常处理机制，确保在出现网络问题或其他异常时，能够正确地关闭连接和通道。
8. 连接和通道的关闭
使用完连接和通道后，应该关闭它们以释放资源。
channel.Close();
connection.Close();在实际应用中，可能还需要考虑更复杂的场景，比如消息的持久化、事务、发送方确认机制、消费者取消订阅等。以上代码提供了在C#中使用RabbitMQ的基本框架，可以根据具体需求进行扩展和优化。
