如何让独立ActiveMQ实例通过TCP使用JDBC持久化而非嵌入式VM

问题根源 #

你当前的Spring代码中创建了BrokerService Bean，这会在你的应用内部启动一个嵌入式ActiveMQ Broker。当使用vm:localhost连接时，实际连的是这个内嵌Broker，它的JDBC配置自然生效；而你部署的独立ActiveMQ镜像是完全独立的进程，用tcp://0.0.0.0:61616连接时，访问的是这个独立Broker，它的默认配置还是KahaDB，所以不会用到你Spring里的JDBC配置。

1. 删除Spring中的BrokerService Bean #

既然要使用独立部署的ActiveMQ实例，完全不需要在Spring应用内部启动Broker，直接删掉这个Bean即可，避免混淆。

2. 配置独立ActiveMQ实例的JDBC持久化 #

独立ActiveMQ的持久化策略由它自身的配置文件决定，需要修改activemq.xml替换默认的KahaDB配置：

替换默认的KahaDB配置 #

找到配置文件中默认的持久化适配器段：

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

替换为JDBC持久化配置：

<persistenceAdapter>
    <jdbcPersistenceAdapter dataSource="#mysql-ds" useLock="true">
        <statements binaryDataType="BINARY"/>
    </jdbcPersistenceAdapter>
</persistenceAdapter>

添加数据源配置 #

在broker标签外（比如beans根标签内）添加数据库数据源配置（以MySQL为例）：

<bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://你的数据库地址:3306/activemq?relaxAutoCommit=true"/>
    <property name="username" value="数据库用户名"/>
    <property name="password" value="数据库密码"/>
    <property name="maxTotal" value="20"/>
    <property name="poolPreparedStatements" value="true"/>
</bean>

注意：如果用Docker部署ActiveMQ，需要确保容器内的lib目录有对应数据库驱动（如mysql-connector-java.jar）和dbcp2依赖包，可以通过挂载本地jar目录或自定义镜像实现。

3. 确认Spring连接工厂配置 #

你的ActiveMQConnectionFactory Bean只需保证brokerUrl指向独立ActiveMQ的实际TCP地址即可（比如tcp://你的ActiveMQ主机IP:61616，不要用0.0.0.0，这是Broker的监听地址，客户端需用实际可访问的IP/主机名），当前代码逻辑无需修改。

验证步骤 #

1. 重启独立ActiveMQ实例，确保配置生效
2. 启动Spring应用发送消息，检查数据库中是否生成ACTIVEMQ_MSGS、ACTIVEMQ_ACKS等表，且消息数据存入这些表中，而非KahaDB的文件目录。

内容的提问来源于stack exchange，提问作者rJqnr