|
|
@@ -0,0 +1,46 @@
|
|
|
+const clientId = 'mqttjs_' + Math.random().toString(16).substr(2, 8)
|
|
|
+
|
|
|
+const host = 'wss://emqx.site0.cn/mqtt'
|
|
|
+
|
|
|
+const options = {
|
|
|
+ keepalive: 30,
|
|
|
+ clientId: clientId,
|
|
|
+ protocolId: 'MQTT',
|
|
|
+ protocolVersion: 4,
|
|
|
+ clean: true,
|
|
|
+ reconnectPeriod: 5000,
|
|
|
+ connectTimeout: 30 * 1000,
|
|
|
+ will: {
|
|
|
+ topic: 'WillMsg',
|
|
|
+ payload: 'Connection Closed abnormally..!',
|
|
|
+ qos: 0,
|
|
|
+ retain: false
|
|
|
+ },
|
|
|
+ rejectUnauthorized: false
|
|
|
+}
|
|
|
+
|
|
|
+console.log('connecting mqtt client')
|
|
|
+const client = mqtt.connect(host, options)
|
|
|
+
|
|
|
+client.on('error', (err) => {
|
|
|
+ console.log('Connection error: ', err)
|
|
|
+ client.end()
|
|
|
+})
|
|
|
+
|
|
|
+client.on('reconnect', () => {
|
|
|
+ console.log('Reconnecting...')
|
|
|
+})
|
|
|
+
|
|
|
+client.on('connect', () => {
|
|
|
+ console.log('Client connected:' + clientId)
|
|
|
+ client.subscribe('/sys/luatos/emulator/test/up', { qos: 0 })
|
|
|
+ client.publish('/sys/luatos/emulator/test/up', 'ws connection demo...!', { qos: 0, retain: false })
|
|
|
+})
|
|
|
+
|
|
|
+client.on('message', (topic, message, packet) => {
|
|
|
+ console.log('Received Message: ' + message.toString() + '\nOn topic: ' + topic)
|
|
|
+})
|
|
|
+
|
|
|
+client.on('close', () => {
|
|
|
+ console.log(clientId + ' disconnected')
|
|
|
+})
|
Wendal Chen