先上链接
流程：
var mqtt = require('mqtt')
var clientId = 'mqttjs_' + Math.random().toString(16).substr(2, 8)
var host = 'wss://localhost:3001/Mosca'
var options = {
keepalive: 10,
clientId: clientId,
protocolId: 'MQTT',
protocolVersion: 4,
clean: true,
reconnectPeriod: 1000,
connectTimeout: 30 * 1000,
will: {
topic: 'WillMsg',
payload: 'Connection Closed abnormally..!',
qos: 0,
retain: false
},
username: 'demo',
password: 'demo',
rejectUnauthorized: false
}
var client = mqtt.connect(host, options)
client.on('error', function (err) {
console.log(err)
client.end()
})
client.on('connect', function () {
console.log('client connected:' + clientId)
})
client.subscribe('topic', { qos: 0 })
client.publish('topic', 'wss secure connection demo...!', { qos: 0, retain: false })
client.on('message', function (topic, message, packet) {
console.log('Received Message:= ' + message.toString() + '\nOn topic:= ' + topic)
})
client.on('close', function () {
console.log(clientId + ' disconnected')
})
注意事项
客户端的默认端口是 8083 不是 1883
| Protocol | Listen On | Max Clients | Current Clients |
|---|---|---|---|
| mqtt:wss | 8084 | 64 | 0 |
| mqtt:ssl | 8883 | 1024 | 0 |
| mqtt:ws | 8083 | 64 | 0 |
| mqtt:tcp | 0.0.0.0:1883 | 102400 | 0 |
| mqtt:tcp | 127.0.0.1:11883 | 102400 | 0 |
| dashboard:http | 18083 | 512 | 4 |
出现无限连接是因为数据没有发送成功，于是会一直连接，直到连接成功。
| Qos | 说明 |
|---|---|
| 0 | 已发送 |
| 1 | 服务端确认收到 |
| 2 | 都确认收到 |
