JMS消息持久化，將ActiveMQ消息持久化到mySql數據庫中

1.  前言

ActiveMQ 是Apache出品，最流行的，能力強勁的開源消息總線。ActiveMQ 是一個徹底支持JMS1.1和J2EE 1.4規範的 JMSProvider實現，儘管JMS規範出臺已是好久的事情了，可是JMS在當今的J2EE應用中間仍然扮演着特殊的地位。

關於ActiveMQ 的詳細介紹請參考：http://baike.baidu.com/view/433374.htm?fr=aladdin

關於JMS的詳細介紹請參考：http://baike.baidu.com/subview/157103/12665866.htm?fr=aladdin

ActiveMQ提供多種數據持久化方式：能夠持久化到文件，也能夠持久化到數據庫，其中數據庫能夠支持MySQL和Oracle兩種類型。

默認提供的是持久化到文件的方式，即activemq.xml文件中的：

<persistenceAdapter>

<kahaDBdirectory="${activemq.base}/data/kahadb"/>

</persistenceAdapter>

2.  步驟

本文重點接收的是持久化到MySQL中的配置方式：

2.1    添加MySQL驅動

首先須要把MySql的驅動放到ActiveMQ的Lib目錄下，我用的文件名字是：

mysql-connector-java-5.1.30-bin.jar

 commons-pool-1.6.jar

commons-dbcp-1.4.jar

2.2    修改配置文件activemq.xml

將其中的這段配置：

<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>

修改成下面這段內容：

<persistenceAdapter>

        <jdbcPersistenceAdapter  dataSource="# mysql-ds "/>

</persistenceAdapter>

 

在</broker>結點以後，增長數據源的配置,以下：

   <!-- MySql DataSource Sample Setup -->  

 <bean id="mysql-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="root"/>  

      <property name="password" value="123456"/>  

      <property name="poolPreparedStatements" value="true"/>  

    </bean>  

        

    <!-- Oracle DataSource Sample Setup -->  

    <!--  

    <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  

      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>  

      <property name="url" value="jdbc:oracle:thin:@localhost:1521:AMQDB"/>  

      <property name="username" value="root"/>  

      <property name="password" value="123456"/>  

      <property name="poolPreparedStatements" value="true"/>  

    </bean>  

 -->  

  

 

2.3    新建數據庫

從配置中能夠看出數據庫的名稱是activemq，須要手動在MySql中新建一個activemq的空數據庫。

此時，從新啓動MQ，就會發現activemq庫中多了三張表：activemq_acks，activemq_lock，activemq_msgs，OK,說明已經持久化成功啦！