时间:2021-07-01 10:21:17 帮助过:35人阅读
1.配置activeMQ需要的mySql数据源
为了能够使用JDBC访问mysql数据库,显然必须要配置消息服务器的数据库源。在activemq/apache-activemq-5.8.0/conf/activemq.xml进行配置
在结点之后,增加数据源的配置
2.改变activeMQ默认的持久化方式
在activemq.xml中注释掉默认的kahadb,使用jdbc持久化
3.提供mysql的驱动程序
由于activeMQ消息服务器,没有自带mysql数据库的驱动程序。我们需要手动将mysql驱动添加到消息服务器。
方法是将驱动拷贝到apache-activemq-5.8.0/lib/目录下。
经过上面的三步配置,我们重新启动消息服务器,就可以发现activeMQ在数据库中新建了3张表
activemq_acks ,activemq_lock ,activemq_msgs 。至此数据库持久化完成。后续博客会继续介绍这3张表的含义和使用,目前我还不清楚。