MQTT.js subscribe()函数的回调未捕获错误消息

const mqtt = require('mqtt');

const client = mqtt.connect('mqtt://broker.example.com'); // 这里填写MQTT代理服务器的地址

client.on('connect', () => {
  console.log('Connected to MQTT broker');

  // 订阅主题
  client.subscribe('topic', (err) => {
    if (err) {
      console.error('Failed to subscribe:', err);
      return;
    }
    console.log('Subscribed to topic');
  });
});

// 消息到达时的回调函数
client.on('message', (topic, message) => {
  try {
    // 处理消息
    console.log('Received message:', message.toString());
  } catch (error) {
    console.error('Error processing message:', error);
    // 进行错误处理，例如记录日志或发送警报
  }
});