当前位置: 首页 > 面试题库 >

ActiveMQ消费者挂起

慕项明
2023-03-14
问题内容

我有一个使用SSL传输的activeMQ代理。我大约有10位使用代理的消费者。我正在使用骆驼配置路线。

即使我重新启动使用者,它总是挂断并且不会使用新消息,即使队列中有待处理的消息也是如此。

我开始尝试一次遍历我的消费者,试图找出问题所在,以找出问题的根源。我终于找到了一个消费者,我可以重新解决这个问题。一段时间后它将挂起,但是,如果我进入活动的MQ管理控制台并尝试查看队列中的消息,它将再次开始运行。我认为Jetty导致连接发生以刷新网页队列,从而解除了我遇到的一些线程问题。我应该如何调试呢?

谢谢


问题答案:

我的一个同事偶然发现了一些有趣的东西,我刚刚在互联网上找到了一个解释:http :
//activemq.2283324.n4.nabble.com/Consumer-is-not-able-to-pick-messages-from-
queue -td2531722.html

显然,当您拥有选择器并且所有消息都在同一队列中时,页面大小可以被填充。对于我们而言,这是正在发生的事情-
我还没有启动使用者,所以我最后得到一整页的消息,其中包含用于其他使用者的选择器,这使我正在运行的使用者无法获得任何其他工作。



 类似资料:
  • 我在ActiveMQ中使用异步消息使用者。我的制作人工作正常,向队列发送消息。现在,我的异步消息消费者正在等待调用onMessage(),但这从未发生过。因此,问题是: 异步使用者不会使用消息 ActiveMQ日志的快照还显示了许多刚刚堆积在挂起状态中的消息: 我想不出问题到底出在哪里。 计数: toPageIn 78 只是不断增加,信息仍然无法传递给消费者。 是服务器端问题还是客户端问题?

  • 我有一个使用ActiveMQ的消息队列。web请求用persistency=true将消息放入队列。现在,我有两个消费者,它们都作为单独的会话连接到这个队列。使用者1总是确认消息,但使用者2从不这样做。 JMS队列实现负载平衡器语义。一条消息将被一个使用者接收。如果在发送消息时没有可用的使用者,它将被保留,直到有可以处理消息的使用者可用为止。如果使用者接收到一条消息,但在关闭之前没有确认它,那么该

  • 我对ActiveMQ有一个类似的问题:http://activemq.2283324.n4.nabble.com/Messages-stuck-in-pending-td4617979.html已经尝试了这里发布的解决方案。 有些消息似乎卡在队列上,可以在那里坐几天而不被消费。我有足够多的消费者大部分时间都是免费的,所以这不是消费者“饱和”的问题。 重新启动ActiveMQ后,一些待处理的消息会立

  • 我有一个使用SSL传输的activeMQ代理。我有大约10个消费者正在使用经纪人。我正在使用camel来配置我的路线。 谢谢

  • 我正在研究ActiveMQ,看看它是否适用于一个项目。我需要展示的当前用例是,晚加入的订阅者将收到在创建订阅之前发布的主题。看起来ActiveMQ追溯消费者将满足这一需求,但我无法让代码工作。 我在这里试图证明的是,一个主题可以被发布,然后在一段任意的时间后(例如。5秒),消费者可以订阅该主题并接收前一条消息。 据我所知,问题似乎是创建主题会创建一个地址,但不会创建任何关联的队列。如果我在队列形成

  • 是否有一种方法以编程方式访问和打印使用者滞后偏移,或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视,我应该在上面添加哪些语句来得到滞后偏移值?