activemq-web报错,activemq版本为5.9

错误代码
java.lang.IllegalStateException: A filter or servlet of the current chain does not support asynchronous operations.
at org.apache.catalina.connector.Request.startAsync(Request.java:1675)
at org.apache.catalina.connector.Request.startAsync(Request.java:1668)
at org.apache.catalina.connector.RequestFacade.startAsync(RequestFacade.java:1022)
at org.eclipse.jetty.continuation.Servlet3Continuation.suspend(Servlet3Continuation.java:202)
at org.apache.activemq.web.MessageListenerServlet.doMessages(MessageListenerServlet.java:349)
at org.apache.activemq.web.MessageListenerServlet.doGet(MessageListenerServlet.java:250)
at org.apache.activemq.web.AjaxServlet.doGet(AjaxServlet.java:47)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:624)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:731)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:303)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
at org.eclipse.jetty.continuation.ContinuationFilter.doFilter(ContinuationFilter.java:137)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:218)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:122)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:505)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:169)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103)
at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:958)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:116)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:452)
at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1087)
at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:637)
at org.apache.tomcat.util.net.AprEndpoint$SocketProcessor.doRun(AprEndpoint.java:2517)
at org.apache.tomcat.util.net.AprEndpoint$SocketProcessor.run(AprEndpoint.java:2506)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Thread.java:745)

** 我的web.xml配置**

<?xml version="1.0" encoding="UTF-8"?>


mqajax


Whether we should include an embedded broker or not
org.apache.activemq.brokerURL
tcp://127.0.0.1:61616 <!-- 这里可以写tcp://192.168.1.111:61616的形式连接其他服务器上的ActiveMQ服务器 -->


AjaxServlet
org.apache.activemq.web.AjaxServlet
1
true


MessageServlet
org.apache.activemq.web.MessageServlet
1


QueueBrowseServlet
org.apache.activemq.web.QueueBrowseServlet


PortfolioPublishServlet
org.apache.activemq.web.PortfolioPublishServlet
1


