NodeJS使用凭据和SSL连接到MQTT服务器

const mqtt = require('mqtt');

// MQTT 服务器配置
const options = {
  port: 8883, // 通常 MQTT over SSL 使用 8883 端口
  host: 'your-mqtt-server.com',
  protocol: 'mqtts', // 使用 mqtts 表示通过 SSL/TLS 连接
  username: 'your-username',
  password: 'your-password',
  rejectUnauthorized: true, // 拒绝未授权的证书
  clientId: 'mqttjs_' + Math.random().toString(16).substr(2, 8),
  clean: true, // 清除会话
};

// 创建客户端连接
const client = mqtt.connect('mqtts://your-mqtt-server.com', options);

client.on('connect', () => {
  console.log('Connected to MQTT server');
  client.subscribe('test/topic', (err) => {
    if (!err) {
      client.publish('test/topic', 'Hello MQTT');
    }
  });
});

client.on('message', (topic, message) => {
  console.log(`Received message on topic ${topic}: ${message.toString()}`);
});

client.on('error', (error) => {
  console.error('Connection error:', error);
});