ActiveMQ默认使用的持久性机制是KahaDB,这货不熟悉,所以这篇文章来介绍一下将队列中的消息存放在mysql数据库里

修改配置

找到 conf 文件夹,打开 activemq.xml 文件,找到下面配置

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

可以看到,ActiveMQ默认使用的是 kahadb ,把这一行注释掉,加上MySQL的配置(mysql-datasource的bean要配置在broker标签外面),如下

<broker> <!-- ... --> <persistenceAdapter> <!-- <kahaDB directory="${activemq.data}/kahadb"/> --> <jdbcPersistenceAdapter dataSource="#mysql-datasource"/> </persistenceAdapter> <!-- ... --> </broker> <bean id="mysql-datasource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/test?relaxAutoCommit=true"/> <property name="username" value="root"/> <property name="password" value=""/> <property name="maxActive" value="200"/> <property name="poolPreparedStatements" value="true"/> </bean> 注意上面数据库连接中的用户名密码要根据自己的mysql服务来进行修改,我这里用是test库 ActiveMQ添加MySQL驱动

将mysql-connector-java、commons-dbcp、commons-pool三个jar包拷贝到 ActiveMQ 文件夹下的 lib 文件夹内


ActiveMQ学习-持久化队列数据,将队列中的消息存入MySQL (3)

然后再次重启ActiveMQ,如果没有报错,一般就没问题了

打开 mysql 数据库客户端 找到 test 库,会发现多了三张表


ActiveMQ学习-持久化队列数据,将队列中的消息存入MySQL (3)
测试

运行HelloWorld里的 Producer 创建100条消息

打开表 ACTIVEMQ_MSGS 可以看到已经有100条数据了


ActiveMQ学习-持久化队列数据,将队列中的消息存入MySQL (3)

再次运行 Consumer 消费这100条消息,然后再打开表 ACTIVEMQ_MSGS 则没有数据了

原文链接:

本文数据库(mysql)相关术语:navicat for mysql mysql workbench mysql数据库 mysql 存储过程 mysql安装图解 mysql教程 mysql 管理工具

代码区博客精选文章
分页:12
转载请注明
本文标题:ActiveMQ学习-持久化队列数据,将队列中的消息存入MySQL (3)
本站链接:https://www.codesec.net/view/611137.html


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 数据库(mysql) | 评论(0) | 阅读(95)