springboot集成activemq持久化mysql

2023-11-20

背景：

activemq的数据默认是持久化在data文件夹下的kahadb的文件夹下，我们修改下它的存储路径，将数据存储到mysql数据库里面。

第一步：加入相关jar包

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

2、将下载完成的jar包，放到activemq的lib目录下，如下所示：

第二步：修改配置文件

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

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

<persistenceAdapter>
    <!--<kahaDB directory="${activemq.data}/kahadb"/>-->
    <jdbcPersistenceAdapter dataSource="#mysql-mq" createTablesOnStartup="true" />
</persistenceAdapter>

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

<bean id="mysql-mq" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
	<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    
        <!--如果是mysql5.7版本就写这个jdbc路径的url路径-->
        <property name="url" value="jdbc:mysql://127.0.0.1:3306/activemq?characterEncoding=utf-8&amp;serverTimezone=Asia/Shanghai" />
        <!--如果是mysql8.0的版本就写这个jdbc的url路径-->
	<property name="url" value="jdbc:mysql://127.0.0.1:3306/activemq?useSSL=false&amp;serverTimezone=UTC" />
	<property name="username" value="root"/>
	<property name="password" value="Rfid123456"/>
	<property name="initialSize" value="5"/>
	<property name="maxTotal" value="100"/>
	<property name="maxIdle" value="30"/>
	<property name="maxWaitMillis" value="10000"/>
	<property name="minIdle" value="1"/>
</bean>

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

第三步：启动activemq服务

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

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

activemq_msgs：消息表，queue和topic都存储在里面

ID：自增主键；

CONTAINER：所属类型以及所在队列或者主题；

MSGID_PROD：生产者ID；

MSGID_SEQ：在同一批次消息中的序号；

EXPIRATION：过期时间（0表示永不过期）；

MSG：序列化之后的消息；

PRIORITY：优先级；

XID：这个不知道。

activemq_acks：存储持久订阅的信息和最后一个持久订阅接收的消息ID

CONTAINER：与上面消息表的CONTAINER一样；

SUB_DEST：子目的地，与CONTAINER一样；

CLIENT_ID：链接的客户端ID，也就是我们程序:connection.setClientID("cc1"); 产生的ID

SUB_NAME：持久订阅者的名称.也就是我们程序: session.createDurableSubscriber(destination, "C11"); 产生的名称

SELECTOR：消息选择器,consumer可以选择自己想要的

LAST_ACKED_ID：最后一次确认ID,这个字段存的该该订阅者最后一次收到的消息的ID

XID：这个不知道。

activemq_lock：锁定表，用来确保在某一时刻，只能有一个ActiveMQ broker实例来访问数据库

XID：自增的主键

TIME：日期

BROKER_NAME：占用数据库的brokerName

3、如果安装过程中出现任何问题，都可以在下面这个位置查看错误的日志信息

4、此时，我们启动生产者，但是不启动消费者，我们发现未消费的数据都存在了以下的位置

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

spring boot

ActiveMQ