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がスレッドセーフであるかどうかわかりませんか？要求ごとに接続を作成する必要がありますか？むしろ単一の永続的な接続ですか？そして、IChannelはどうですか？

また、私はThreadLocalとして接続を保存する必要がありますか？または、リクエストごとに接続を作成する必要がありますか？

Answer 1

IConnectionはスレッドセーフであり、IModelはそうではありません。一般的に、アプリケーションの存続期間中は接続をオープンに保つように努めなければなりません。これは、メッセージを受信するために開かれた接続が必要なコンシューマがある場合に特に当てはまります。ネットワークやブローカの障害のために、中断された接続を検出して回復することが重要です。私はVidelaとWilliamsの「RabbitMQ in Action」を読むことをお勧めします。特に第6章「失敗を生き延びるコードを書く」をお勧めします。

今、恥知らずのプラグです。私はEasyNetQの著者であり、RabbitMQ用の高水準の.NET APIです。すべての接続管理を行い、ネットワークまたはブローカの停止が発生した場合は、自動的にすべての加入者を再接続して再構築します。また、クラスタとフェールオーバーのサポートを提供します。試してみる。