我使用的是spring jms和activemq结合,在配置文件中定义了普通的connectionFactory的bean,如下所示:
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<description>JMS连接工厂</description>
<property name="brokerURL" value="tcp://192.168.20.23:61616" />
</bean>
定义了上面的文件之后,在使用spring jms的JmsTemplate发送jms消息时,如果发送大量消息的话,有时候会抛出如下异常:
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS
processing; nested exception is javax.jms.JMSException: Could not connect to broker
URL: tcp://192.168.20.23:61616. Reason: java.net.BindException: Address already in use: connect
at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469)
at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:534)
at net.kentop.astoam.device.MG800DeviceService.excute(MG800DeviceService.java:423)
at net.kentop.astoam.device.MG800DeviceService$HandlerReceiveMessage.
handlerUdpData(MG800DeviceService.java:936)
at net.kentop.mon4mg.monitor.UDPReceiverThread.run(UDPReceiverThread.java:51)
Caused by: javax.jms.JMSException: Could not connect to broker URL: tcp://192.168.20.23:61616.
Reason: java.net.BindException: Address already in use: connect
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35)
at org.apache.activemq.ActiveMQConnectionFactory.
createActiveMQConnection(ActiveMQConnectionFactory.java:286)
at org.apache.activemq.ActiveMQConnectionFactory.
createActiveMQConnection(ActiveMQConnectionFactory.java:230)
at org.apache.activemq.ActiveMQConnectionFactory.
createConnection(ActiveMQConnectionFactory.java:178)
at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:184)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:456)
... 4 more
而且在运行的时候会增加很多activemq的线程,使得整个程序运行起来比较慢。通过观察,猜测主要原因是连接activemq时,没有使用池连接,导致每次发送jms消息时,用的不是同一个连接,而是创建一个新的连接,所以耗费很多系统资源,并且因为整个项目是多线程的,所以就会抛出如上面的异常。解决方法是将activemq的连接的bean定义为activemq的池连接定义,将配置文件中的connectionFactory的bean定义改为如下内容:
<bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.20.23:61616" />
</bean>
</property>
</bean>
修改之后重新运行程序,再测试。果然没有占用那么多资源,而且也不会抛出上面的异常了。
注意:要使用activemq的池连接,必须在classpath中包含有activemq-pool.jar
分享到:
相关推荐
ActiveMQ 中javax.jms的源码 javax.jms-sources-1.1.zip
apache-activemq-5.16.6-bin.zip
4.配置环境变量,配置完环境变量之后在任何地方都可以使用命令 activemq启动 ACTIVEMQ_HOME=/opt/apache-activemq-5.15.12 PATH=/opt/apache-activemq-5.15.12/bin:$PATH export ACTIVEMQ_HOME PATH 5....
ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web应用程序之间交换消息,使用MQTT协议管理物联网设备 ActiviMq消息队列,可解决服务解耦合的动作,缓解了服务并发量很大而造成服务器无法处理...
对应Maven信息:groupId:org.apache.activemq.protobuf,artifactId:activemq-protobuf,version:1.1 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中...
MQ是消息中间件,是一种在分布式系统中应用程序借以传递消息的媒介,常用的有ActiveMQ,RabbitMQ,kafka。ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 特点: 1、支持多种...
activemqBroker插件:activemqBroker-2.14-SNAPSHOT.war
apache-activemq-5.15.13-bin.tar.gz Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。
对应Maven信息:groupId:org.apache.activemq.protobuf,artifactId:activemq-protobuf,version:1.1 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中...
支持jdk1.7_80的activeMQ可在Linux环境解压部署,可以参考我的博客
apache-activemq-5.12.0-bin.tar.gz.
apache-activemq-5.3.1-bin.tar.gz安装包,apache-activemq-5.3.1版本安装包
apache-activemq-5.15.3-bin.tar.gz
apache-activemq-5.13.1-bin.tar.gz
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
apache-activemq-5.15.5-bin.tar.gz
apache-activemq-5.6.0-bin.tar.gz
官网下载极慢最新版apache-activemq-5.14.5-bin.tar.gz linux版本
ActiveMQ 5.15.11 Linux版,