2

我们使用 HornetQ 2.2.5,我们的问题是在客户端(向 Q 发送消息),所有生产者线程都卡在 WAITING 状态。

请注意生产者在一台机器上,而 HornetQ 服务器在另一台机器上。

这是客户端的线程转储:

线程:pool-10-thread-9:优先级:5,demon:false,threadId:521,threadState:WAITING,lockName:java.util.concurrent.Semaphore$NonfairSync@60568a13

sun.misc.Unsafe.park(本机方法)

java.util.concurrent.locks.LockSupport.park(LockSupport.java:156) java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811) java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer. java:969) java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1281)

java.util.concurrent.Semaphore.acquire(Semaphore.java:441) org.hornetq.core.client.impl.ClientProducerCreditsImpl.acquireCredits(ClientProducerCreditsImpl.java:74) org.hornetq.core.client.impl.ClientProducerImpl.doSend( ClientProducerImpl.java:305) org.hornetq.core.client.impl.ClientProducerImpl.send(ClientProducerImpl.java:142) org.hornetq.jms.client.HornetQMessageProducer.doSend(HornetQMessageProducer.java:451) org.hornetq.jms。 client.HornetQMessageProducer.send(HornetQMessageProducer.java:199)

与 Q 的连接和会话在客户端被缓存和重用。

在服务器端有以下日志:

[hornetq-failure-check-thread] 19:25:30,820 警告 [org.hornetq.core.protocol.core.impl.RemotingConnectionImpl]
检测到连接失败:未从 /10.2.6.11:50697 接收数据。很可能客户端在没有关闭连接的情况下退出或崩溃,或者服务器和客户端之间的网络出现故障。您也可能错误地配置了 connection-ttl 和 client-failure-check-period。请查看用户手册了解更多信息。现在将关闭连接。[代码=3]

所有生产者线程都卡住了有什么原因吗?

4

1 回答 1

2

这是 hornetq 用户论坛上的常见问题解答...

HornetQ 有不同的方法来处理消息溢出,保护它免受内存不足的影响。

  • 溢出时阻塞
  • 流到磁盘(我们称之为..分页)
  • 丢弃(消息将消失。仅在您可以承受丢失消息的情况下有效)
  • 报错(最近在2.4上引入,2.2没有这个功能)

当您将系统设置为阻止时,客户端将等待仅在您消费消息后才会到达的信用。

因此,要么使用消息,要么将地址设置设置为分页。

有关设置分页的文档:

http://docs.jboss.org/hornetq/2.4.0.beta1/docs/user-manual/html/paging.html#paging.main.config

关于阻塞模式的文档:

http://docs.jboss.org/hornetq/2.4.0.beta1/docs/user-manual/html/paging.html#d0e5213

于 2013-11-06T16:54:41.523 回答