C# RabbitMQ 客户端线程安全

Question

ConnectionFactory factory = new ConnectionFactory {HostName = "localhost"};

using (IConnection connection = factory.CreateConnection())
using (IModel channel = connection.CreateModel())
{
    channel.QueueDeclare("hello", false, false, false, null);
    for (int i = 0; i < 100000; i++)
    {
        MemoryStream stream = new MemoryStream();

        var user = new User 
                       {
                           Id = i
                       };

        Serializer.Serialize(stream, user);


        channel.BasicPublish("", "hello", null, stream.ToArray());

    }

}

我有上面的代码，我对线程安全很好奇。

我不确定，但我想ConnectionFactory 是线程安全的。但是IConnection 线程安全吗？我应该为每个请求创建一个连接吗？还是一个单一的持久连接？那么频道（IModel）呢？

另外，我应该将连接存储为 ThreadLocal 吗？或者我应该为每个请求创建一个连接？

Answer 1

IConnection 是线程安全的，而 IModel 不是。通常，您应该努力在应用程序的整个生命周期内保持连接打开。如果您的消费者需要打开连接才能接收消息，则尤其如此。由于网络或代理故障，检测中断连接并从中恢复非常重要。我建议阅读 Videla 和 Williams 的“RabbitMQ in Action”，尤其是第 6 章“编写在失败中幸存的代码”。

现在是一个无耻的插件。我是EasyNetQ 的作者，这是一个用于 RabbitMQ 的高级 .NET API。它为您完成所有连接管理，如果网络或代理中断，它将自动重新连接并重建您的所有订阅者。它还提供开箱即用的集群和故障转移支持。试试看吧。