ActiveMQ的消费挂起(ActiveMQ Consumer Hangs)

2019-06-23 10:30发布

我有使用SSL传输的ActiveMQ代理。 我有大约10名消费者正在使用代理。 我用骆驼来配置我的路线。

几乎每隔一段时间,就挂断了电话,并不会消耗新的消息,即使我重启了消费者,即使是在队列中未决的消息。

我开始试图找出其中这是通过一次通过我的消费者一个步进试图复制问题发生。 我终于得到了一个消费者,我可以重新创建的问题。 一段时间后,它就会挂掉,但是,如果我去主动MQ管理控制台,并尝试在队列中查看邮件,它会重新开始运行。 我认为Jetty是导致连接发生刷新队列的网页,从而疏通我有一些线程问题。 我应该如何调试呢?

谢谢

Answer 1:

我的一个同事无意中发现了一些有趣的事情,我只是发现在互联网上的解释: http://activemq.2283324.n4.nabble.com/Consumer-is-not-able-to-pick-messages-from-queue -td2531722.html

显然有是当你有一个选择,所有的信息都在同一个队列,可以得到填补页面大小。 这是发生了我们 - 我还没有开始消费,所以我结束了消息的完整页面,选择了不同的消费,这引起了我跑步消费者得不到发送给它的任何额外的工作。



Answer 2:

尝试排队的预读设置为1,以跨越促进消费者更好的分配,减少对特定消费者卡住“消息

看到http://activemq.apache.org/what-is-the-prefetch-limit-for.html



Answer 3:

太晚了你,但我有同样的问题,问题是,我是想用我用拿东西离开队列的同一个连接东西添加到队列中。

有一次,我把他们分开(两种完全不同的情况下,其用于生产,另一个用于消费),问题解决本身。



文章来源: ActiveMQ Consumer Hangs