C# RabbitMQ An toàn chủ đề của khách hàng

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

    } 

} 

Tôi có mã ở trên và tôi tò mò về sự an toàn của luồng.

Tôi không chắc chắn, nhưng tôi sẽ tưởng tượng ConnectionFactory là chủ đề an toàn. Nhưng sau đó tôi không chắc chắn nếu IConnection là chủ đề an toàn? Tôi có nên tạo kết nối cho mỗi yêu cầu không? Hay đúng hơn là một kết nối liên tục? Và những gì về IChannel?

Ngoài ra, tôi có nên lưu trữ kết nối dưới dạng ThreadLocal không? Hoặc tôi có nên tạo kết nối cho mỗi yêu cầu không?

Answer 1

Kết nối chỉ là an toàn chỉ, IModel thì không. Nói chung, bạn nên cố gắng giữ kết nối mở trong suốt thời gian đăng ký của bạn. Điều này đặc biệt đúng nếu bạn có người tiêu dùng cần kết nối mở để nhận tin nhắn. Điều quan trọng là phát hiện và khôi phục từ các kết nối bị gián đoạn, do lỗi mạng hoặc Môi giới. Tôi muốn khuyên bạn nên đọc 'RabbitMQ trong Hành động' của Videla và Williams, đặc biệt là chương 6 'Viết mã mà sống sót thất bại'.

Bây giờ cho một plug không biết xấu hổ. Tôi là tác giả của EasyNetQ, một API cấp cao cho RabbitMQ. Nó thực hiện tất cả các quản lý kết nối cho bạn và sẽ tự động kết nối lại và xây dựng lại tất cả các thuê bao của bạn nếu có một mạng hoặc cúp môi giới. Nó cũng cung cấp hỗ trợ cluster và fail-over ra khỏi hộp. Hãy thử một lần.