activemq的数据存储方式与存储位置以及如何修改使之存储到mysql

    技术2022-07-10  89

    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,说明已经持久化成功啦!

     

    Processed: 0.023, SQL: 9