使用MQTT.js库连接CP7

Search…

使用MQTT.js库连接CP7

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

以下示例代码已CP7官方测试支持自动重连，并且稳定性测试。建议使用浏览器领域或小程序开发方向优先使用此库。
使用此例示例代码前请先运行CP7 Core和CP7 WS代理服务，并使用WS代理服务所在IP和端口进行连接测试。
1
<!DOCTYPE html>
2
<html lang="en">
3
<head>
4
    <meta charset="UTF-8">
5
    <title>Coolpy7 mqttjs client demo</title>
6
    <script src="https://raw.githubusercontent.com/Coolpy7/mqttjs_browser_client_demo/master/lib/browserMqtt.js"></script>
7
</head>
8
<script>
9
    // 连接选项
10
    const options = {
11
        connectTimeout: 5000, // 超时时间
12
        keepalive: 60,
13
        reconnectPeriod:2000,
14
        // 认证信息
15
        clientId: 'cp7-clientid-websocket',
16
        username: 'cp7-username-websocket',
17
        password: 'cp7-password-websocket',
18
    }
19
​
20
    const client = mqtt.connect('mqtt://127.0.0.1:8083', options)
21
​
22
    client.on('connect', function () {
23
        client.subscribe('coolpy/chatroom', function (err) {
24
            if (!err) {
25
                //client.publish('presence', 'Hello mqtt')
26
                console.log("sub ok")
27
            }
28
        })
29
    })
30
​
31
    client.on('reconnect', (error) => {
32
        console.log('正在重连:', error)
33
    })
34
​
35
    client.on('error', (error) => {
36
        console.log('连接失败:', error)
37
    })
38
​
39
    client.on('message', function (topic, message) {
40
        // message is Buffer
41
        console.log(message.toString())
42
    })
43
</script>
44
<body>
45
​
46
</body>
47
</html>
Copied!

COOLPY7领域应用 - Previous

微信小程序实时通信聊天室应用

Next - COOLPY7领域应用

Paho.mqtt.golang客户端连接示例

Last modified 9mo ago

Copy link