2 w2c2y2 w2c2y2 于 2016.03.29 22:48 提问

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,提示已经连接了,不能再连接。如何解决?

2个回答

w2c2y2
w2c2y2   2016.03.29 22:48

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

CSDNXIAOD
CSDNXIAOD   2016.03.30 11:32

activemq 重新连接的机制
activemq 重新连接的机制
----------------------biu~biu~biu~~~在下问答机器人小D,这是我依靠自己的聪明才智给出的答案,如果不正确,你来咬我啊!

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
activemq 重新连接的机制
activemq 重新连接的机制
ActiveMQ的N多问题
1、将工程部署到Tomcat上,如果出现下述错误提示,则是忘记开启ActiveMQ的服务器了。 Connection refused: connect at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQConnec
重新连接 到 时出错 Microsoft Windows Network:本地设备名已在使用中
今天遇到这个问题,先记录下。原来是服务器down了……无语……
activemq 重新连接的机制
最近一个项目要用到ActiveMq,并且需要最大程度的保证消息不丢失。以前对activeMq不是很熟悉,完全是摸着石头过河,目前基 本配置都搞定了。只是对于它的自动重连一直找不到好的解决办法,我希望的效果是当一个broker(假设只有这一个,没有备用的)如果异常down掉的 话,那么监听程序能够等待broker重启后再自动重新连接。看了它的文档似乎 设置一下failover:(tcp://loca
折腾ActiveMQ时遇到的问题和解决方法
1.先讲严重的:服务挂掉。 这得从ActiveMQ的储存机制说起。在通常的情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的,它们的最大限制在配置文件的节点中配置。但是,在非持久化消息堆积到一定程度,内存告急的时候,ActiveMQ会将内存中的非持久化消息写入临时文件中,以腾出内存。虽然都保存到了文件里,但它和持久化消息的区别是,重启后持久化消息会从文件中恢复,非持久化的临时文件会
xp系统关闭远程桌面时,弹出一个窗口,提示"正在重新连接"
转载:百度知道http://zhidao.baidu.com/link?url=YHTiwWP8JL-3ZxR5PGIEGnZr9dHfjHunWlKY_nsTm9tQ2FXEJfxVSNCm5-NN1x0AwrZcGvcRvK6DTWdoweWcUK 关闭远程桌面时,弹窗提示如下图: 解决办法:远程桌面连接--选项---体验 下面有一个 如果连
Activemq 访问后台出现503错误
-
ActiveMQ中的NetworkConnector(网络连接器)详解
注:本文以ActiveMQ5.10版本为基础。        我们知道,ActiveMQ中的TransportConnector(传输连接器)主要用于配置ActiveMQ服务端和客户端之间的通信方式,NetworkConnector(网络连接器)则主要用来配置ActiveMQ服务端与服务端之间的通信。在某些场景,网络拓扑中我们可能会需要大量的生产者和消费者,也就是说我们会有大量的ActiveMQ
activemq 5.6 连接池的内存泄露问题
最近在使用activemq 的连接池时,发现它存在很严重的内存泄露问题。 通过jmap监控,可以看到java.util.concurrent.locks.ReentrantLock, org.apache.activemq.pool.PooledConnection这两个类占用的空间非常大,而且增长速度也很快。 网上查了一下,正好找到activemq的bug 报告.:https://issue
Sping+ActiveMQ整合
通过前一篇《ActiveMQ简述》大概对ActiveMQ有了一个大概的认识,本篇所阐述的是如何通过Spring继承ActiveMQ进而更有效、更灵活的运用ActiveMQ.Spring和ActiveMQ整合需要在项目中包含以下这几个jar包(缺一不可):activeio-core-3.1.4.jar,activemq-all-5.13.2.jar,activemq-pool-5.13.2.jar,c