c# - NServiceBus-如何为接收者订阅的每种消息类型获取单独的队列？

Question

我有以下情况:

因此，接收者订阅两种事件:eventA和eventB。 NServiceBus为接收方(Receiver)创建队列，并将eventA和eventB类型的消息放入同一队列。问题是，是否可以将NServiceBus配置为针对接收器的每种事件类型使用单独的队列(ReceiverEventA和ReceiverEventB)？或者我可以在单个进程中有两个接收者(每个接收者单独的队列)。
事实是，EventA比EventB需要更长的处理时间，而且它们是独立的-因此，如果将它们放在单独的队列中，则可以同时处理它们。

更新:如果我要使用这样的幼稚方法，则接收器无法从空引用异常开始:

 private static IBus GetBus<THandler, TEvent>()
    {                   
        var bus = Configure.With(new List<Type>
                                     {
                                         typeof(THandler), 
                                         typeof(TEvent),
                                         typeof(CompletionMessage)
                                     })
            .Log4Net()
            .DefaultBuilder()
            .XmlSerializer()
            .MsmqTransport()
            .IsTransactional(true)
            .PurgeOnStartup(false)
            .UnicastBus()
            .LoadMessageHandlers()
            .ImpersonateSender(false);

        bus.Configurer.ConfigureProperty<MsmqTransport>(x => x.InputQueue, "Queue" + typeof(THandler).Name);

        return bus.CreateBus().Start();
    }

    [STAThread]
    static void Main()
    {
        Busses = new List<IBus>
                     {
                         GetBus<ItemEventHandlerA, ItemEventA>(),
                         GetBus<ItemEventHandlerB, ItemEventB>()
                     };          

        Application.EnableVisualStyles();
        Application.SetCompatibleTextRenderingDefault(false);
        Application.Run(new TestForm());
    }

异常堆栈跟踪为:

at NServiceBusTest2.WinFormsReceiver.Program.GetBusTHandler,TEvent in C:\Users\User\Documents\Visual Studio 2010\Projects\NServiceBusTest2\NServiceBusTest2.WinFormsReceiver\Program.cs:line 57
at NServiceBusTest2.WinFormsReceiver.Program.Main() in C:\Users\User\Documents\Visual Studio 2010\Projects\NServiceBusTest2\NServiceBusTest2.WinFormsReceiver\Program.cs:line 26
at System.AppDomain._nExecuteAssembly(RuntimeAssembly assembly, String[] args)
at System.AppDomain.ExecuteAssembly(String assemblyFile, Evidence assemblySecurity, String[] args) at Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly()
at System.Threading.ThreadHelper.ThreadStart_Context(Object state)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean ignoreSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Threading.ThreadHelper.ThreadStart()

Answer 1

为了支持我对@stephenl发布的答案的评论，我开始就为什么不应该有两个单独的流程写出更为详尽的解释。 NServiceBus基本上每个进程强制一个输入队列。

因此，通常情况下，您将有两个单独的过程。 EventAService将从QForEventA读取EventA，与EventBService分开的过程从EventBService读取QForEventB。

然后，我更加仔细地查看了您的示例代码，并意识到您正在使用Windows Forms应用程序。 h!现在，我感到有些愚蠢。当然，您只能有一个过程。试想一下，如果在启动Outlook之后还必须启动MailService.exe来实际接收邮件!

因此，问题实际上是您在Windows Forms应用程序中对EventA和EventB的处理时间截然不同。我没有任何办法知道它的工作原理，但是对于客户端应用程序来说这有点奇怪。

大多数情况下，它是一项需要大量处理的服务，并且客户端收到的任何消息都是相当轻量级的-类似于“实体X发生了变化，因此下次您需要直接从数据库中加载它”处理它只涉及将某些内容从缓存中删除-当然不是一个长时间运行的过程。

但这听起来似乎出于任何原因，您的客户端中的处理都需要花费更长的时间，这在WinForms应用中令人担忧，原因是担心UI线程编码，阻塞UI线程等。

我建议您不要在WinForms应用程序的NServiceBus处理程序中进行所有处理，而是将其编码(marshal)至其他位置的系统。将其作为工作项或类似的东西扔到ThreadPool中。或者将长时间运行的项目放入队列，并以自己的速度对那些后台线程进行处理。这样NServiceBus消息处理程序所做的就是“是的，得到了​​消息。非常感谢。”然后，一次处理一个NServiceBus消息并不重要。

更新:

在评论中，OP询问如果在NServiceBus整理收到工作后将工作扔给ThreadPool，会发生什么情况。当然，这就是这种方法的另一面-完成NServiceBus之后，您就自己决定了-如果它在ThreadPool中失败，则取决于您自己创建重试逻辑，还是只捕获异常，提醒用户WinForms应用程序，并使其消失。

显然，这是最佳选择，但这引出了一个问题-您到底想在WinForms应用中完成什么样的工作？如果NServiceBus提供的鲁棒性(自动重试和针对错误消息的错误队列)是此难题的关键，那么为什么它首先要在WinForms应用程序中进行？可能需要将此逻辑卸载到WinForms应用程序外部的服务，在该服务中，每种消息类型具有单独的队列(通过部署单独的服务)变得容易，然后只有影响UI的部分才发送回WinForms客户端。当发送到UI的消息仅影响UI时，对它们的处理几乎总是微不足道的，并且您将不需要卸载到ThreadPool来保持最新状态。

直接说到GitHub Issue中描述的情况，这确实听起来像是一种场景，其中每种消息类型的单独进程正是规定的解决方案。我听说部署和管理这么多流程听起来不堪重负，但是我认为您会发现它并不像听起来那样糟糕。甚至还具有优势-例如，如果您必须通过Amazon.com重新部署连接器，则只需重新部署那个终端节点，而其他任何一个都无需停机，也可以避免其他任何错误的引入。

为了简化部署，希望您使用的是持续集成服务器，然后 checkin DropkicK之类的工具来帮助编写脚本。就个人而言，我最喜欢的部署工具是老式的Robocopy。甚至像1)NET STOP ServiceName，2)ROBOCOPY，3)NET START ServiceName一样简单。