我应该如何为一个生产者和许多消费者设置rebus

Question

我正在浏览示例并阅读文档,但我仍然不确定如何为我的场景配置rebus(或者使用总线是一个很好的选择).

我有一个要做的任务生产者,比如说ImportOrder和CalculateOrderPrice

我想从生产者转储消息并将大量这些消息排队.我想要两个侦听ImportOrder的客户端和10个侦听CalculatePriceOfOrder的客户端.我不希望同一个订单同时转到多个端点,我正在尝试分散工作量.

到目前为止生产者配置:

 <rebus inputQueue="publisher.input" errorQueue="publisher.error" workers="1" maxRetries="5">

var adapter = new BuiltinContainerAdapter();
            Configure.With(adapter)
                   .Logging(l => l.Log4Net())
                        .Transport(t => t.UseMsmqAndGetInputQueueNameFromAppConfig())
                        .Subscriptions(s => s.StoreInXmlFile(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "rebus_subscriptions.xml")))
                        .MessageOwnership(d => d.FromRebusConfigurationSection())
                        .CreateBus()
                        .Start();

目前消费者配置:

<rebus inputQueue="calcserver1.input" errorQueue="calcserver1.error" workers="1" maxRetries="5">
<endpoints>
  <add messages="Messages.RecalculateContractMessage,  Messages" endpoint="publisher.RecalculateContract@se-devws-0007.sirius.local"/>
</endpoints>

Configure.With(adapter)
               .Logging(l => l.Log4Net())
                .Transport(t => t.UseMsmqAndGetInputQueueNameFromAppConfig())
                .MessageOwnership(d => d.FromRebusConfigurationSection())
                .CreateBus()
                .Start();

        adapter.Bus.Subscribe<RecalculateContractMessage>();

我似乎无法配置此设置,如果我使用msmq或sqlserver并不重要.

• rebus(或任何服务总线类型的解决方案)听起来不太合适吗？
  
• 我应该使用pub/sub还是普通发送模式？如果当时只有一个端点或几个端点处理消息,那么该选择会影响吗？
  
• 有人能指出一个很好的例子或解释如何设置这个场景吗？

Answer 1

我来一一回答你的问题：

• rebus（或任何服务总线类型的解决方案）听起来很适合这里吗？

是的，服务总线可以帮助您处理很多事情（例如序列化、线程化等），否则您必须以某种方式自己处理这些事情。

• 我应该使用发布/订阅还是普通发送模式？如果消息同时仅由一个端点还是多个端点处理，这一选择是否会产生影响？

在这种情况下，在我看来，您需要一种竞争性消费者类型的任务分配。

这不是 pub/sub - pub/sub 意味着每个消息实例有 0..* 个消费者，但您希望每个任务只有一个接收者。因此，您将完成bus.Send本例中的任务。

• 谁能为我指出一个很好的例子或解释如何设置这个场景？

我写了几篇博客文章，试图通过不同支持的传输的示例来展示如何使用 Rebus 扩展工作负载的处理。

通过查看帖子并使用例如 SQL Server 作为传输工具，您应该相当容易开始。