activemq的数据持久化存储方式默认是kahadb,
数据存储位置在activemq安装目录\data\kahadb里面:
activemq默认提供的是持久化方式是到文件,这在activemq.xml文件中可以看得出来:
<persistenceAdapter> <kahaDB directory="${activemq.base}/data/kahadb"/> </persistenceAdapter>现在我们来看如何使其持久化到mysql,这里使用的activemq是5.13的版本,我们来看。
一、首先需要把下面三个jar包放到activemq的安装目录F:\Program\activemq\apache-activemq-5.8.0\lib里面去:
01.mysql-connector-java-5.1.5-bin.jar
02.commons-pool2-2.4.2.jar
03.commons-dbcp.jar
因为activemq会连接到mysql需要这些jar包,以及连接池。
二、将其中的这段配置:
<persistenceAdapter> <kahaDB directory="${activemq.base}/data/kahadb"/> </persistenceAdapter>修改为下面这段内容:
<persistenceAdapter> <jdbcPersistenceAdapter dataSource="#mysql-ds"/> </persistenceAdapter>
另外需要在broker节点的上面定义id为mysql-ds的bean,如下:
<bean id="mysql-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>
从配置中可以看出数据库的名称是test_mq,需要手动在MySql中新建一个test_mq的空数据库,不需要自己建表的。
此时,重新启动MQ,就会发现test_mq库中多了三张表:activemq_acks,activemq_lock,activemq_msgs,OK,说明已经持久化成功啦!