如何用ActiveMQ Artemis将单条MQTT消息克隆至多主题？

一、你的需求完全可以实现 #

ActiveMQ Artemis原生支持消息克隆转发+离线消息持久化，完全匹配你的场景：

1. 消息克隆到多主题 #

用Artemis的地址转发就能搞定消息从mydata/PC到mydata/PC/1、mydata/PC/2的复制：

• 直接在broker.xml里给mydata/PC地址配置两条转发规则，分别指向两个子主题。每收到一条原主题的消息，Artemis会自动生成两份副本，分别投递到两个目标主题，不需要额外写代码。
• 如果需要加过滤逻辑，也可以用核心桥接配置，灵活性更高。

2. 离线消息保留 #

针对PC离线的情况，只要给两个子主题配置MQTT持久化订阅就行：

• Telegraf的MQTT插件支持配置clean_session = false，再给每个PC的Telegraf设置唯一的client_id，这样Artemis会识别这是持久化订阅。
• 在Artemis的broker.xml里给mydata/PC/1、mydata/PC/2这两个地址开启持久化（persist-messages=true），调整好消息过期策略（比如设为永久保留直到消费）。这样PC离线时，消息会存在Artemis的持久化存储里，等PC上线后自动投递。

二、关于“消息需被读取n次后清除”的说明 #

你提到的类似JMS多订阅者确认后删除的逻辑，在这个MQTT场景下其实不需要额外设置“读取n次清除”：

• 每个持久化订阅都是独立的，Artemis会给每个订阅者单独维护消息队列。PC1消费了mydata/PC/1的消息，只会删掉这个订阅对应的副本，PC2的mydata/PC/2的消息副本会一直保留，直到PC2上线消费。
• 如果真要实现“原消息必须被n个订阅者消费后才彻底删除”，可以用Artemis的自定义拦截器统计消费次数，但对你的需求来说完全没必要，前面的转发+持久化订阅已经能解决问题。

三、Telegraf配置要点 #

Telegraf的MQTT消费者插件直接支持持久化订阅，给你个配置示例：

# PC1的Telegraf配置
[[inputs.mqtt_consumer]]
  servers = ["tcp://你的Artemis地址:1883"]
  topics = ["mydata/PC/1"]
  client_id = "telegraf-pc-001" # 每个PC用唯一ID，不能重复
  clean_session = false
  qos = 1 # 至少一次交付，避免消息丢失

PC2的配置只要把topics改成mydata/PC/2，client_id改成唯一值就行。

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