C#和RabbitMQ进行基本操作的简单示例

以下是一个在 C# 中使用 RabbitMQ 进行基本操作的示例。在这个示例中，我们需要安装 RabbitMQ.Client 库。

这个示例将创建一个名为 hello 的队列，并将一个带有 Hello World! 消息的简单生产者发送到该队列。 然后，我们将创建一个简单的消费者，从队列中接收消息并打印到控制台。

using System;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

class Program
{
    static void Main(string[] args)
    {
        // 连接到 RabbitMQ 服务器
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                // 声明一个名为 "hello" 的队列
                channel.QueueDeclare(queue: "hello",
                                     durable: false,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);

                // 向队列发送一个消息
                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);

                // 创建一个消费者接收队列中的消息
                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body.ToArray();
                    var messageReceived = Encoding.UTF8.GetString(body);
                    Console.WriteLine(" [x] Received {0}", messageReceived);
                };
                channel.BasicConsume(queue: "hello",
                                     autoAck: true,
                                     consumer: consumer);

                Console.WriteLine(" Press [enter] to exit.");
                Console.ReadLine();
            }
        }
    }
}

在这个示例中，我们首先创建一个 ConnectionFactory 对象，并使用它创建一个 Connection 对象。然后，我们使用 CreateModel 方法创建一个 IModel 对象，它代表了一种通信方式。

我们使用 IModel.QueueDeclare 方法声明一个队列，该队列名为 hello。接下来，我们使用 IModel.BasicPublish 方法发布一个消息，该消息包含 Hello World! 字符串，并在队列中发送。

然后，我们创建一个 EventingBasicConsumer 对象作为消费者并使用它的 Received 事件处理程序接收消息。在 Received 事件处理程序中，我们使用 Encoding.UTF8.GetString 方法从接收到的字节数组中获取消息，并将其打印到控制台。

最后，我们使用 IModel.BasicConsume 方法开始接收队列中的消息。要退出该程序，请按下 enter 键。

请注意，此示例是基本示例之一，并不涵盖完整的 RabbitMQ 功能。具体实现取决于你的需求和所使用的库和框架。