activeMQ性能優化--對象池管理connection

activeMQ的某個應用場景，消費者和伺服器隻需建立一個長連接配接，而生産者的情況集中在伺服器,需要對伺服器端的生産者連接配接進行優化。

首先maven引入jar包依賴

[java] ​​view plain​​ ​​copy​​

​​​​

1. <dependency>  
2.        <groupId>org.activemq</groupId>  
3.        <artifactId>activemq-all</artifactId>  
4.        <version>5.9.0</version>  
5.    </dependency>  
6.    <dependency>  
7.        <groupId>org.apache.activemq</groupId>  
8.        <artifactId>activemq-pool</artifactId>  
10.        <exclusions>  
11.            <exclusion>  
12.                <groupId>org.apache.geronimo.specs</groupId>  
13.                <artifactId>geronimo-jms_1.1_spec</artifactId>  
14.            </exclusion>  
15.        </exclusions>  

下面是實作代碼

1. import org.apache.activemq.ActiveMQConnectionFactory;  
2. import org.apache.activemq.pool.PooledConnection;  
3. import org.apache.activemq.pool.PooledConnectionFactory;  
4. import org.slf4j.Logger;  
5. import org.slf4j.LoggerFactory;  
6. import javax.jms.*;  
7. public class MQProductHelper {  
8.   public static final Logger LOG = LoggerFactory.getLogger(MQProductHelper.class);  
9.   private static PooledConnectionFactory poolFactory;  
10.   /** 
11.    * 擷取單例的PooledConnectionFactory 
12.    *  @return 
13.    */  
14.   private static synchronized PooledConnectionFactory getPooledConnectionFactory() {  
15.     LOG.info("getPooledConnectionFactory");  
16.     if (poolFactory != null) return poolFactory;  
17.     LOG.info("getPooledConnectionFactory create new");  
18.     IConfigService configService = ServiceManager.getService(IConfigService.class);  
19.     String userName = configService.getConfig("MQ_USER_NAME", ShopConstant.BC_SHOP_ID);  
20.     String password = configService.getConfig("MQ_USER_PASS", ShopConstant.BC_SHOP_ID);  
21.     String url = configService.getConfig("MQ_BROKER_URL", ShopConstant.BC_SHOP_ID);  
22.     ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(userName, password, url);  
23.     poolFactory = new PooledConnectionFactory(factory);        
24.     // 池中借出的對象的最大數目  
25.     poolFactory.setMaxConnections(100);  
26.     poolFactory.setMaximumActiveSessionPerConnection(50);        
27.     //背景對象清理時，休眠時間超過了3000毫秒的對象為過期  
28.     poolFactory.setTimeBetweenExpirationCheckMillis(3000);  
29.     LOG.info("getPooledConnectionFactory create success");  
30.     return poolFactory;  
31.   }  
33.    * 1.對象池管理connection和session,包括建立和關閉等 
34.    * 2.PooledConnectionFactory預設設定MaxIdle為1， 
35.    *  官方解釋Set max idle (not max active) since our connections always idle in the pool.   * 
36.    *  @return   * @throws JMSException 
38.   public static Session createSession() throws JMSException {  
39.     PooledConnectionFactory poolFactory = getPooledConnectionFactory();  
40.     PooledConnection pooledConnection = (PooledConnection) poolFactory.createConnection();  
41.     //false 參數表示 為非事務型消息，後面的參數表示消息的确認類型（見4.消息發出去後的确認模式）  
42.     return pooledConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
44.   public static void produce(String subject, String msg) {  
45.     LOG.info("producer send msg: {} ", msg);  
46.     if (StringUtil.isEmpty(msg)) {  
47.       LOG.warn("發送消息不能為空。");  
48.       return;  
49.     }  
50.     try {  
51.       Session session = createSession();  
52.       LOG.info("create session");  
53.       TextMessage textMessage = session.createTextMessage(msg);  
54.       Destination destination = session.createQueue(subject);  
55.       MessageProducer producer = session.createProducer(destination);  
56.       producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  
57.       producer.send(textMessage);  
58.       LOG.info("create session success");  
59.     } catch (JMSException e) {  
60.       LOG.error(e.getMessage(), e);  
63.   public static void main(String[] args) {  
64.     MQProductHelper.produce("test.subject", "hello");  
66. }