问题描述

ActiveMQ提示重新连接出错

2016-03-29 21:52:03,136 | WARN | Transport Connection to: MQTTSocket_621347941 failed: java.io.IOException: Broker: localhost - Client: cy already connected from MQTTSocket_475507959 | org.apache.activemq.broker.TransportConnection.Transport | qtp1907161685-36
2016-03-29 21:55:19,990 | WARN | Failed to add Connection ID:iZ94bx4ng7iZ-58865-1459258343193-2:22 | org.apache.activemq.broker.TransportConnection | qtp1907161685-37
javax.jms.InvalidClientIDException: Broker: localhost - Client: cy already connected from MQTTSocket_475507959
at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:255)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:231)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:92)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.security.JaasAuthenticationBroker.addConnection(JaasAuthenticationBroker.java:87)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:809)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:79)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.ws.jetty8.MQTTSocket.sendToActiveMQ(MQTTSocket.java:122)[activemq-http-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.mqtt.MQTTProtocolConverter.sendToActiveMQ(MQTTProtocolConverter.java:173)[activemq-mqtt-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.mqtt.MQTTProtocolConverter.onMQTTConnect(MQTTProtocolConverter.java:275)[activemq-mqtt-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.mqtt.MQTTProtocolConverter.onMQTTCommand(MQTTProtocolConverter.java:196)[activemq-mqtt-5.11.3.jar:5.11.3]
at org.apache.activemq.transport.ws.jetty8.MQTTSocket.onMessage(MQTTSocket.java:62)[activemq-http-5.11.3.jar:5.11.3]
at org.eclipse.jetty.websocket.WebSocketConnectionRFC6455$WSFrameHandler.onFrame(WebSocketConnectionRFC6455.java:878)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.websocket.WebSocketParserRFC6455.parseNext(WebSocketParserRFC6455.java:349)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.websocket.WebSocketConnectionRFC6455.handle(WebSocketConnectionRFC6455.java:225)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:696)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:53)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)[jetty-all-8.1.16.v20140903.jar:8.1.16.v20140903]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_76]
2016-03-29 21:55:19,993 | WARN | Transport Connection to: MQTTSoc

大家帮我看看，activemq同一个clientID=cy，提示已经连接了，不能再连接。如何解决？

解决方案

断开后，重新连接不上。这个大家遇到过吗？

解决方案二：

activemq 重新连接的机制
activemq 重新连接的机制