Apache ActiveMQ 持久化到MySQL数据库的简单配置

时间:2022-09-10 13:02:00

1.  前言

ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管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>

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

</persistenceAdapter>

2.  步骤

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

2.1    添加MySQL驱动

首先需要把MySql的驱动放到ActiveMQ的Lib目录下,我用的文件名字是:mysql-connector-java-5.1.30-bin.jar

 

2.2    修改配置文件activemq.xml

将其中的这段配置:

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

修改为下面这段内容:

<persistenceAdapter>

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

</persistenceAdapter>

 

另外需要在broker节点的上面定义id为derby-ds的bean,如下:

                   <beanid="derby-ds"class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close">

                            <propertyname="driverClassName" value="com.mysql.jdbc.Driver"/>

                            <property name="url"value="jdbc:mysql://localhost:3306/test_mq?relaxAutoCommit=true"/>

                            <propertyname="username" value="root"/>

                            <propertyname="password" value="root"/>

                            <propertyname="maxActive" value="200"/>

                            <propertyname="poolPreparedStatements" value="true"/>

                   </bean>

2.3    新建数据库

从配置中可以看出数据库的名称是test_mq,需要手动在MySql中新建一个test_mq的空数据库。

此时,重新启动MQ,就会发现test_mq库中多了三张表:activemq_acks,activemq_lock,activemq_msgs,OK,说明已经持久化成功啦!