2

我们将 Rebus 与 MSMQ 一起用于应用程序组件之间的基于消息的通信。这些组件都在同一台机器上运行。

发送和接收消息之间的时间通常保持在 1 秒以下。但是，如果系统空闲一分钟左右（这意味着没有消息正在发送），接下来的一两条消息有时需要大约五秒钟才能传递。MSMQ 性能计数器显示这些消息在此期间保留在队列中。

对于我们的应用程序，希望消息具有恒定的传递时间（低于一秒）。

这种行为的原因可能是什么？有没有办法影响 MSMQ 或 Rebus 中消息的传递时间？我们是否应该选择其他运输类型以获得更稳定的交货时间？

4

2 回答 2

4

默认情况下，Rebus 将根据BackoffBehavior中的时间跨度逐渐取消对队列的轮询- 正如您所看到的，如果它保持空闲足够长的时间，它将最终每 5 秒轮询一次队列。

您可以通过以下方式更改为低延迟退避策略

Configure.With(...)
    .(...)
    .Behavior(b => b. SetLowLatencyBackoffBehavior())
    .(...)

在配置拼写中。

更新：在更高版本的 Rebus（即版本 >= 2）中，可以像这样自定义回退时间：

Configure.With(...)
    .(...)
    .Options(o => {
        o.SetBackoffTimes(
            TimeSpan.FromMilliseconds(100),
            TimeSpan.FromMilliseconds(200),
            TimeSpan.FromSeconds(1)
        );
    })

在这种情况下，在空闲运行的前两秒以 100 毫秒和 200 毫秒的间隔轮询，然后在其余时间以 1 秒的间隔轮询。

如果这个级别的定制还不够，ISyncBackoffStrategy可以通过上面o.Register<ISyncBackoffStrategy>(c => new YourOwn SyncBackoffStrategy())的.Options配置器来实现和使用。

于 2014-09-23T15:05:39.153 回答
1

据我记得，当 Rebus 注意到队列中没有消息时，它会逐渐增加它在下次查看之前等待的秒数。

你提到的 5 秒似乎与我之前在调试模式下运行 Rebus 时所经历的最大等待时间非常吻合（你可以看到，它增加了时间跨度）。

于 2014-09-23T12:06:27.147 回答