如何为MQTT Broker接收的所有主题统一添加后缀？

针对Mosquitto Broker的实现方式 #

Mosquitto本身没有原生的后缀添加配置，但可以通过两种方式实现需求：

• 自定义插件扩展：借助mosquitto-auth-plug这类可扩展插件，编写消息处理钩子。当Broker收到XXX/ecg、XXX/hr、XXX/acc这类主题的消息时，自动拼接/YYY后缀，再重新发布到新主题。核心逻辑伪代码如下：

  void on_message_received(char* original_topic, char* payload) {
      char new_topic[256];
      snprintf(new_topic, sizeof(new_topic), "%s/YYY", original_topic);
      // 将消息发布到新主题
      mosquitto_publish(client, NULL, new_topic, strlen(payload), payload, 0, false);
  }
  

• Python脚本转发：写一个简单的中间转发脚本，订阅原主题并重新发布到带后缀的新主题。示例代码：

  import paho.mqtt.client as mqtt
  
  def on_connect(client, userdata, flags, rc):
      # 订阅目标主题
      client.subscribe("XXX/ecg")
      client.subscribe("XXX/hr")
      client.subscribe("XXX/acc")
  
  def on_message(client, userdata, msg):
      # 构造带后缀的新主题
      new_topic = f"{msg.topic}/YYY"
      # 保留原消息的QoS和保留属性，发布到新主题
      client.publish(new_topic, msg.payload, qos=msg.qos, retain=msg.retain)
  
  # 初始化客户端并连接Broker
  client = mqtt.Client()
  client.on_connect = on_connect
  client.on_message = on_message
  client.connect("你的Broker地址", 1883, 60)
  client.loop_forever()
  

针对EMQX Broker的实现方式 #

EMQX的规则引擎可以零代码实现主题修改：

1. 登录EMQX控制台，创建新规则
2. 设置触发条件：选择「消息发布」事件，订阅XXX/ecg、XXX/hr、XXX/acc三个主题
3. 添加动作：选择「重新发布消息」，在主题输入框填写${topic}/YYY
4. 保存规则后，所有匹配原主题的消息都会自动转发到带后缀的新主题

通用兼容方案 #

如果你的Broker不支持插件或规则引擎，最稳妥的方式是搭建一个轻量的转发服务：

• 让服务订阅Broker上的XXX/ecg、XXX/hr、XXX/acc主题
• 收到消息后，把原主题和/YYY拼接成新主题
• 将原消息内容、QoS、保留属性原样发布到新主题上

这种方式不需要修改Broker本身，适配所有MQTT Broker，唯一需要维护这个转发服务的运行。

内容的提问来源于stack exchange，提问作者syed danish Abbas