温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Apache ActiveMQ 的消息持久化到MySQL数据库详细步骤

发布时间:2020-05-09 15:16:32 来源:亿速云 阅读:250 作者:三月 栏目:数据库

下文主要给大家带来Apache ActiveMQ 的消息持久化到MySQL数据库详细步骤,希望Apache ActiveMQ 的消息持久化到MySQL数据库详细步骤能够带给大家实际用处,这也是我编辑这篇文章的主要目的。好了,废话不多说,大家直接看下文吧。

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>

 Apache ActiveMQ 的消息持久化到MySQL数据库详细步骤

在</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    新建数据库

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

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

对于以上关于Apache ActiveMQ 的消息持久化到MySQL数据库详细步骤,大家是不是觉得非常有帮助。如果需要了解更多内容,请继续关注我们的行业资讯,相信你会喜欢上这些内容的。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI