JMS之——ActiveMQ時拋出的錯誤Could not connect to broker URL-使用線程池解決高並發連接

轉載請注明出處：http://blog.csdn.net/l1028386804/article/details/69046395

解決使用activemq時拋出的異常：javax.j ms.JMSException: Could not connect to broker URL
我使用的是spring jms和activemq結合，在配置文件中定義了普通的connectionFactory的bean，如下所示：

   
   
  
  
          
 
           
 
            
 
             
 
            
 
            
 
             
 
              <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
             
 
            
 
           
 
            
 
             
 
            
 
            
 
             
 
              <description>JMS連接工廠 
              </description> 
             
 
            
 
           
 
            
 
             
 
            
 
            
 
             
 
              <property name="brokerURL" value="tcp://192.168.50.131: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.50.131: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.50.131:61616" /> 
             
 
            
 
           
 
            
 
             
 
            
 
            
 
             
 
              </bean> 
             
 
            
 
           
 
            
 
             
 
            
 
            
 
             
 
              </property> 
             
 
            
 
           
 
            
 
             
 
            
 
            
 
             
 
              </bean> 
             
 
            
 
          
  
  
 
 
         

修改之后重新運行程序，再測試。果然沒有占用那么多資源，而且也不會拋出上面的異常了。
注意：要使用activemq的池連接，必須在classpath中包含有activemq-pool.jar