1

我在 Ubuntu 14.04 虚拟机上部署了 MyBroker 服务并获得以下日志:apollo.log:

    2016-03-07 13:52:28,301 | INFO  | java.io.IOException: Connection reset by peer | 1535101acf6
2016-03-07 13:52:28,301 | INFO  | java.io.IOException: Connection reset by peer | 1535101acf8
2016-03-07 13:52:28,302 | INFO  | java.io.IOException: Connection reset by peer | 1535101acfa
2016-03-07 13:52:28,302 | INFO  | java.io.IOException: Connection reset by peer | 1535101acfc
2016-03-07 13:52:28,303 | INFO  | java.io.IOException: Connection reset by peer | 1535101acfe
2016-03-07 13:52:28,303 | INFO  | java.io.IOException: Connection reset by peer | 1535101ad00
2016-03-07 13:52:28,303 | INFO  | java.io.IOException: Connection reset by peer | 1535101ad02
2016-03-07 13:52:37,923 | INFO  | java.io.IOException: Connection reset by peer | 1535101ad04
2016-03-07 13:53:07,938 | INFO  | java.io.IOException: Connection reset by peer | 1535101ad06
2016-03-07 13:53:27,963 | INFO  | java.io.IOException: Connection reset by peer | 1535101ad08

连接日志

2016-03-07 13:53:22,817 connected: local:/127.0.0.1:61613, remote:/127.0.0.1:53221
2016-03-07 13:53:22,825 connected: local:/127.0.0.1:61613, remote:/127.0.0.1:53222
2016-03-07 13:53:22,847 connected: local:/127.0.0.1:61613, remote:/127.0.0.1:53222
2016-03-07 13:53:22,852 connected: local:/127.0.0.1:61613, remote:/127.0.0.1:53221
2016-03-07 13:53:27,045 disconnected: local:/127.0.0.1:61613, remote:/127.0.0.1:53222
2016-03-07 13:53:27,963 Shutting connection '/127.0.0.1:53221'  down due to: java.io.IOException: Connection reset by peer
2016-03-07 13:53:27,964 disconnected: local:/127.0.0.1:61613, remote:/127.0.0.1:53221

堆栈跟踪日志

2016-03-04 14:31:40,305 | WARN  | stackref=153416c3084
java.lang.ArrayIndexOutOfBoundsException: 32
    at org.fusesource.mqtt.codec.SUBSCRIBE.decode(SUBSCRIBE.java:65)
    at org.apache.activemq.apollo.mqtt.MqttSession.on_transport_command(MqttSession.java:334)
    at org.apache.activemq.apollo.mqtt.MqttSession$3.call(MqttSession.java:142)
    at org.apache.activemq.apollo.util.UnitFn1.apply(Scala2JavaHelper.scala:41)
    at org.apache.activemq.apollo.mqtt.MqttProtocolHandler.on_transport_command(MqttProtocolHandler.java:377)
    at org.apache.activemq.apollo.broker.BrokerConnection.on_transport_command(Connection.scala:144)
    at org.apache.activemq.apollo.broker.Connection$$anon$1.onTransportCommand(Connection.scala:71)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport.drain_inbound(WebSocketTransportFactory.scala:480)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport$$anonfun$onMessage$1.apply$mcV$sp(WebSocketTransportFactory.scala:403)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
2016-03-04 14:31:44,370 | WARN  | stackref=153416c3088
java.lang.ArrayIndexOutOfBoundsException: 32
    at org.fusesource.mqtt.codec.SUBSCRIBE.decode(SUBSCRIBE.java:65)
    at org.apache.activemq.apollo.mqtt.MqttSession.on_transport_command(MqttSession.java:334)
    at org.apache.activemq.apollo.mqtt.MqttSession$3.call(MqttSession.java:142)
    at org.apache.activemq.apollo.util.UnitFn1.apply(Scala2JavaHelper.scala:41)
    at org.apache.activemq.apollo.mqtt.MqttProtocolHandler.on_transport_command(MqttProtocolHandler.java:377)
    at org.apache.activemq.apollo.broker.BrokerConnection.on_transport_command(Connection.scala:144)
    at org.apache.activemq.apollo.broker.Connection$$anon$1.onTransportCommand(Connection.scala:71)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport.drain_inbound(WebSocketTransportFactory.scala:480)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport$$anonfun$onMessage$1.apply$mcV$sp(WebSocketTransportFactory.scala:403)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
