Paho JavaScript MQTT订阅多主题如何实现类似Python的message_callback_add多回调

架构老林

2026-10-17

问题解答

Paho JavaScript MQTT 客户端没有内置和Python版本message_callback_add对应的原生接口，但可以通过自定义主题回调映射的方式实现完全一致的效果，比写链式if判断更简洁、后续扩展效率更高。

实现思路

定义一个topicCallbacks对象存储「主题-回调函数」的映射关系
统一通过自定义方法完成订阅+回调注册，避免维护两份主题列表
在onMessageArrived中直接根据消息主题匹配对应回调执行即可，不需要硬编码判断逻辑

优化后实现代码

var mqtt;
var reconnectTimeout = 5000;
var host = "localhost";
var port = 8083;
// 新增主题-回调映射表
const topicCallbacks = {};

MQTTconnect();

function MQTTconnect(){
  console.log("mqtt connecting to " + host + ":" + port);
  mqtt = new Paho.MQTT.Client(host, port, "client_test");
  var options = {
    timeout: 100,
    onSuccess: onConnect,
    onFailure: onFailure,
  };
  mqtt.onMessageArrived = onMessageArrived;
  mqtt.connect(options);
}

// 封装自定义订阅方法，同时注册回调
function subscribeTopic(topic, callback) {
  mqtt.subscribe(topic);
  topicCallbacks[topic] = callback;
}

function onConnect(){
  console.log("Mqtt Connected - Subscribe to the topics");
  // 订阅时直接绑定对应回调
  subscribeTopic("topic1/a", (msg) => {
    console.log("Topic1: ", msg.payloadString);
  });
  subscribeTopic("topic2/b", (msg) => {
    console.log("Topic2: ", msg.payloadString);
  });
}
            
function onFailure(message){
  console.log("Connection attempt to MQTT " + host + " failed");
  setTimeout(MQTTconnect, reconnectTimeout);
}

function onMessageArrived(msg){
  const targetTopic = msg.destinationName;
  // 存在对应回调直接执行，不需要硬编码判断
  if (topicCallbacks[targetTopic]) {
    topicCallbacks[targetTopic](msg);
  }
}