背景:
为了防止当activemq宕机之后,数据不丢失的情况,可以把数据存到mysql数据库进行持久化操作,这样就可以保证当activemq重启之后,数据可以继续被消费者消费。
第一步:加入相关jar包
1、首先下载mysql驱动mysql-connector-java,我这里选择的版本是mysql-connector-java-8.0.18版本,如下所示:
2、将下载完成的jar包,放到activemq的lib目录下,如下所示:
第二步:修改配置文件
1、修改conf文件夹下的activemq.xml文件
2、找到<persistenceAdapter>标签,注释掉默认的kahaDB配置,加入mysql的配置如下:
3、在文件最下面添加mysql具体配置:这里注意一下数据库连接中的参数&需要使用转义字符:&
4、在mysql数据库中创建数据库activemq
第三步:启动activemq服务
1、进入到文件夹下启动服务
2、查看数据库中是否生成了activemq_acks、activemq_lock、activemq_msgs这三张表
3、到此,关于activemq客户端的配置基本结束,接下来是进行代码配置和测试