ActiveMQ Artemis跨集群地址联邦双向配置致消息重复问题咨询

你配置的双向upstream联邦是导致消息重复的直接原因：

• 欧洲集群生产的消息会被转发到美国集群的所有节点
• 美国集群的upstream又会把这条已经联邦过来的消息再次回传给欧洲集群
• 即使max-hops=1阻止了无限循环，美国的消费者还是会收到重复消息：一次是欧洲直接转发来的，一次是美国回传后再分发的。再加上每个upstream配置了对方3个节点，单条消息会被多次转发，最终出现每次重复2条的情况。

要保留两地互通能力同时消除重复，只需要在两边的地址策略里添加exclude-federated="true"，这个参数会阻止已经通过联邦过来的消息再次被转发，从根源上切断循环。

欧洲集群所有节点的配置修改 #

更新<address-policy>节点：

<address-policy name="events-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" exclude-federated="true">
    <include address-match="events.#" />
</address-policy>

美国集群所有节点的配置修改 #

同样更新<address-policy>节点：

<address-policy name="events-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" exclude-federated="true">
    <include address-match="events.#" />
</address-policy>

可选优化：减少upstream目标节点 #

你现在每个upstream都配置了对方3个节点，会导致单条消息被多次转发到对方集群的不同节点，建议改为只连接对方集群的集群连接器（如果已经配置了集群连接），或者选择1-2个核心节点作为转发目标，进一步降低重复风险：

<!-- 示例：美国集群配置欧洲集群的统一连接器 -->
<connector name="europe-cluster">tcp://dev-broker-europe-cluster.example.com:61616?sslEnabled=true</connector>

<!-- 替换原有的3个节点连接器 -->
<static-connectors>
    <connector-ref>europe-cluster</connector-ref>
</static-connectors>

• 迁移初期：保持双向联邦+exclude-federated=true，确保两地生产者的消息能同步到两地消费者，不影响业务
• 迁移中期：当欧洲的生产者逐步切换到美国集群后，移除欧洲→美国的upstream配置
• 迁移后期：当欧洲的消费者全部迁移完成后，移除美国→欧洲的upstream配置，完成整个迁移流程

1. 重启两地所有集群节点，让配置生效
2. 在欧洲生产1条测试消息，检查美国的消费者是否只收到1条
3. 分别在两地生产消息，验证对方集群的消费者能正常接收，且无重复

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