node.js mqtt樣例

const mqtt = require('mqtt')
//import mqtt from 'mqtt'

// 連接選項
const options = {
          clean: true, // 保留回話
      connectTimeout: 4000, // 超時時間
      // 認證信息
      clientId: 'emqx_test',
      username: 'XXX', //必須在mqtt關閉匿名才會起作用
      password: 'XXX',
}

// 連接字符串, 通過協議指定使用的連接方式
// ws 未加密 WebSocket 連接
// wss 加密 WebSocket 連接
// mqtt 未加密 TCP 連接
// mqtts 加密 TCP 連接
// wxs 微信小程序連接
// alis 支付寶小程序連接
//const connectUrl = 'wss://broker.emqx.io:8084/mqtt'
const connectUrl = 'mqtt://XX.XX.XXX.XXX:1883/mqtt'
const client = mqtt.connect(connectUrl, options)
client.subscribe('qi',{qos:1});//訂閱主題為test的消息  
client.publish("qi","nodejs");
client.on('reconnect', (error) => {
    console.log('正在重連:', error)
})

client.on('error', (error) => {
    console.log('連接失敗:', error)
})

client.on('message', (topic, message) => {
  console.log('收到消息：', topic, message.toString())
})