AjaxServlet
/amq/*


MessageServlet
/message/*


QueueBrowseServlet
/queueBrowse/*


PortfolioPublishServlet
/portfolioPublish

<!-- 这种方式是在tomcat7版本以下运行,因为ajax+activemq需要servlet3.0的支持,而servlet3.0又只有在tomcat7中得到支持,所有加上jetty此包,就能在tomcat6运行了 -->


session

org.eclipse.jetty.continuation.ContinuationFilter





session

/*


index.jsp


JS代码

var amq = org.activemq.Amq; amq.init({ uri: 'amq', logging: true, timeout: 20 }); var myHandler = function(message){ $("#msgDiv").append(message); $("#msgDiv").append("<br>"); } amq.addListener("smeguangdong","topic://FirstTopic",myHandler); function send(){ var nickname = $("#nickname").val(); var content = $("#content").val(); var msg = nickname + " : " +content; //alert(msg); amq.sendMessage("topic://FirstTopic","<message>"+msg+"</message>"); }

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
下载的apache-activemq-5.2.0-bin.zip这个压缩文件为什么不能解压

我从apache网站上下载的apache-activemq-5.2.0-bin.zip这个压缩文件为什么不能解压开?我下载apache-activemq-5.1.0-bin.zip以及apache-activemq-5.0.0-bin.zip这两个版本也都打不开,不知道为什么,在解压缩的时候提示:这个压缩文件格式未知或者数据已经被损坏!大家有没有遇到这个问题,是什么原因呢?大家知道的 请告诉小弟!非常谢谢谢!

activeMQ 报错not initialized - call 'refresh'

activeMQ5.13.3版本启动报错,也 找一些资料,说是主机名的问题而我的主机名是没有待下划线啥的乱七八糟的啊,那个大神遇到过嘛?请教了。。。 2016-11-17 09:17:23,015 | INFO | Apache ActiveMQ 5.13.3 (localhost, ID:linjiexianserver-3840-1479345442777-0:1) is shutdown | org.apache.activemq.broker.BrokerService | main 2016-11-17 09:17:23,016 | INFO | Closing org.apache.activemq.xbean.XBeanBrokerFactory$1@71f80d51: startup date [Thu Nov 17 09:17:21 CST 2016]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2016-11-17 09:17:23,019 | WARN | Exception thrown from LifecycleProcessor on context close | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main java.lang.IllegalStateException: LifecycleProcessor not initialized - call 'refresh' before invoking lifecycle methods via the context: org.apache.activemq.xbean.XBeanBrokerFactory$1@71f80d51: startup date [Thu Nov 17 09:17:21 CST 2016]; root of context hierarchy at org.springframework.context.support.AbstractApplicationContext.getLifecycleProcessor(AbstractApplicationContext.java:357)[spring-context-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:884)[spring-context-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:843)[spring-context-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.apache.activemq.hooks.SpringContextHook.run(SpringContextHook.java:30)[activemq-spring-5.13.3.jar:5.13.3] at org.apache.activemq.broker.BrokerService.stop(BrokerService.java:873)[activemq-broker-5.13.3.jar:5.13.3] at org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:122)[activemq-spring-5.13.3.jar:5.13.3] at org.apache.activemq.broker.BrokerService.start(BrokerService.java:627)[activemq-broker-5.13.3.jar:5.13.3] at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:73)[activemq-spring-5.13.3.jar:5.13.3] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.7.0_80] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)[:1.7.0_80] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.7.0_80] at java.lang.reflect.Method.invoke(Method.java:606)[:1.7.0_80] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1700)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1639)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1568)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:539)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:303)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:755)[spring-beans-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:762)[spring-context-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480)[spring-context-4.1.9.RELEASE.jar:4.1.9.RELEASE] at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:64)[xbean-spring-3.18.jar:3.18] at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:52)[xbean-spring-3.18.jar:3.18] at org.apache.activemq.xbean.XBeanBrokerFactory$1.<init>(XBeanBrokerFactory.java:104)[activemq-spring-5.13.3.jar:5.13.3] at org.apache.activemq.xbean.XBeanBrokerFactory.createApplicationContext(XBeanBrokerFactory.java:104)[activemq-spring-5.13.3.jar:5.13.3] at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:67)[activemq-spring-5.13.3.jar:5.13.3] at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:71)[activemq-broker-5.13.3.jar:5.13.3] at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:54)[activemq-broker-5.13.3.jar:5.13.3] at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:87)[activemq-console-5.13.3.jar:5.13.3] at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:63)[activemq-console-5.13.3.jar:5.13.3] at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:154)[activemq-console-5.13.3.jar:5.13.3] at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:63)[activemq-console-5.13.3.jar:5.13.3] at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:104)[activemq-console-5.13.3.jar:5.13.3] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.7.0_80] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)[:1.7.0_80] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.7.0_80] at java.lang.reflect.Method.invoke(Method.java:606)[:1.7.0_80] at org.apache.activemq.console.Main.runTaskClass(Main.java:262)[activemq.jar:5.13.3] at org.apache.activemq.console.Main.main(Main.java:115)[activemq.jar:5.13.3] 2016-11-17 09:17:23,025 | WARN | Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.apache.activemq.xbean.XBeanBrokerService#0' defined in class path resource [activemq.xml]: Invocation of init method failed; nested exception is java.io.IOException: Transport Connector could not be registered in JMX: java.io.IOException: Failed to bind to server socket: amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600 due to: java.net.BindException: Address already in use | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main

spring activemq 关闭时报错

javax.jms.JMSException: Peer (vm://localhost#3) disposed. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1292) at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1284) at org.apache.activemq.AdvisoryConsumer.dispose(AdvisoryConsumer.java:57) at org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:632) at org.springframework.jms.connection.SingleConnectionFactory.closeConnection(SingleConnectionFactory.java:456) at org.springframework.jms.connection.SingleConnectionFactory.resetConnection(SingleConnectionFactory.java:345) at org.springframework.jms.connection.CachingConnectionFactory.resetConnection(CachingConnectionFactory.java:205) at org.springframework.jms.connection.SingleConnectionFactory.destroy(SingleConnectionFactory.java:335) at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:258) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroyBean(DefaultSingletonBeanRegistry.java:540) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingleton(DefaultSingletonBeanRegistry.java:516) at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingleton(DefaultListableBeanFactory.java:827) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingletons(DefaultSingletonBeanRegistry.java:485) at org.springframework.context.support.AbstractApplicationContext.destroyBeans(AbstractApplicationContext.java:921) at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:895) at org.springframework.context.support.AbstractApplicationContext$1.run(AbstractApplicationContext.java:809) Caused by: org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://localhost#3) disposed. at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:89) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1290) ... 15 more 10:01:29 [org.apache.activemq.util.ThreadPoolUtils:136] [DEBUG] - Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@5294755d[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. 10:01:29 [org.apache.activemq.util.ThreadPoolUtils:54] [DEBUG] - Forcing shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@6f902c71[Running, pool size = 2, active threads = 0, queued tasks = 0, completed tasks = 6] 10:01:29 [org.springframework.jms.connection.CachingConnectionFactory:463] [DEBUG] - Could not close shared JMS Connection javax.jms.JMSException: Peer (vm://localhost#3) disposed. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQConnection.doSyncSendPacket(ActiveMQConnection.java:1431) at org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:675) at org.springframework.jms.connection.SingleConnectionFactory.closeConnection(SingleConnectionFactory.java:456) at org.springframework.jms.connection.SingleConnectionFactory.resetConnection(SingleConnectionFactory.java:345) at org.springframework.jms.connection.CachingConnectionFactory.resetConnection(CachingConnectionFactory.java:205) at org.springframework.jms.connection.SingleConnectionFactory.destroy(SingleConnectionFactory.java:335) at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:258) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroyBean(DefaultSingletonBeanRegistry.java:540) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingleton(DefaultSingletonBeanRegistry.java:516) at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingleton(DefaultListableBeanFactory.java:827) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingletons(DefaultSingletonBeanRegistry.java:485) at org.springframework.context.support.AbstractApplicationContext.destroyBeans(AbstractApplicationContext.java:921) at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:895) at org.springframework.context.support.AbstractApplicationContext$1.run(AbstractApplicationContext.java:809) Caused by: org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://localhost#3) disposed. at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:89) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81) at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:91) at org.apache.activemq.ActiveMQConnection.doSyncSendPacket(ActiveMQConnection.java:1418) ... 13 more 10:01:29 [org.springframework.beans.factory.support.DisposableBeanAdapter:323] [DEBUG] - Invoking destroy method 'close' on bean with name 'dataSource'

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启动问题,总是一闪而过

<div class="iteye-blog-content-contain" style="font-size: 14px;"> <p>下的是apache-activemq-5.8.0,点击里面lib下activemq.bat总是一闪而过,无法启动,jdk1.6.0_43的相关环境变量也是配好了的,弄了半天也没解决问题,有谁知道原因啊?在此拜谢。</p> <p>对了,自己装了win8系统,难道跟系统有点关系?</p> </div>

activeMQ启动时出错,导致安装失败

这是在启动activeMQ运行bin/win32/activemq.bat时,出现错误图片,求大神看看到底是什么原因导致的,跪求 ![图片说明](https://img-ask.csdn.net/upload/201604/14/1460621288_831623.png)

ActiveMQcpp测试失败!

auto_ptr<ConnectionFactory> connectionFactory( ConnectionFactory::createCMSConnectionFactory( brokerURI ) ); 进入这条语句后就死了

activeMQ创建连接抛空指针

javax.jms.JMSException: java.lang.NullPointerException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1287) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1384) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:504) ~[activemq-all-5.4.2.jar:5.4.2] at com.catt.pub.net.jms.service.JMSCommon.connectio.createSessn(JMSCommon.java:192) ~[catt-pub-net.jar:na] at com.catt.pub.net.jms.service.Consumerion(Consumer.java:300) ~[catt-pub-net.jar:na] at com.catt.pub.net.jms.service.Consumer.createConsumerByTopic(Consumer.java:221) ~[catt-pub-net.jar:na] at com.catt.pub.net.jms.JMSUtils.getConsumer(JMSUtilJMSManageImpl.createConsumerss.java:137) ~[catt-pub-net.jar:na] at com.catt.zhwg.jms.services.collect.(JMSManageImpl.java:174) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] at com.catt.zhwg.jms.services.collect.JMSManageImpl.launch(JMSManageImpl.java:132) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] at com.catt.zhwg.jms.ManageThread.launch(ManageThread.java:106) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] at com.catt.zhwg.jms.utils.swing.Console.start(Console.java:172) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] at com.catt.zhwg.jms.utils.swing.Console.start(Console.java:153) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] at com.catt.zhwg.jms.utils.swing.SwingMain.main(SwingMain.java:50) [JMSCollectModule-1.0.0.0-SNAPSHOT.jar:na] java.lang.NullPointerException: null at com.huawei.imanager.nbi.activemq.security.CustomAuthenticate.addConnection(CustomAuthenticate.java:92) ~[na:na] at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:715) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:79) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229) ~[na:na] at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222) ~[activemq-all-5.4.2.jar:5.4.2] at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204) ~[activemq-all-5.4.2.jar:5.4.2] at java.lang.Thread.run(Unknown Source) ~[na:1.6.0_23]

SunOS10上部署ActivemqCPP(CMS)开源库各种崩溃,求分享经验

最近有个项目需要在一个老系统平台是SunOS上开发基于JMS通信的新增功能。由于只能用c/c++,只好搭建开源库AcitveMQCPP,我用的版本是3.6且编译安装成为32位动态库,apr及apr-util都安装成功,但是编译安装ActiveMQCPP的时候遇到各种语法问题,好不容易编译安装完成,运行ActieMQ服务器后测试实例example老是coredump,跟踪一堆问题什么线程计数器等等,头都大了。 有哪些大牛跑过啊,跪求经验。

Active MQ 在Centos无法启动

如题,启动信息如下,这是什么情况啊 ``` INFO: Loading '/usr/local/activemq/apache-activemq-5.15.10//bin/env' INFO: Using java '/usr/java/jdk1.8.0_221/bin/java' Java Runtime: Oracle Corporation 1.8.0_221 /usr/java/jdk1.8.0_221/jre Heap sizes: current=63360k free=62653k max=1013632k JVM args: -Xms64M -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=/usr/local/activemq/apache-activemq-5.15.10//conf/login.config -Dactivemq.classpath=/usr/local/activemq/apache-activemq-5.15.10//conf:/usr/local/activemq/apache-activemq-5.15.10//../lib/: -Dactivemq.home=/usr/local/activemq/apache-activemq-5.15.10/ -Dactivemq.base=/usr/local/activemq/apache-activemq-5.15.10/ -Dactivemq.conf=/usr/local/activemq/apache-activemq-5.15.10//conf -Dactivemq.data=/usr/local/activemq/apache-activemq-5.15.10//data Extensions classpath: [/usr/local/activemq/apache-activemq-5.15.10/lib,/usr/local/activemq/apache-activemq-5.15.10/lib/camel,/usr/local/activemq/apache-activemq-5.15.10/lib/optional,/usr/local/activemq/apache-activemq-5.15.10/lib/web,/usr/local/activemq/apache-activemq-5.15.10/lib/extra] ACTIVEMQ_HOME: /usr/local/activemq/apache-activemq-5.15.10 ACTIVEMQ_BASE: /usr/local/activemq/apache-activemq-5.15.10 ACTIVEMQ_CONF: /usr/local/activemq/apache-activemq-5.15.10/conf ACTIVEMQ_DATA: /usr/local/activemq/apache-activemq-5.15.10/data Usage: ./activemq [--extdir <dir>] [task] [task-options] [task data] Tasks: browse - Display selected messages in a specified destination. bstat - Performs a predefined query that displays useful statistics regarding the specified broker consumer - Receives messages from the broker create - Creates a runnable broker instance in the specified path. decrypt - Decrypts given text dstat - Performs a predefined query that displays useful tabular statistics regarding the specified destination type encrypt - Encrypts given text export - Exports a stopped brokers data files to an archive file list - Lists all available brokers in the specified JMX context producer - Sends messages to the broker purge - Delete selected destination's messages that matches the message selector query - Display selected broker component's attributes and statistics. start - Creates and starts a broker using a configuration file, or a broker URI. stop - Stops a running broker specified by the broker name. Task Options (Options specific to each task): --extdir <dir> - Add the jar files in the directory to the classpath. --version - Display the version information. -h,-?,--help - Display this help information. To display task specific help, use Main [task] -h,-?,--help Task Data: - Information needed by each specific task. JMX system property options: -Dactivemq.jmx.url=<jmx service uri> (default is: 'service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi') -Dactivemq.jmx.user=<user name> -Dactivemq.jmx.password=<password> Tasks provided by the sysv init script: kill - terminate instance in a drastic way by sending SIGKILL restart - stop running instance (if there is one), start new instance console - start broker in foreground, useful for debugging purposes status - check if activemq process is running Configuration of this script: The configuration of this script is read from the following files: /etc/default/activemq /root/.activemqrc /usr/local/activemq/apache-activemq-5.15.10//bin/env This script searches for the files in the listed order and reads the first available file. Modify /usr/local/activemq/apache-activemq-5.15.10//bin/env or create a copy of that file on a suitable location. To use additional configurations for running multiple instances on the same operating system rename or symlink script to a name matching to activemq-instance-<INSTANCENAME>. This changes the configuration location to /etc/default/activemq-instance-<INSTANCENAME> and $HOME/.activemqrc-instance-<INSTANCENAME>. ```

activemq not initialized - call 'refresh'

改了activeMQ的activeMQ.xml文件(也就是在里面加入mysql持久化方式),然后activemq.bat文件启动后就闪退了,activeMQ.log日志文件记录的错误如下: java.lang.IllegalStateException: LifecycleProcessor not initialized - call 'refresh' before invoking lifecycle methods via the context: org.apache.activemq.xbean.XBeanBrokerFactory$1@1ceabc1: startup date [Tue Mar 14 11:16:52 CST 2017]; root of context hierarchy at org.springframework.context.support.AbstractApplicationContext.getLifecycleProcessor(AbstractApplicationContext.java:353) at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1045) at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:1000) at org.apache.activemq.hooks.SpringContextHook.run(SpringContextHook.java:30) at org.apache.activemq.broker.BrokerService.stop(BrokerService.java:766) at org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:96) at org.apache.activemq.broker.BrokerService.start(BrokerService.java:559) at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:60) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1581) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1522) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:605) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:925) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:472) at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:64) at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:52) at org.apache.activemq.xbean.XBeanBrokerFactory$1.<init>(XBeanBrokerFactory.java:101) at org.apache.activemq.xbean.XBeanBrokerFactory.createApplicationContext(XBeanBrokerFactory.java:101) at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:65) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:71) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:54) at org.apache.activemq.console.command.StartCommand.startBroker(StartCommand.java:125) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:84) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:150) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:104) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.activemq.console.Main.runTaskClass(Main.java:262) at org.apache.activemq.console.Main.main(Main.java:115) 我的计算名称已经改为admin了,麻烦知道的大神告诉小弟一下,在此谢过!

急!ActiveMQ集群启动失败 No IOExceptionHandler registered, ignoring IO exception

ActiveMQ是最新5.15的版本,结合zookeeper搭的集群,搭建好第一次用时很正常,然后关机第二天重启以后发现启动失败了,控制台也打不开,大家能帮忙看看问题在哪么? ``` 2019-10-30 19:28:09,199 | INFO | No IOExceptionHandler registered, ignoring IO exception | org.apache.activemq.broker.BrokerService | LevelDB IOException handler. java.io.IOException: com/google/common/util/concurrent/internal/InternalFutureFailureAccess at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:40)[activemq-client-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.LevelDBClient.replay_init(LevelDBClient.scala:667)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.LevelDBClient.start(LevelDBClient.scala:558)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.DBManager.start(DBManager.scala:648)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.LevelDBStore.doStart(LevelDBStore.scala:312)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.replicated.MasterLevelDBStore.doStart(MasterLevelDBStore.scala:110)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)[activemq-client-5.15.10.jar:5.15.10] at org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1.apply$mcV$sp(ElectingLevelDBStore.scala:230)[activemq-leveldb-store-5.15.10.jar:5.15.10] at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)[hawtdispatch-scala-2.11-1.22.jar:1.22] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_191] at java.lang.Thread.run(Thread.java:748)[:1.8.0_191] 2019-10-30 19:28:09,207 | INFO | Stopped LevelDB[/usr/local/activemq/apache-activemq-5.15.10/data/leveldb] | org.apache.activemq.leveldb.LevelDBStore | LevelDB IOException handler. ``` 查了网上的解决方案 一种是让删除lib文件夹下的一个jar包,但是我看了文件夹里面并没有 另一种让把配置文件xml里面的日志配置注释掉,我注释后再运行,日志内容如下: 2019-10-30 21:09:25,810 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@598067a5: startup date [Wed Oct 30 21:09:25 CST 2019]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2019-10-30 21:09:26,471 | INFO | Using Persistence Adapter: Replicated LevelDB[/usr/local/activemq/apache-activemq-5.15.10/data/leveldb, 211.67.17.205:2181,211.67.19.187:2181,211.67.16.224:2181//activemq/leveldb-stores] | org.apache.activemq.broker.BrokerService | main 2019-10-30 21:09:26,572 | INFO | Starting StateChangeDispatcher | org.apache.activemq.leveldb.replicated.groups.ZKClient | ZooKeeper state change dispatcher thread 2019-10-30 21:09:26,578 | INFO | Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:host.name=admin1 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.version=1.8.0_191 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.vendor=Oracle Corporation | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.home=/usr/java/jdk1.8.0_191/jre | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.class.path=/usr/local/activemq/apache-activemq-5.15.10/bin/activemq.jar | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.io.tmpdir=/usr/local/activemq/apache-activemq-5.15.10/tmp | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:java.compiler=<NA> | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:os.name=Linux | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:os.arch=amd64 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:os.version=3.13.0-24-generic | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,578 | INFO | Client environment:user.name=admin1 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,579 | INFO | Client environment:user.home=/home/admin1 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,579 | INFO | Client environment:user.dir=/usr/local/activemq/zookeeper-3.4.10/bin | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,579 | INFO | Initiating client connection, connectString=211.67.17.205:2181,211.67.19.187:2181,211.67.16.224:2181 sessionTimeout=2000 watcher=org.apache.activemq.leveldb.replicated.groups.ZKClient@dc7df28 | org.apache.zookeeper.ZooKeeper | main 2019-10-30 21:09:26,591 | WARN | SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/usr/local/activemq/apache-activemq-5.15.10/conf/login.config'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. | org.apache.zookeeper.ClientCnxn | main-SendThread(211.67.19.187:2181) 2019-10-30 21:09:26,592 | INFO | Opening socket connection to server 211.67.19.187/211.67.19.187:2181 | org.apache.zookeeper.ClientCnxn | main-SendThread(211.67.19.187:2181) 2019-10-30 21:09:26,593 | WARN | unprocessed event state: AuthFailed | org.apache.activemq.leveldb.replicated.groups.ZKClient | main-EventThread 2019-10-30 21:09:26,595 | INFO | Socket connection established to 211.67.19.187/211.67.19.187:2181, initiating session | org.apache.zookeeper.ClientCnxn | main-SendThread(211.67.19.187:2181) 2019-10-30 21:09:26,611 | INFO | Session establishment complete on server 211.67.19.187/211.67.19.187:2181, sessionid = 0x26e1bcd90df0005, negotiated timeout = 4000 | org.apache.zookeeper.ClientCnxn | main-SendThread(211.67.19.187:2181)

Linux 启动activemq报错?Could not load properties求大神指点

**Linux activemq 无法启动mq ** 报错如下: 2017-03-28 16:34:42,493 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@14d9c11d: startup date [Tue Mar 28 16:34:42 CST 2017]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2017-03-28 16:34:42,990 | ERROR | Failed to load: class path resource [activemq.xml], reason: Could not load properties; nested exception is java.net.ConnectException: Connection refused | org.apache.activemq.xbean.XBeanBrokerFactory | main org.springframework.beans.factory.BeanInitializationException: Could not load properties; nested exception is java.net.ConnectException: Connection refused okeBeanFactoryPostProcessors(AbstractApplicationContext.java:663) 求大神们指点指点

把activemq.xml文件更改为mysql持久化之后就会启动报错是怎么回事呢?

在弄activemq持久化的,我把activemq.xml文件更改为mysql持久化之后就会启动报错是怎么回事呢?

关于jmx连接linux上的activemq,实现监控,一直提示连接超时

linux版本:Red Hat Enterprise Linux Server release 5.6 activemq版本:apache-activemq-5.8.0 ============================ 本地端使用Java的JMX方法来远程连接activemq,用来返回队列相关信息,但是后台一直报连接超时 java.net.ConnectException: Connection timed out: connect linux上的activemq已设置 useJmx="true" <managementContext createConnector="true" connectorPort="11099" /> bin文件夹中的 activemq也修改了,解开了注释 ACTIVEMQ_SUNJMX_START="-Dcom.sun.management.jmxremote.port=11099 " ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.password.file=${ACTIVEMQ_CONF}/jmx.password" ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.access.file=${ACTIVEMQ_CONF}/jmx.access" ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.ssl=false" ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote" hosts文件的ip地址也改成本机地址了,hostname也曾经改过,但是没效果,就改回来了 现在已经不知道该怎么改了,始终没法连接成功,烦请各位大佬支支招。

请教大家 ActiveMQ在Android上面怎么部署

是ActiveMQ,不是MQTT. 我的ActiveMQ的Demo可以在Eclipse上面跑, 移植到Android上面就 Process: com.jf.activemqtest, PID: 23497 java.lang.NoClassDefFoundError: org.apache.activemq.ActiveMQConnectionFactory

关于ActiveMQ的编码与List问题

最近在做JMS,用Apache的ActiveMQ作为消息中间件,出现了两个问题: 1、服务端返回值中存在中文时,就报错,如下:Exception in thread "main" org.apache.axiom.om.OMException: com.ctc.wstx.exc.WstxIOException: Invalid UTF-8 middle byte 0xd5 (at char #233, byte #127) 针对该问题,网上有人说“调用接口的文件的编码方式不是UTF-8格式”,但是还是不知道怎么改正。 2、当服务端放回为为List时,报错如下:javax.xml.bind.JAXBException: java.util.List is not known to this context 该问题都不知道是什么原因。 请各问大神帮忙解决一下,谢谢!

activeMQ代码在eclipse里运行出现java.net.BindException: Address already in use: JVM_Bind

大家好!我最近在研究activeMQ,我把一些网上的例子在eclipse里运行(没有用spring,觉得spring太麻烦了 先不考虑) 但是第一次运行,结果正常,再运行一遍,就会出现如下error ---------------------------------------------------------------------------------------------------- [color=red]java.io.IOException: Failed to bind to server socket: tcp://localhost:61616 due to: java.net.BindException: Address already in use: JVM_Bind at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33) at org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:141) at org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60) at org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:131) at org.apache.activemq.broker.BrokerService.createTransportConnector(BrokerService.java:1712) at org.apache.activemq.broker.BrokerService.addConnector(BrokerService.java:217) at org.apache.activemq.broker.BrokerService.addConnector(BrokerService.java:207) at homework.Test.main(Test.java:18) Caused by: java.net.BindException: Address already in use: JVM_Bind at java.net.PlainSocketImpl.socketBind(Native Method) at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:359) at java.net.ServerSocket.bind(ServerSocket.java:319) at java.net.ServerSocket.<init>(ServerSocket.java:185) at java.net.ServerSocket.<init>(ServerSocket.java:141) at javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:162) at org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:134) ... 6 more 2009-10-14 9:55:05 org.apache.activemq.transport.failover.FailoverTransport doReconnect 信息: Successfully connected to tcp://localhost:61616[/color]Consumer:->Begin listening... [color=red]2009-10-14 9:55:06 org.apache.activemq.transport.failover.FailoverTransport doReconnect[/color] [color=red]信息: Successfully connected to tcp://localhost:61616[/color] Producer:->Sending message: Hello, world! Producer:->Message sent complete! Producer:->Closing connection Consumer:->Received: Hello, world! Consumer:->Closing connection -------------------------------------------------------------------------------------------------- 虽然结果还是能出来,但是java.io.IOException: Failed to bind to server socket: tcp://localhost:61616 due to: java.net.BindException: Address already in use: JVM_Bind不知道怎么解决,一定要重启eclipse才不报错。 我main函数的代码如下 package homework; import javax.jms.JMSException; import org.apache.activemq.broker.BrokerService; public class Test{ /** *//** * @param args */ public static void main(String[] args) throws JMSException, Exception { // TODO Auto-generated method stub BrokerService broker = new BrokerService(); broker.setUseJmx(true); try { broker.addConnector("tcp://localhost:61616"); broker.start(); } catch (InterruptedException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } ConsumerTool consumer = new ConsumerTool(); ProducerTool producer = new ProducerTool(); // 开始监听 consumer.consumeMessage(); // 延时500毫秒之后发送消息 Thread.sleep(500); producer.produceMessage("Hello, world!"); producer.close(); // 延时500毫秒之后停止接受消息 Thread.sleep(500); consumer.close(); broker.stop(); } } 请指点 谢谢!!!是要关掉什么服务吗?怎么关呢?如有需要 我把producerTool和ProducerTool的代码也贴上来 [b]问题补充:[/b] ProducerTool和ConsumerTool这两个类我是从网上找的 ProducerTool ------------------------------------------------------ package homework; import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; public class ProducerTool{ private String user = ActiveMQConnection.DEFAULT_USER; private String password = ActiveMQConnection.DEFAULT_PASSWORD; private String url = ActiveMQConnection.DEFAULT_BROKER_URL; private String subject = "TOOL.DEFAULT"; private Destination destination = null; private Connection connection = null; private Session session = null; private MessageProducer producer = null; // 初始化 private void initialize() throws JMSException, Exception{ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory( user, password, url); connection = connectionFactory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue(subject); producer = session.createProducer(destination); producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); } // 发送消息 public void produceMessage(String message) throws JMSException, Exception{ initialize(); TextMessage msg = session.createTextMessage(message); connection.start(); System.out.println("Producer:->Sending message: " + message); producer.send(msg); System.out.println("Producer:->Message sent complete!"); } // 关闭连接 public void close() throws JMSException{ System.out.println("Producer:->Closing connection"); if (producer != null) producer.close(); if (session != null) session.close(); if (connection != null) connection.close(); } } ------------------------------------------------------------- ConsumerTool package homework; import javax.jms.Connection; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageConsumer; import javax.jms.Session; import javax.jms.MessageListener; import javax.jms.Message; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; public class ConsumerTool implements MessageListener{ private String user = ActiveMQConnection.DEFAULT_USER; private String password = ActiveMQConnection.DEFAULT_PASSWORD; private String url = ActiveMQConnection.DEFAULT_BROKER_URL; private String subject = "TOOL.DEFAULT"; private Destination destination = null; private Connection connection = null; private Session session = null; private MessageConsumer consumer = null; // 初始化 private void initialize() throws JMSException, Exception{ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory( user, password, url); connection = connectionFactory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue(subject); consumer = session.createConsumer(destination); } // 消费消息 public void consumeMessage() throws JMSException, Exception{ initialize(); connection.start(); System.out.println("Consumer:->Begin listening..."); // 开始监听 consumer.setMessageListener(this); // Message message = consumer.receive(); } // 关闭连接 public void close() throws JMSException{ System.out.println("Consumer:->Closing connection"); if (consumer != null) consumer.close(); if (session != null) session.close(); if (connection != null) connection.close(); } // 消息处理函数 public void onMessage(Message message){ try { if (message instanceof TextMessage){ TextMessage txtMsg = (TextMessage) message; String msg = txtMsg.getText(); System.out.println("Consumer:->Received: " + msg); } else { System.out.println("Consumer:->Received: " + message); } } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } 第一次运行代码是好的,再运行一遍就会说java.io.IOException: Failed to bind to server socket: tcp://localhost:61616 due to: java.net.BindException: Address already in use: JVM_Bind 一定要重启eclipse才行 好郁闷啊 8)

通过Go中的STOMP连接到ActiveMQ出错

<div class="post-text" itemprop="text"> <p>我正在试图通过github.com/go-STOMP/STOMP库连接到AWS上的ActiveMQ实例。</p> <p>以下代码引发了无效的命令错误:</p> <pre><code>func (s *STOMP) Init() error { netConn, err := stomp.Dial("tcp", "host:61614") if err != nil { return errors.Wrap(err, "dial to server") } s.conn = netConn return nil } </code></pre> </div>

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

程序员请照顾好自己,周末病魔差点一套带走我。

程序员在一个周末的时间,得了重病,差点当场去世,还好及时挽救回来了。

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

点沙成金:英特尔芯片制造全过程揭密

“亚马逊丛林里的蝴蝶扇动几下翅膀就可能引起两周后美国德州的一次飓风……” 这句人人皆知的话最初用来描述非线性系统中微小参数的变化所引起的系统极大变化。 而在更长的时间尺度内,我们所生活的这个世界就是这样一个异常复杂的非线性系统…… 水泥、穹顶、透视——关于时间与技艺的蝴蝶效应 公元前3000年,古埃及人将尼罗河中挖出的泥浆与纳特龙盐湖中的矿物盐混合,再掺入煅烧石灰石制成的石灰,由此得来了人...

上班一个月,后悔当初着急入职的选择了

最近有个老铁,告诉我说,上班一个月,后悔当初着急入职现在公司了。他之前在美图做手机研发,今年美图那边今年也有一波组织优化调整,他是其中一个,在协商离职后,当时捉急找工作上班,因为有房贷供着,不能没有收入来源。所以匆忙选了一家公司,实际上是一个大型外包公司,主要派遣给其他手机厂商做外包项目。**当时承诺待遇还不错,所以就立马入职去上班了。但是后面入职后,发现薪酬待遇这块并不是HR所说那样,那个HR自...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

外包程序员的幸福生活

今天给你们讲述一个外包程序员的幸福生活。男主是Z哥,不是在外包公司上班的那种,是一名自由职业者,接外包项目自己干。接下来讲的都是真人真事。 先给大家介绍一下男主,Z哥,老程序员,是我十多年前的老同事,技术大牛,当过CTO,也创过业。因为我俩都爱好喝酒、踢球,再加上住的距离不算远,所以一直也断断续续的联系着,我对Z哥的状况也有大概了解。 Z哥几年前创业失败,后来他开始干起了外包,利用自己的技术能...

C++11:一些微小的变化(新的数据类型、template表达式内的空格、nullptr、std::nullptr_t)

本文介绍一些C++的两个新特性,它们虽然微小,但对你的编程十分重要 一、Template表达式内的空格 C++11标准之前建议在“在两个template表达式的闭符之间放一个空格”的要求已经过时了 例如: vector&lt;list&lt;int&gt; &gt;; //C++11之前 vector&lt;list&lt;int&gt;&gt;; //C++11 二、nullptr ...

优雅的替换if-else语句

场景 日常开发,if-else语句写的不少吧??当逻辑分支非常多的时候,if-else套了一层又一层,虽然业务功能倒是实现了,但是看起来是真的很不优雅,尤其是对于我这种有强迫症的程序"猿",看到这么多if-else,脑袋瓜子就嗡嗡的,总想着解锁新姿势:干掉过多的if-else!!!本文将介绍三板斧手段: 优先判断条件,条件不满足的,逻辑及时中断返回; 采用策略模式+工厂模式; 结合注解,锦...

深入剖析Springboot启动原理的底层源码,再也不怕面试官问了!

大家现在应该都对Springboot很熟悉,但是你对他的启动原理了解吗?

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试:第十六章:Java中级开发(16k)

HashMap底层实现原理,红黑树,B+树,B树的结构原理 Spring的AOP和IOC是什么?它们常见的使用场景有哪些?Spring事务,事务的属性,传播行为,数据库隔离级别 Spring和SpringMVC,MyBatis以及SpringBoot的注解分别有哪些?SpringMVC的工作原理,SpringBoot框架的优点,MyBatis框架的优点 SpringCould组件有哪些,他们...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

【阿里P6面经】二本,curd两年,疯狂复习,拿下阿里offer

二本的读者,在老东家不断学习,最后逆袭

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

《经典算法案例》01-08:如何使用质数设计扫雷(Minesweeper)游戏

我们都玩过Windows操作系统中的经典游戏扫雷(Minesweeper),如果把质数当作一颗雷,那么,表格中红色的数字哪些是雷(质数)?您能找出多少个呢?文中用列表的方式罗列了10000以内的自然数、质数(素数),6的倍数等,方便大家观察质数的分布规律及特性,以便对算法求解有指导意义。另外,判断质数是初学算法,理解算法重要性的一个非常好的案例。

《Oracle Java SE编程自学与面试指南》最佳学习路线图(2020最新版)

正确选择比瞎努力更重要!

面试官:你连SSO都不懂,就别来面试了

大厂竟然要考我SSO,卧槽。

微软为一人收购一公司?破解索尼程序、写黑客小说,看他彪悍的程序人生!...

作者 | 伍杏玲出品 | CSDN(ID:CSDNnews)格子衬衫、常掉发、双肩包、修电脑、加班多……这些似乎成了大众给程序员的固定标签。近几年流行的“跨界风”开始刷新人们对程序员的...

终于,月薪过5万了!

来看几个问题想不想月薪超过5万?想不想进入公司架构组?想不想成为项目组的负责人?想不想成为spring的高手,超越99%的对手?那么本文内容是你必须要掌握的。本文主要详解bean的生命...

我说我懂多线程,面试官立马给我发了offer

不小心拿了几个offer,有点烦

自从喜欢上了B站这12个UP主,我越来越觉得自己是个废柴了!

不怕告诉你,我自从喜欢上了这12个UP主,哔哩哔哩成为了我手机上最耗电的软件,几乎每天都会看,可是吧,看的越多,我就越觉得自己是个废柴,唉,老天不公啊,不信你看看…… 间接性踌躇满志,持续性混吃等死,都是因为你们……但是,自己的学习力在慢慢变强,这是不容忽视的,推荐给你们! 都说B站是个宝,可是有人不会挖啊,没事,今天咱挖好的送你一箩筐,首先啊,我在B站上最喜欢看这个家伙的视频了,为啥 ,咱撇...

立即提问
相关内容推荐