Nservicebus 同步调用

Question

我正在为我的一个项目使用 NServiceBUs 的请求回复模型。有一个自托管服务总线侦听请求消息并回复请求消息。 所以在 WCF 消息代码中，我已经像

// sent the message to bus.
var synchronousMessageSent = 
    this._bus.Send(destinationQueueName, requestMessage)
    .Register(
        (AsyncCallback)delegate(IAsyncResult ar)
        {
             // process the response from the message.
             NServiceBus.CompletionResult completionResult = ar.AsyncState as NServiceBus.CompletionResult;
             if (completionResult != null)
             {
                 // set the response messages.
                 response = completionResult.Messages;
             }                                                     
        }, 
        null);

       // block the current thread.
        synchronousMessageSent.AsyncWaitHandle.WaitOne(1000);
       return response;

destinaton que 将发送回复。 在没有回复客户的情况下，我收到一两次回复。我做错什么了吗

Answer 1

您为什么要尝试将异步框架转变为同步框架？您正在尝试做的事情存在一个根本缺陷。

您应该仔细审视您的设计，并欣赏异步调用的好处。你正在做的事实

// block the current thread.
synchronousMessageSent.AsyncWaitHandle.WaitOne(1000);

高度关注。你想用这个来达到什么目的？基于异步消息通信设计您的系统，您将拥有一个更好的系统。否则你还不如只使用某种阻塞 tcp/ip 套接字。