活跃的 MQ 代理网络导致高消息发送延迟

Question

长时间侦听者，堆栈溢出:)上的首次调用者

我有一个具有生产者和消费者的ActiveMQ代理。创建器正在连接到活动 MQ 代理。有一个使用者附加到同一个代理。当我使用此设置发送消息 P -

现在我添加另一个代理来创建代理网络，并使用以下配置发送消息：P-

附加信息:

P和B1在同一个数据中心，DC1。

B2 和 C 位于同一数据中心 DC2 中。

DC1和DC2是同一海岸上的两个不同数据中心，ping延迟约为20-30ms。

我使用的是activemq tarball附带的默认配置。我添加的唯一配置是连接代理以创建代理网络。

在B1上，我向activemq.xml添加了以下配置：

<networkConnectors>
</networkConnectors>

在B2上，我向activemq.xml添加了以下配置

<networkConnectors>
            <networkConnector name="B2" uri="static://(tcp://b1.prod.xxx.com:61616)" duplex="true"/>
</networkConnectors>

它是全双工连接，B2位于防火墙后面，因此如宣传的那样工作。

任何想法，为什么延迟增加了这么多。10倍的延迟是不可接受的。当生产者数量增加时，情况可能会更糟。

我做错什么了吗？

编辑：

我看到将消息从 B1 发送到 B2 正在占用

2013-07-10 23:05:00186|TRACE|运行任务迭代932-传输连接到：vm://broker135;0|.org.apache.activemq.thread。PooledTaskRunner:128|ActiveMQ代理服务[broker1]任务-3

2013-07-10 23:05:00,187|调试|桥接（经纪1-

2013-07-10 23：05：00，438 |跟踪|正在运行任务迭代 933 - 传输连接到：vm：//broker1#0 |org.apache.activemq.thread.PooledTaskRunner：128 |ActiveMQ 代理服务[代理 1] 任务-3

2013-07-10 23:05:00,439|调试|桥接（经纪1-

2013-07-10 23:05:00,708|TRACE|正在运行的任务迭代934-传输连接到：vm：//Broker1#0|org.apache.activemq.thread.PooledTaskRunner:128|ActiveMQ BrokerService[Broker1]Task-3

调试|桥接(代理1 -

2013-07-10 23:05:00962|TRACE|运行任务迭代935-传输连接到：vm://broker135;0|.org.apache.activemq.thread。PooledTaskRunner:128|ActiveMQ代理服务[broker1]任务-3

代理到代理的数据传输似乎需要很长时间。

我尝试设置persistent=false并使用KahaDB删除，但没有成功。

Answer 1

你所看到的是代理网络中存储转发的效果。当你从P发送消息时，它是:

• 存储在 B1 中，并在发送时确认给 P。
• 然后 B1 将其转发给 B2，后者存储它并确认给 B1;B1 从其本地存储中删除邮件。
• 然后，B2 将消息转发给 C。当 C 使用它时，它会向 B2 确认消息，B2 会从其本地存储中删除该消息。

消息代理网络与常规网络不透明的方式不同。代理上的接收和调度机制实际上由消息存储库彼此分离，该消息存储库位于磁盘上或内存中。每个经纪人都是生产者和消费者之间途中的一个站点。因此，在这方面，看到更高的延迟，我并不感到惊讶。我喜欢这个比喻，它就像一群人经过一桶水。

有关更详细的说明，请参阅了解 ActiveMQ 代理网络。