ActiveMQ Classic非持久化主从故障转移配置实现问题咨询

问题根源很明确：当你给broker设置persistent="false"时，ActiveMQ会强制切换到MemoryPersistenceAdapter，直接忽略你配置的KahaDB适配器——这就导致共享文件锁机制完全失效，两台broker都会认为自己是主节点，出现双活情况。

要实现带冗余故障转移的非持久化broker，不需要关闭broker的持久化开关，而是换个层面控制消息不落地，同时保留KahaDB的锁机制来实现主从选举：

步骤1：恢复KahaDB主从配置 #

移除broker标签中的persistent="false"属性，保留原有的KahaDB共享文件锁配置，确保两台broker能通过共享存储竞争主节点锁。

步骤2：全局设置消息非持久化 #

在broker配置中添加destinationPolicy，全局强制所有队列和主题的消息为非持久化模式，这样消息只会存在内存中，不会写入磁盘：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
...
   <persistenceAdapter>
      <kahaDB directory="/mnt/SHARED_AMQ" lockKeepAlivePeriod="1000">
         <locker>
            <shared-file-locker lockAcquireSleepInterval="1000"/>
         </locker>
      </kahaDB>
   </persistenceAdapter>

   <!-- 全局配置所有消息非持久化 -->
   <destinationPolicy>
      <policyMap>
         <policyEntries>
            <policyEntry queue="*" persistent="false"/>
            <policyEntry topic="*" persistent="false"/>
         </policyEntries>
      </policyMap>
   </destinationPolicy>
...
</broker>

可选：按需配置持久化规则 #

如果部分业务需要持久化消息，也可以单独针对特定队列/主题配置持久化，比如：

<policyEntries>
   <policyEntry queue="*" persistent="false"/>
   <policyEntry queue="CRITICAL_QUEUE" persistent="true"/> <!-- 特定队列保留持久化 -->
   <policyEntry topic="*" persistent="false"/>
</policyEntries>

另一种思路：微服务端控制持久化 #

也可以不在broker层面配置，而是让所有微服务的连接工厂设置deliveryMode=NON_PERSISTENT，确保发送的所有消息都标记为非持久化。这种方式更灵活，适合不同服务有不同需求的场景。

通过以上配置，既能保留KahaDB的主从锁机制实现故障转移（一台宕机后另一台自动获取锁成为主节点），又能保证消息不落地磁盘，完全满足你的维护需求。

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