activemq集群假死

Question

现象是：进程都还在，但是端口已经不监听，查看日志发现以下错误，集群重启后就好了，这个情况大家碰到过吗，有规避的办法吗，在这里先谢谢了

2017-01-04 04:43:12,184 | WARN  | listeners are taking too long to process the events | org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport | ZooKeeper state change dispatcher thread
2017-01-04 04:43:12,209 | WARN  | Exception while executing listener (ignored) | org.apache.activemq.leveldb.replicated.groups.ZKClient | ZooKeeper state change dispatcher thread
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /activemq/leveldb-stores/00000000333
at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)[zookeeper-3.4.6.jar:3.4.6-1569965]
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)[zookeeper-3.4.6.jar:3.4.6-1569965]
at org.apache.zookeeper.ZooKeeper.setData(ZooKeeper.java:1270)[zookeeper-3.4.6.jar:3.4.6-1569965]
at org.linkedin.zookeeper.client.ZooKeeperImpl.setData(ZooKeeperImpl.java:239)[org.linkedin.zookeeper-impl-1.4.0.jar:]
at org.linkedin.zookeeper.client.AbstractZooKeeper.setData(AbstractZooKeeper.java:261)[org.linkedin.zookeeper-impl-1.4.0.jar:]
at org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup.liftedTree1$1(ZooKeeperGroup.scala:146)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup.update(ZooKeeperGroup.scala:145)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ClusteredSingleton.join(ClusteredSingleton.scala:212)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ClusteredSingleton.onConnected(ClusteredSingleton.scala:240)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ClusteredSingletonWatcher$$anon$2.connected(ClusteredSingleton.scala:112)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$$anonfun$fireConnected$1$$anonfun$apply$mcV$sp$1.apply(ChangeListener.scala:70)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$$anonfun$fireConnected$1$$anonfun$apply$mcV$sp$1.apply(ChangeListener.scala:69)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at scala.collection.immutable.List.foreach(List.scala:383)[scala-library-2.11.0.jar:]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$$anonfun$fireConnected$1.apply$mcV$sp(ChangeListener.scala:69)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$$anonfun$fireConnected$1.apply(ChangeListener.scala:69)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$$anonfun$fireConnected$1.apply(ChangeListener.scala:69)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class.check_elapsed_time(ChangeListener.scala:97)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup.check_elapsed_time(ZooKeeperGroup.scala:73)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class.fireConnected(ChangeListener.scala:68)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup.fireConnected(ZooKeeperGroup.scala:73)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup.onConnected(ZooKeeperGroup.scala:129)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZKClient.callListeners(ZKClient.java:385)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]
at org.apache.activemq.leveldb.replicated.groups.ZKClient$StateChangeDispatcher.run(ZKClient.java:354)[activemq-leveldb-store-5.12-SNAPSHOT.jar:5.12-SNAPSHOT]

Answer 1

楼主这个问题解决了吗？我这里也碰到了，蛋疼！！！

Answer 2

请问这位大神玩什么？ACTIVEMQ烂？请大神写个MQ软件过大家玩。不要说你用什么ROCKETMQ等，每种MQ都有其领域

Answer 3

回复
这位大神喜欢自己造轮子。嫌别人的框架太大，自己从中花150行代码写某个自己需要的小功能。

Answer 4

不要用activieMQ，就是这个有坑。。你还不如改成一台MQ 然后做高可用切换