C#操作RabbitMQ的完整实例

以下是使用C#操作RabbitMQ的完整实例攻略，包含两个示例说明。

示例1：发送消息到RabbitMQ

步骤1：安装RabbitMQ.Client NuGet包

在Visual Studio中打开项目，右键单击项目名称，选择“管理NuGet程序包”，在搜索框中输入“RabbitMQ.Client”，选择安装。

步骤2：创建连接

在代码中添加以下命名空间：

using RabbitMQ.Client;

然后创建一个连接：

var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
    // 在这里添加发送消息的代码
}

步骤3：创建通道

在连接中创建一个通道：

using (var channel = connection.CreateModel())
{
    // 在这里添加发送消息的代码
}

步骤4：声明队列

在通道中声明一个队列：

channel.QueueDeclare(queue: "hello",
                     durable: false,
                     exclusive: false,
                     autoDelete: false,
                     arguments: null);

步骤5：发送消息

在通道中发送一条消息：

string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: "",
                     routingKey: "hello",
                     basicProperties: null,
                     body: body);
Console.WriteLine(" [x] Sent {0}", message);

示例2：从RabbitMQ接收消息

步骤1：安装RabbitMQ.Client NuGet包

同示例1。

步骤2：创建连接

同示例1。

步骤3：创建通道

同示例1。

步骤4：声明队列

同示例1。

步骤5：创建消费者

在通道中创建一个消费者：

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);

以上就是使用C#操作RabbitMQ的完整实例攻略，包含两个示例说明。