Sử dụng phần mở rộng Phản hồi (Rx) cho tin nhắn MSMQ nhận được bằng cách sử dụng mẫu không đồng bộ (queue.BeginReceive, queue.EndReceive)

Question

Tôi đã sử dụng Rx một thời gian cho các sự kiện trong các dự án của tôi và dành riêng cho lập trình Socket và phần tốt là làm tốt. Quản lý mã của tôi, lợi thế hiệu suất và tốt hơn nhiều để thực thi và diễn giải. Gần đây tôi phải sửa đổi quy trình dự án của tôi, nơi tôi cần phải đổ tất cả dữ liệu đến (từ hoạt động ổ cắm) vào hàng đợi (sử dụng triển khai MSMQ theo quyết định xếp hàng).

Vì MSMQ cung cấp cuộc gọi không đồng bộ cho các thông báo dequeing từ hàng đợi (nhưng trong một mẫu hình kinh khủng). Tôi đã đấu tranh để sử dụng Rx cho mục đích này ngay bây giờ, nhưng cho phép làm như vậy.

Câu hỏi: Một số người có thể cung cấp cho tôi một ví dụ mã rõ ràng để triển khai Rx cho nhận thư từ hàng đợi bằng mẫu Async.

tôi cần thực hiện hành async cho MSMQ tương tự như một cái gì đó như thế này

var data = Observable.FromAsyncPattern<byte[]>(
         this.receiverSocket.BeginReceive, 
         this.receiverSocket.EndReceive(some parameters); 

Cảm ơn trước. * cổ vũ * để Rx và .NET

Answer 1

Nó sẽ là đơn giản như:

var queue = new System.Messaging.MessageQueue("test"); 
var fun = Observable.FromAsyncPattern((cb, obj) => queue.BeginReceive(TimeSpan.FromMinutes(10),obj,cb), a => queue.EndReceive(a)); 
var obs = fun();