使用C#和RabbitMQ发送和接收消息_c# rabbitmq 客户端

通过NuGet安装RabbitMQ.Client

以下是一个简单的示例代码，演示如何使用 C# 和 RabbitMQ 客户端库来发送和接收消息：

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

public class Program
{
    public static void Main()
    {
        // 设置连接参数
        var factory = new ConnectionFactory() { HostName = "localhost", Port = 5672, UserName = "guest", Password = "guest" };

        // 建立连接和通道
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            // 声明 Exchange
            channel.ExchangeDeclare(exchange: "myexchange", ExchangeType.Direct);

            // 声明队列
            channel.QueueDeclare(queue: "myqueue", durable: false, exclusive: false, autoDelete: false, arguments: null);

            // 绑定 Exchange 和 Queue
            channel.QueueBind(queue: "myqueue", exchange: "myexchange", routingKey: "myroutingkey");

            // 发送消息
            for (int i = 0; i < 5; i++)
            {
                string message = i.ToString();
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish(exchange: "myexchange", routingKey: "myroutingkey", basicProperties: null, body: body);
            }

            // 接收消息
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);

                Console.WriteLine($"第{message}次开始{DateTime.Now}");

                Thread.Sleep(3000);

                Console.WriteLine($"第{message}次结束{DateTime.Now}");

            };
            channel.BasicConsume(queue: "myqueue", autoAck: true, consumer: consumer);

            Console.ReadLine();
            //日志输出
            //第0次开始2023 / 6 / 28 11:29:46
            //第0次结束2023 / 6 / 28 11:29:49
            //第1次开始2023 / 6 / 28 11:29:49
            //第1次结束2023 / 6 / 28 11:29:52
            //第2次开始2023 / 6 / 28 11:29:52
            //第2次结束2023 / 6 / 28 11:29:55
            //第3次开始2023 / 6 / 28 11:29:55
            //第3次结束2023 / 6 / 28 11:29:58
            //第4次开始2023 / 6 / 28 11:29:58
            //第4次结束2023 / 6 / 28 11:30:01
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

durable持久化
durable 参数用于指定队列是否是持久化的。

当 durable 参数设置为 true 时，表示队列是持久化的。持久化的队列会在RabbitMQ服务器重启后仍然存在，确保数据的持久性。如果你的消息需要长期存储或重要性很高，建议将 durable 设置为 true。

当 durable 参数设置为 false 时，表示队列是非持久化的。非持久化的队列在RabbitMQ服务器重启后会被删除。如果你的消息是临时性的或不需要持久化，可以将 durable 设置为 false。

一般来说，你需要根据你的业务需求来确定队列是否需要持久化。如果你希望确保即使在RabbitMQ服务器重启后消息仍然可用，或者消息具有重要性，那么你应该将 durable 设置为 true。

示例：

_channel.QueueDeclare(queue: queueName,
    durable: true, // 设置为true表示队列是持久化的
    exclusive: false,
    autoDelete: false,
    arguments: null);
1
2
3
4
5

RabbitMQ官方文档：https://www.rabbitmq.com/documentation.html