Coolpy7技术手册
  • COOLPY7千万级MQTT消息服务器
  • 开始使用
    • Coolpy7消息服务器简介
    • 一分钟运行 Coolpy7
    • 单机千万级连接测试
    • 消息并发压力测试
    • 部署架构
    • 程序安装
    • 分布式集群
    • Docker部署CP7(Win&Linux)
    • 消息通信功能测试
    • DbPoxy代理服务
    • 内核功能扩展
    • 规则引擎
    • 启动参数及内核特殊功能
    • 功能性API接口说明
    • 使用JWT身份验证
    • 消息组播
    • HTTP、CoAP推送消息
    • MQTT-SN代理服务
    • 客户端SDK示例库
    • 常见问题总汇
  • CGP通用IOT物联网控制协议
    • CGP协议
    • CGP协议安全模式
  • OAuth2用户中心应用
    • 用户中心
  • COOLPY7领域应用
    • CP7领域应用指南简略图
    • 使用paho-mqtt.js库实时聊天室
    • 微信小程序实时通信聊天室应用
    • 使用MQTT.js库连接CP7
    • Paho.mqtt.golang客户端连接示例
  • MQTT协议基础知识
    • MQTT协议
    • MQTT-SN 协议
    • MQTT应用指南
Powered by GitBook
On this page

Was this helpful?

  1. COOLPY7领域应用

使用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://raw.githubusercontent.com/Coolpy7/mqttjs_browser_client_demo/master/lib/browserMqtt.js"></script>
</head>
<script>
    // 连接选项
    const options = {
        connectTimeout: 5000, // 超时时间
        keepalive: 60,
        reconnectPeriod:2000,
        // 认证信息
        clientId: 'cp7-clientid-websocket',
        username: 'cp7-username-websocket',
        password: 'cp7-password-websocket',
    }

    const client = mqtt.connect('mqtt://127.0.0.1:8083', options)

    client.on('connect', function () {
        client.subscribe('coolpy/chatroom', 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>
Previous微信小程序实时通信聊天室应用NextPaho.mqtt.golang客户端连接示例

Last updated 4 years ago

Was this helpful?