Azure ServiceBus QueueClient.OnMessage có thực hiện trên một luồng khác

Question

Phương thức QueueClient.OnMessage có luôn thực hiện tham số gọi lại trên một luồng khác không?

Tôi giả định rằng nếu MaxConcurrentCalls được đặt thành 10 thì queueClient sẽ quay lên tối đa 10 luồng để xử lý các thư song song. Có một chủ đề mới được tạo ra nếu bạn vượt qua trong một giá trị MaxConcurrentConnection 1 hoặc hiện nó thực hiện trở lại trên thread hiện tại?

Vấn đề thực tế của tôi:
Trong vai trò công nhân Tôi muốn xử lý nhiều hàng đợi nhưng có tất cả quá trình đồng thời. Ví dụ.

 _queueClient1.OnMessage(x => 
      { 
       // Do something 
      }, new OnMessageOptions { MaxConcurrentCalls = 1}); 

     _queueClient2.OnMessage(x => 
     { 
      // Do something 
     }, new OnMessageOptions { MaxConcurrentCalls = 1 }); 

     _queueClient3.OnMessage(x => 
     { 
      // Do something 
     }, new OnMessageOptions { MaxConcurrentCalls = 1 }); 

     _queueClient4.OnMessage(x => 
     { 
      // Do something 
     }, new OnMessageOptions { MaxConcurrentCalls = 1 }); 

Điều này có dẫn đến mỗi cuộc gọi lại được thực thi song song để gọi lại _queueClient4 không chờ _queueClient2 hoàn tất trước khi có thể thực thi?

Answer 1

Khi bạn đăng ký gọi lại với OnMessage, nó được gọi trên một chủ đề khác. Nếu bạn đặt MaxConcurrentCalls để nói 10, thì chúng tôi sẽ tạo 10 chuỗi cho 10 thư và gọi lại tất cả các thư này cho mỗi thư cùng một lúc. Bạn cũng có thể thực hiện điều này trên các Hàng đợi như bạn đã trình bày ở trên, nhưng tất nhiên không có sự đồng bộ hoặc thứ tự được thực hiện giữa mỗi lần xử lý gọi lại riêng lẻ.

Khi chúng ta gọi hàm gọi lại trên một chuỗi mới, thì nó sẽ đồng bộ cho thông báo/thực hiện cụ thể đó cho đến khi phương thức hoàn thành hoặc ngoại lệ được ném, quá trình xử lý tin nhắn chưa hoàn thành. Nếu MaxConcurrentCalls là 0 thì chỉ một luồng duy nhất sẽ được xử lý cho mỗi lần gọi lại đã đăng ký. Tuy nhiên khi bạn có các trường hợp QueueClient khác nhau, bạn có thể đăng ký các callback khác nhau cho chúng hoặc cùng một cuộc gọi lại với các số lượng đồng thời khác nhau, v.v.