使用MQTT.js库连接CP7

一个优秀的MQTT客户端库,支持小程序和H5等相关应用方向,功能相 当完备,支持qos0,1,2。开源地址https://github.com/mqttjs/MQTT.js

以下示例代码已CP7官方测试支持自动重连,并且稳定性测试。建议使用浏览器领域或小程序开发方向优先使用此库。

使用此例示例代码前请先运行CP7 Core和CP7 WS代理服务,并使用WS代理服务所在IP和端口进行连接测试。

<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Coolpy7 mqttjs client demo</title>
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
</head>
<script>
// 连接选项
const options = {
connectTimeout: 5000, // 超时时间
keepalive: 0,
reconnectPeriod:2000,
// 认证信息
clientId: 'cp7-connect-via-websocket',
username: 'cp7-connect-via-websocket',
password: 'cp7-connect-via-websocket',
}
const client = mqtt.connect('ws://localhost:8083/', options)
client.on('connect', function () {
client.subscribe('presence', function (err) {
if (!err) {
//client.publish('presence', 'Hello mqtt')
console.log("sub ok")
}
})
})
client.on('reconnect', (error) => {
console.log('正在重连:', error)
})
client.on('error', (error) => {
console.log('连接失败:', error)
})
client.on('message', function (topic, message) {
// message is Buffer
console.log(message.toString())
})
</script>
<body>
</body>
</html>