6

我正在浏览示例并阅读文档，但我仍然不确定如何为我的场景配置 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 还是普通的发送模式？如果消息一次仅由一个或多个端点处理，该选择会影响吗？
  • 谁能指出我一个很好的例子或解释如何设置这个场景？
4

1 回答 1

1

我会一一回答你的问题：

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

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

  • 我应该使用 pub/sub 还是普通的发送模式？如果消息一次仅由一个或多个端点处理，该选择会影响吗？

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

这不是 pub/sub - pub/sub 意味着每个消息实例有 0..* 个消费者，但您希望每个任务只有一个接收者。因此，您将bus.Send在这种情况下执行任务。

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

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

通过查看帖子并使用例如 SQL Server 作为您的传输工具，您应该很容易上手。

于 2014-02-09T12:54:57.960 回答