如何将ActiveMQ Classic中的定时消息迁移至Artemis？

方法一：使用Artemis官方迁移工具 #

ActiveMQ Artemis提供了专门的迁移命令，能识别并迁移KahaDB中存储的定时消息（区别于仅处理当前队列消息的KahaDB Export Tool），步骤如下：

• 停止ActiveMQ Classic broker，确保数据一致性
• 执行Artemis迁移命令，指定Classic的KahaDB路径和Artemis的绑定数据路径：

  ./artemis migrate --source-kahadb /path/to/activemq-classic/data/kahadb --target-bindings /path/to/artemis/data/bindings
  

• 启动Artemis broker，检查定时消息是否被正确导入到对应队列的定时存储中

方法二：自定义脚本导出导入 #

如果官方工具不符合需求，可以基于ActiveMQ和Artemis的API编写脚本手动处理定时消息：

• 用ActiveMQ的KahaDBStore类加载目标KahaDB存储，通过scheduledMessageStore遍历所有未投递的定时消息
• 提取消息的内容、目标队列、定时投递时间等核心信息
• 使用Artemis的Core API或JMS客户端，将消息发送到Artemis并设置对应的定时投递参数（比如调用Message.setScheduledDeliveryTime()设置投递时间，或设置_AMQ_SCHED_DELIVERY属性）

方法三：双写过渡（无停机场景） #

如果无法停服迁移，可采用双写方案：

• 修改应用代码，同时向ActiveMQ Classic和Artemis发送定时消息
• 等待Classic中所有存量定时消息全部投递完成后，切换应用到仅向Artemis发送消息
• 最后停用Classic broker

注意事项 #

• 迁移前务必完整备份KahaDB数据，避免数据丢失
• 先在测试环境验证迁移结果，确认定时消息的投递时间、内容与原环境一致
• 注意Classic与Artemis的定时属性映射：Classic的AMQ_SCHEDULED_DELAY对应Artemis的_AMQ_SCHED_DELIVERY，或直接使用Core API的定时方法设置更准确

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