You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
40 lines
1.1 KiB
40 lines
1.1 KiB
import crypto from 'crypto'
|
|
import mqtt from './mqtt'
|
|
|
|
const host = '39.98.253.192'
|
|
const url = `wx://${host}/mqtt`
|
|
|
|
export function getMQTTClient(productId, deviceName, deviceSecret) {
|
|
const clientId = 'iotx_admin_' + Math.random().toString(16).substr(2, 8)
|
|
const content = productId + deviceName + clientId
|
|
const hmac = crypto.createHmac('md5', deviceSecret)
|
|
const up = hmac.update(content)
|
|
const sign = up.digest('hex')
|
|
const options = {
|
|
keepalive: 200,
|
|
clean: true,
|
|
reconnectPeriod: 5000,
|
|
connectTimeout: 5000,
|
|
clientId: clientId,
|
|
username: `${deviceName}&${productId}`,
|
|
password: sign
|
|
}
|
|
const client = mqtt.connect(url, options)
|
|
client.on('error', (e) => {
|
|
console.log(e)
|
|
client.end()
|
|
})
|
|
let reconnectCount = 1
|
|
client.on('reconnect', () => {
|
|
console.log(clientId + ' reconnect ' + reconnectCount + ' times')
|
|
reconnectCount++
|
|
if (reconnectCount > 3) {
|
|
client.end()
|
|
console.log(clientId + ' reconnect failed')
|
|
}
|
|
})
|
|
client.on('close', () => {
|
|
console.log(clientId + ' disconnected')
|
|
})
|
|
return client
|
|
}
|
|
|