2016-03-07 08:47:06,569 | WARN  | stackref=153416c320c
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 08:47:07,227 | WARN  | stackref=153416c320e
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:35:08,660 | WARN  | stackref=153416c3319
java.lang.NullPointerException
    at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$unbind$1$$anonfun$apply$mcV$sp$4$$anonfun$apply$4.apply(Router.scala:258)
    at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$unbind$1$$anonfun$apply$mcV$sp$4$$anonfun$apply$4.apply(Router.scala:256)
    at scala.collection.TraversableLike$$anonfun$filterNot$1.apply(TraversableLike.scala:274)
    at scala.collection.TraversableLike$$anonfun$filterNot$1.apply(TraversableLike.scala:274)
    at scala.collection.TraversableLike$$anonfun$filter$1.apply(TraversableLike.scala:264)
    at scala.collection.immutable.List.foreach(List.scala:309)
    at scala.collection.TraversableLike$class.filter(TraversableLike.scala:263)
    at scala.collection.AbstractTraversable.filter(Traversable.scala:105)
    at scala.collection.TraversableLike$class.filterNot(TraversableLike.scala:274)
    at scala.collection.AbstractTraversable.filterNot(Traversable.scala:105)
    at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$unbind$1$$anonfun$apply$mcV$sp$4.apply(Router.scala:256)
    at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$unbind$1$$anonfun$apply$mcV$sp$4.apply(Router.scala:251)
    at scala.collection.TraversableLike$$anonfun$filterNot$1.apply(TraversableLike.scala:274)
    at scala.collection.TraversableLike$$anonfun$filterNot$1.apply(TraversableLike.scala:274)
    at scala.collection.TraversableLike$$anonfun$filter$1.apply(TraversableLike.scala:264)
    at scala.collection.immutable.List.foreach(List.scala:309)
    at scala.collection.TraversableLike$class.filter(TraversableLike.scala:263)
    at scala.collection.AbstractTraversable.filter(Traversable.scala:105)
    at scala.collection.TraversableLike$class.filterNot(TraversableLike.scala:274)
    at scala.collection.AbstractTraversable.filterNot(Traversable.scala:105)
    at org.apache.activemq.apollo.broker.DeliveryProducerRoute$$anonfun$unbind$1.apply$mcV$sp(Router.scala:251)
    at org.apache.activemq.apollo.util.DeferringDispatched$$anon$1.run(Dispatched.scala:38)
    at org.apache.activemq.apollo.util.DeferringDispatched$$anonfun$dispatch_queue_task_source$1$$anonfun$apply$mcV$sp$1.apply(Dispatched.scala:45)
    at org.apache.activemq.apollo.util.DeferringDispatched$$anonfun$dispatch_queue_task_source$1$$anonfun$apply$mcV$sp$1.apply(Dispatched.scala:45)
    at scala.collection.immutable.List.foreach(List.scala:309)
    at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:32)
    at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:45)
    at org.apache.activemq.apollo.util.DeferringDispatched$$anonfun$dispatch_queue_task_source$1.apply$mcV$sp(Dispatched.scala:45)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.HawtCustomDispatchSource$1.run(HawtCustomDispatchSource.java:127)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
