activeMQ 持久化配置

Mac 中安裝activeMQ

  brew install activemq

啟動

  activemq start

控制台：在瀏覽器中輸入url: http://localhost:8161/

 

A：持久化為文件

     這個你裝ActiveMQ時默認就是這種，只要你設置消息為持久化就可以了。涉及到的配置和代碼有

           <persistenceAdapter> 
          
 <kahaDB directory="${activemq.base}/data/kahadb"/> 
          
 </persistenceAdapter> 
          
 
          
producer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue); 
         

B：持久化為MySql

     你首先需要把MySql的驅動放到ActiveMQ的Lib目錄下，我用的文件名字是：mysql-connector-java-5.0.4-bin.jar

     接下來你修改配置文件

           <persistenceAdapter> 
          
 <jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/> 
          
 </persistenceAdapter> 
         

在配置文件中的broker節點外增加

           <bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> 
          
 <property name="driverClassName" value="com.mysql.jdbc.Driver"/> 
          
 <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/> 
          
 <property name="username" value="activemq"/> 
          
 <property name="password" value="activemq"/> 
          
 <property name="maxActive" value="200"/> 
          
 <property name="poolPreparedStatements" value="true"/> 
          
 </bean> 
         

從配置中可以看出數據庫的名稱是activemq，你需要手動在MySql中增加這個庫。

然后重新啟動消息隊列，你會發現多了3張表

1：activemq_acks

2：activemq_lock

3：activemq_msgs

C：持久化為Oracle

    和持久化為MySql一樣。

 

 

異步訪問：

tcp://localhost:61616?jms.useAsyncSend=true&jms.producerWindowSize=1024000