如何配置Apache Artemis使新订阅者获取历史消息

刚好我之前也遇到过类似的需求，Apache Artemis里的Retroactive Subscriptions就是专门解决这个问题的——让新创建的持久订阅者能直接获取Broker保留的历史消息，而不是只能等待新消息。和ActiveMQ的思路类似，但配置方式有一点区别，我给你详细拆解下：

Artemis的Retroactive订阅机制会在新持久订阅创建时，自动将该地址上留存的持久化历史消息推送给订阅者。你可以通过两种方式配置：

1. 直接在Camel路由的订阅URI中指定参数 #

针对你新增的测试消费者路由，只需要在from的ActiveMQ URI里添加retroactive=true参数即可。修改后的路由配置如下：

<route id="outbox-testing" streamCache="true">
  <from uri="activemq:topic:testing?clientId=my-local-consumer&amp;durableSubscriptionName=my-local-consumer&amp;retroactive=true"/>
  <to uri="file:outbox-local"/>
</route>

这个参数会告诉Artemis Broker：当这个新的持久订阅创建时，把该主题下保留的历史持久化消息推送给它。

2. 在Broker层面全局或针对特定地址配置 #

如果你希望所有主题或者特定主题默认支持Retroactive订阅，可以修改Artemis的broker.xml配置文件，在address-settings节点中添加对应规则：

全局配置（所有地址生效） #

<address-settings>
  <address-setting match="#">
    <!-- 配置保留给新订阅者的历史消息数量，按需调整 -->
    <retroactive-message-count>10</retroactive-message-count>
    <!-- 开启Retroactive订阅支持 -->
    <retroactive>true</retroactive>
  </address-setting>
</address-settings>

针对单个主题配置（比如你的testing主题） #

<address-settings>
  <address-setting match="testing">
    <retroactive-message-count>5</retroactive-message-count>
    <retroactive>true</retroactive>
  </address-setting>
</address-settings>

• 消息必须是持久化的：Retroactive订阅只能回溯持久化消息，如果你的消息是非持久化的，Broker不会保存历史记录，自然无法回溯。默认情况下Camel的ActiveMQ组件发送的消息是持久化的，如果你有修改过消息模式需要确认。
• 历史消息留存数量：retroactive-message-count控制了Broker会给新订阅者推送多少条历史消息，根据你的测试需求调整即可（比如你说的“最近几条”，设为3-5都可以）。

1. 确保Broker已经配置好Retroactive（不管是URI参数还是broker.xml配置）
2. 启动你的测试消费者路由
3. 检查outbox-local目录，应该能看到之前发送到testing主题的历史文件，而不需要等待新消息生成

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