- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在使用 top-shelf 和 rebus 编写一个“多 worker ”应用程序。
我的想法是使用 MyWorker1Namespace
- MyWorker1Namespace.Messages
, MyWorker2Namespace
- MyWorker2Namespace.Messages
图案。
我想在不跨越多个进程的情况下运行应用程序,相反,我想使用多个输入队列配置应用程序,以便准备好在必要时将其拆分为多个进程。
有没有办法使用 Rebus 在一个应用程序中声明多个输入队列和多个工作线程?
我想配置应该是这样的:
<rebus inputQueue="MyWorker1Namespace.input" errorQueue="MyWorker1Namespace.error" workers="1" maxRetries="5"> </rebus>
<rebus inputQueue="MyWorker2Namespace.input" errorQueue="MyWorker2Namespace.error" workers="1" maxRetries="5"> </rebus>
...
最佳答案
由于 Rebus app.config XML 是针对每个进程一个总线实例的场景进行了优化,因此您不能完全在 XML 中配置多个总线,但是没有什么可以阻止您在同一进程中启动多个总线实例。
我经常这样做,例如在 Azure 辅助角色中,我希望托管多个逻辑端点,而不会产生物理分离部署的成本,有时我也使用 Topshelf 托管的 Windows 服务来完成。
通常,我的 app.config 以以下 XML 结尾:
<rebus workers="1">
<add messages="SomeAssembly.Messages" endpoint="someEndpoint.input"/>
<add messages="AnotherAssembly.Messages" endpoint="anotherEndpoint.input"/>
</rebus>
var containers = new List<IWindsorContainer> {
new WindsorContainer()
// always handlers first
.Install(FromAssembly.Containing<SomeEndpoint.SomeHandler>())
// and then the bus, which gets started at this point
.Install(new RebusInstaller("someEndpoint.input", "error"))
// and then e.g. background timers and other "living things"
.Install(new PeriodicTimersInstannce()),
new WindsorContainer()
.Install(FromAssembly.Containing<AnotherEndpoint.AnotherHandler>())
.Install(new RebusInstaller("anotherEndpoint.input", "error"))
};
// and then remember to dispose each container when shutting down the process
RebusInstaller
(这是一种 Windsor 机制)基本上只是将具有正确队列名称的总线放入容器中,例如像这样:
Configure.With(new WindsorContainerAdapter(container))
.Transport(t => t.UseMsmq(_inputQueueName, _errorQueueName))
.(...) etc
.CreateBus().Start();
关于rebus - 一个 rebus 进程中的多个输入队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26145670/
我有一个 Web 应用程序,它使用 Rebus 和 Azure 服务总线队列作为传输。 它配置了 Simple Injector 容器。 在应用程序处理期间,我想阻止 rebus 接受新消息并检查目前
我想通过上下文 A 引发的事件集成两个限界上下文并使用来自上下文 B 的事件。我怎么想避免编译时间依赖性,所以上下文 B 不必包含上下文 A 的 dll/库。(至少我不希望每次新事件类型获取时都需要更
我有一个运行良好的输入队列。有时一条消息会进入错误队列。现在我希望能够检查这些消息,如果我知道这条特定消息会通过,可能会再次将它们转发到输入队列。 如何开始检查错误队列?有什么最佳实践吗?我不能只执行
我正在使用 top-shelf 和 rebus 编写一个“多 worker ”应用程序。 我的想法是使用 MyWorker1Namespace - MyWorker1Namespace.Message
是否可以以编程方式或通过 UI 将错误消息从错误队列移动到其原始队列? 更新 关于下面代码的问题: 1 以下代码是否适用于发布者或订阅者或两者? 下面的代码: Configure.With(acti
使用 时出错阿祖尔服务巴士 , 如果我使用 MSMQ 排队然后没有错误,所以请建议代码有什么问题或任何缺少的配置? 注:下面的 Rebus 初始化代码是在 web 应用程序下运行的:
假设我有一个 saga 数据,其中包含具有以下值之一的状态: JustWaiting, AwatingPrepareDrink, WaitingForPayment 我也有不同的消息要处理,但只想在状
我在以下一般情况下使用 Rebus,对于 WCF 或 WebAPI 来说很自然。有两个微服务,在它们的程序集中具有相同的 DTO 集,用于交换集成事件。 DTO 类类似,但它们驻留在具有不同 .Net
我正在研究 Rebus 并将其与 Azure 服务总线一起使用。将它与 regalure Queues 一起使用很容易,但是当我想改用 Topic 时,我无法让它工作。 这里有没有完成设置并将其与主题
我有一个 Rebus Servicebus 控制台应用程序在我的测试环境中作为 Windows 服务运行。服务总线是这样创建的: Bus = Configure.With(adapter)
当我发送由 AutoMapper.Mapper.DynamicMap() 创建的实例时,我遇到了一个错误,其中 Rebus 似乎想要确定 DynamicMap 返回的代理类型的端点。此实例将包含 T
我有一个 Rebus 总线设置,只有一个工作人员,最大并行度为 1,可以“顺序”处理消息。如果处理程序失败,或出于特定业务原因,我希望总线实例立即停止处理消息。 我尝试使用 Rebus.Event 包
在 Rebus 中,是否有一种方法可以按顺序处理消息来控制消息的处理?即第一个处理,然后删除然后第二个处理等 最佳答案 是的 - 也不是 :) 首先,我只想说,你最好尽你所能设计你的系统,使其能够容忍
我最近一直在与 Rebus 合作,到目前为止,它一直很棒。 一个值得关注的领域是,当我们有数千或数十万条消息正在处理并且依赖服务(如数据库或 RabbitMQ)出现故障时。 在这种情况下,我们不需要错
尝试延迟在单向客户端上发送消息时,以下异常背后的基本原理是什么: System.InvalidOperationException “不能将自己用作超时管理器,因为我们是单向客户端” 最佳答案 单向客
有没有办法指定为特定异常重试消息的等待时间? 例如。如果对象处于 SomethingInProgress 状态,则抛出 SomethignInProgressException 并且我希望消息在 40
我正在浏览示例并阅读文档,但我仍然不确定如何为我的场景配置 rebus(或者使用总线很合适)。 我有一个任务生产者要做,比如说 ImportOrder 和CalculateOrderPrice 我想转
我想知道 Rebus Service Bus 是否可以处理以下用例: 为将来的日期排队消息 如果有一条消息 ProcessInvoice 的上下文类似于 Customer Id: 1000,我们是否可
我正在尝试使用 CQRS/ES 架构设置 WebApp。 我已经定义了一个模型实体,带有创建和编辑命令/事件。 命令由相关的 Saga 处理。 事件被保存到一个 mongo 事件存储,这是立即一致的存
当配置为单向客户端(RabbitMq 和 Azure)时,我在使用 rebus 发送消息(而不是发布)时遇到错误,因为队列必须存在。 如果在发送消息之前不存在队列,OneWayClient 有没有办法
我是一名优秀的程序员,十分优秀!