ActiveMQ Classic 5.18.3故障转移模式下SQL Server主键冲突原因及解决

产生原因 #

• 主从切换期间的消息重复持久化：S564失去主节点排他锁后，并未立即终止已有的inflight消息处理，而是进入超时等待流程。此时新主节点S563已接管服务，会重新处理这些未完成的消息并写入ACTIVEMQ_MSGS表。当S564最终完成消息处理并尝试持久化时，就会因相同主键已存在触发冲突。
• 锁与消息处理的超时窗口不匹配：ActiveMQ的锁心跳周期与inflight消息等待超时时间配置不协调，导致旧主节点在锁释放后仍有足够时间尝试写入已被新主节点处理过的消息。
• 主键策略配置不当：若ACTIVEMQ_MSGS表使用SQL Server自增主键而非ActiveMQ生成的全局唯一消息ID（MSG_ID），主从节点处理同一条消息时可能生成重复的自增ID，引发主键冲突。

解决方法 #

• 调整超时参数，缩短旧主节点处理窗口：
  • 修改activemq.xml中的lockKeepAlivePeriod（锁心跳周期）和shutdownTimeout（节点关闭超时），让旧主节点在失去锁后更快终止inflight消息处理，避免延迟写入。
  • 配置inFlightRepository的超时时间，缩短旧主节点等待inflight消息完成的时长，确保在新主节点处理完相同消息前，旧主节点已停止写入操作。
• 恢复默认主键策略，保证消息ID全局唯一：
  • 确认ACTIVEMQ_MSGS表使用ActiveMQ生成的MSG_ID（默认是全局唯一字符串）作为主键，而非数据库自增ID。如果之前修改过表结构，恢复默认配置，利用ActiveMQ的消息ID生成机制从根源避免重复主键。
• 优化主从消息同步逻辑：
  • 启用ActiveMQ共享存储模式下的消息同步机制，配置replicationTimeout等参数，确保新主节点在接管前同步旧主节点的未完成消息状态，避免重复处理。
• 清理冲突数据，修复表一致性：
  • 对于已出现的冲突，可手动删除ACTIVEMQ_MSGS表中的重复记录（需确认消息已被正确消费），同时检查ACTIVEMQ_ACKS等关联表的一致性，防止后续消息处理异常。

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