2016-03-07 09:37:13,687 | WARN  | stackref=153416c334d
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:37:14,493 | WARN  | stackref=153416c334f
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:37:15,274 | WARN  | stackref=153416c3351
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:37:16,555 | WARN  | stackref=153416c3353
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:38:49,275 | WARN  | stackref=153416c335f
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:38:50,234 | WARN  | stackref=153416c3361
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:38:50,990 | WARN  | stackref=153416c3363
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:38:51,752 | WARN  | stackref=153416c3365
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 09:38:52,515 | WARN  | stackref=153416c3367
java.lang.ArrayIndexOutOfBoundsException
2016-03-07 10:48:21,306 | WARN  | stackref=1535072b8fc
java.lang.ArrayIndexOutOfBoundsException: 80
    at org.fusesource.mqtt.codec.SUBSCRIBE.decode(SUBSCRIBE.java:65)
    at org.apache.activemq.apollo.mqtt.MqttSession.on_transport_command(MqttSession.java:334)
    at org.apache.activemq.apollo.mqtt.MqttSession$3.call(MqttSession.java:142)
    at org.apache.activemq.apollo.util.UnitFn1.apply(Scala2JavaHelper.scala:41)
    at org.apache.activemq.apollo.mqtt.MqttProtocolHandler.on_transport_command(MqttProtocolHandler.java:377)
    at org.apache.activemq.apollo.broker.BrokerConnection.on_transport_command(Connection.scala:144)
    at org.apache.activemq.apollo.broker.Connection$$anon$1.onTransportCommand(Connection.scala:71)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport.drain_inbound(WebSocketTransportFactory.scala:480)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport$$anonfun$onMessage$1.apply$mcV$sp(WebSocketTransportFactory.scala:403)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
2016-03-07 10:51:57,043 | WARN  | stackref=1535072b916
java.lang.ArrayIndexOutOfBoundsException: 80
    at org.fusesource.mqtt.codec.SUBSCRIBE.decode(SUBSCRIBE.java:65)
    at org.apache.activemq.apollo.mqtt.MqttSession.on_transport_command(MqttSession.java:334)
    at org.apache.activemq.apollo.mqtt.MqttSession$3.call(MqttSession.java:142)
    at org.apache.activemq.apollo.util.UnitFn1.apply(Scala2JavaHelper.scala:41)
    at org.apache.activemq.apollo.mqtt.MqttProtocolHandler.on_transport_command(MqttProtocolHandler.java:377)
    at org.apache.activemq.apollo.broker.BrokerConnection.on_transport_command(Connection.scala:144)
    at org.apache.activemq.apollo.broker.Connection$$anon$1.onTransportCommand(Connection.scala:71)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport.drain_inbound(WebSocketTransportFactory.scala:480)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport$$anonfun$onMessage$1.apply$mcV$sp(WebSocketTransportFactory.scala:403)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
2016-03-07 13:30:06,035 | WARN  | stackref=1535101abf7
java.lang.ArrayIndexOutOfBoundsException: 32
    at org.fusesource.mqtt.codec.SUBSCRIBE.decode(SUBSCRIBE.java:65)
    at org.apache.activemq.apollo.mqtt.MqttSession.on_transport_command(MqttSession.java:334)
    at org.apache.activemq.apollo.mqtt.MqttSession$3.call(MqttSession.java:142)
    at org.apache.activemq.apollo.util.UnitFn1.apply(Scala2JavaHelper.scala:41)
    at org.apache.activemq.apollo.mqtt.MqttProtocolHandler.on_transport_command(MqttProtocolHandler.java:377)
    at org.apache.activemq.apollo.broker.BrokerConnection.on_transport_command(Connection.scala:144)
    at org.apache.activemq.apollo.broker.Connection$$anon$1.onTransportCommand(Connection.scala:71)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport.drain_inbound(WebSocketTransportFactory.scala:480)
    at org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory$WebSocketTransport$$anonfun$onMessage$1.apply$mcV$sp(WebSocketTransportFactory.scala:403)
    at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
    at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)

我的假设是具有 Ubuntu 14.04(和 1,5 GB RAM)的虚拟机无法处理所有服务(在同一台机器上还运行其他服务,如 Tomcat) - 有人根据发布的日志文件有想法吗?(我只在 stacktrace.log 中看到线程的 NullPointException)

4

1 回答 1

0

Apollo activemq AMQP NullPointerException这似乎与我已经假设的答案相同:

Apollo Developers 继续前进。

“您应该使用 ActiveMQ 5 或试用 ActiveMQ Artemis” https://stackoverflow.com/users/375722/tim-bish

于 2016-03-08T14:36:19.263 回答