NServiceBus：按需处理消息

如何解决NServiceBus：按需处理消息

| 我刚刚接触服务总线（尤其是NServiceBus），并且刚刚写了我的第一个Saga。 传奇旨在接收交易，然后发送消息以验证用户ID，付款明细和产品明细等，以针对大多数封闭的系统（难以通过编程方式进行访问）。现在，其中一些功能易于自动化和编写处理程序，但是在某些情况下，由于没有可用的api来执行这些任务，因此需要人工干预才能完成交易。现在，我们将有多个人工代理对此进行努力，因此并发成为一个问题，我想为什么不让每个用户都按需提取下一条消息，并利用MSMQ固有的并发性。 我尚未在nhibernate的IBus上找到任何方法来允许根据需要检索下一条可用消息，因为它似乎一切都是基于推送的。因此，我为原型设计了一个UI，该UI使用标准的.NET System.Messaging.MessageQueue API从MSMQ手动检索消息，并允许用户与之交互，然后通过通过IBus写回响应将返回的消息发送回saga。 Send（）方法。 关于这一点，我的主要问题是：这是否违反了围绕NServiceBus的基本原则？是否可以通过NServiceBus API做到这一点？ 您还会通过MSMQ或UI应用程序处理并发吗？ 干杯     

解决方法

        出于多种原因，NSB中的所有内容都是单向的。为了通知您的客户他们需要做某事，您可以轮询视图模型以查看是否有一定间隔要完成的工作。 Saga将负责为用户界面插入/更新正确的行。 UI完成后，您可以使用NSB将消息发送回Saga。如果这是一个Web UI，请查看下载中的AsyncPages示例。 执行此操作的另一种方法是将消息推送到客户端，假设已将消息传递与客户端一起安装。您将需要在后台创建某种消息泵。同样，一旦工作完成，将执行一个简单的Send（）。