AcitveMQ提供了一套性能测试的工具按照手册我在HostA上:mvn activemq-perf:broker -Durl=broker:tcp://localhost:61616
在HostB上:mvn activemq-perf:producer -Dfactory.brokerURL=tcp://<IP>:61616
在HostC上:mvn activemq-perf:producer -Dfactory.brokerURL=tcp://<IP>:61616于是HostC上就报了下边的错误:
[INFO] ------------------------------------------------------------------------
[INFO] [activemq-perf:producer]
Apr 15, 2009 3:03:07 AM org.apache.activemq.tool.AbstractJmsClientSystem loadJmsFactory
INFO: Created: org.apache.activemq.ActiveMQConnectionFactory using SPIConnectionFactory: org.apache.activemq.tool.spi.ActiveMQReflectionSPI
javax.jms.InvalidClientIDException: Broker: localhost - Client: JmsProducer0 already connected from /<HostA's IP>:46942
at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:209)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:75)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:89)
at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:679)
at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Thread.java:619)不知道改如何下手解决这个问题了?!
在HostB上:mvn activemq-perf:producer -Dfactory.brokerURL=tcp://<IP>:61616
在HostC上:mvn activemq-perf:producer -Dfactory.brokerURL=tcp://<IP>:61616于是HostC上就报了下边的错误:
[INFO] ------------------------------------------------------------------------
[INFO] [activemq-perf:producer]
Apr 15, 2009 3:03:07 AM org.apache.activemq.tool.AbstractJmsClientSystem loadJmsFactory
INFO: Created: org.apache.activemq.ActiveMQConnectionFactory using SPIConnectionFactory: org.apache.activemq.tool.spi.ActiveMQReflectionSPI
javax.jms.InvalidClientIDException: Broker: localhost - Client: JmsProducer0 already connected from /<HostA's IP>:46942
at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:209)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:75)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:89)
at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:679)
at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Thread.java:619)不知道改如何下手解决这个问题了?!
解决方案 »
- lucene做数据库高级搜索
- servlet监听到超时怎么给页面提示呢?
- JMS MessageListener 的疑问
- 连接池爆了 怎么查到哪里的连接没释放?
- [Struts2]如何消除addActionError("错误!")对跳转的影响??
- Action 为什么不执行方法。
- 那位大侠有httpclient的相关资料。
- 读取pdf文件,然后把相应的字符在程序中替换掉,itext能实现嘛?
- 请指教lookup()和PortableRemoteObject.narrow()
- 一个url的问题
- java中存储int,int,String 行 列 值用什么类型比较好。
- 小问题 quartz定时器时间设置
javax.jms.InvalidClientIDException: Broker: localhost - Client: www.xxxxxx.com already connected from /192.168.0.98:38475
at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:243)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:66)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)
at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:692)
at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:83)
at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:137)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
at java.lang.Thread.run(Thread.java:636)