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)不知道改如何下手解决这个问题了?!

解决方案 »

  1.   

    [ERROR] javax.jms.InvalidClientIDException: Broker: localhost - Client: www.xxxxxx.com already connected from /192.168.0.98:38475 
    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)