springboot集成activemq持久化mysql

背景:

       为了防止当activemq宕机之后,数据不丢失的情况,可以把数据存到mysql数据库进行持久化操作,这样就可以保证当activemq重启之后,数据可以继续被消费者消费。

第一步:加入相关jar包

       1、首先下载mysql驱动mysql-connector-java,我这里选择的版本是mysql-connector-java-8.0.18版本,如下所示:

springboot集成activemq持久化mysql

       2、将下载完成的jar包,放到activemqlib目录下,如下所示:

springboot集成activemq持久化mysql

第二步:修改配置文件 

        1、修改conf文件夹下的activemq.xml文件

springboot集成activemq持久化mysql

       2、找到<persistenceAdapter>标签,注释掉默认的kahaDB配置,加入mysql的配置如下: 

springboot集成activemq持久化mysql

       3、在文件最下面添加mysql具体配置:这里注意一下数据库连接中的参数&需要使用转义字符:&amp; 

springboot集成activemq持久化mysql

       4、在mysql数据库中创建数据库activemq

springboot集成activemq持久化mysql

第三步:启动activemq服务

       1、进入到文件夹下启动服务

springboot集成activemq持久化mysql

       2、查看数据库中是否生成了activemq_acks、activemq_lock、activemq_msgs这三张表

springboot集成activemq持久化mysql

       3、到此,关于activemq客户端的配置基本结束,接下来是进行代码配置和测试