阿琨个人网

欢迎来到Kun的个人空间

EMQX物联网平台开放端口443 & 1883

记录内容如下链接
https://rayking.fun/api/hao
https://rayking.fun/api/long


MQTT接入手册



1、 MQTT连接配置
域名:   rayking.fun 
端口:   1883, 8083,443 
三元组 (暂无校验。客户端id不可重复) 
clientId:   {myname}_{device_name} 
username:   {myname}_{device_name}
password:    xxx
主题 (暂无校验。) 
订阅主题名称和发送主题名称相同,可直接进行消息流转 
            

2、 4G模块(AT固件)连接示例 
示例模块: DX-CT511N    
(仅供参考,具体配置以模块手册为准) 
//配置APN 
AT+QICSGP=1,1,"cmnbiot","","" 
//开启移动网络 
AT+NETOPEN 
//配置连接信息:clientId 、username 、password 
AT+MCONFIG="RayKing_4G_1","RayKing_4G_1","123456" 
//配置服务器信息:域名/公网IP 、端口号 
AT+MIPSTART="8.138.253.50",1883,4 
//连接MQTT服务器 
AT+MCONNECT=1,60 
//订阅主题 
AT+MSUB="RayKing_topic_1",0 
//发布主题 
AT+MPUB="RayKing_topic_1",0,0,"send_data"
            

3、微信小程序连接示例
let mqtt = require("../../utils/mqtt.min.js") 
let client = null 
 
Page({ 
    data: { 
 
    }, 
    onLoad(){ 
        this.mqtt_connect() 
    }, 
    mqtt_connect(){ 
        const that = this 
        const options = { 
            clientId: "WeChat_miniprogram_1",       //客户端ID  
            username: "WeChat_miniprogram_1",       //设备名称 
            password: "123456",                     //密码 
            connectTimeout: 4000,                   //超时时间(ms) 
            createWebsocket: (url, protocols) => wx.connectSocket({ url, protocols }) 
        } 
        //连接源创物联网MQTT服务 
        client = mqtt.connect("wxs://rayking.fun:443/mqtt", options)   
        client.on("connect",(res)=>{ 
            console.log("MQTT连接成功") 
            client.subscribe("Topic_path_1",{qos:0},function(err){ 
                if(!err){ 
                    console.log("成功订阅主题:Topic_path_1") 
                    that.mqtt_send('Topic_path_1','test')           //测试发布主题
                } 
            }) 
        }) 
        //监听订阅信息 
        client.on("message",function(topic,message){ 
            console.log("接受到订阅主题信息:\n"+topic+" : "+message.toString()) 
        }) 
        //重新连接 
        client.on("reconnect",(err)=>{ 
            console.log('正在重新连接',err) 
        }) 
        //连接失败 
        client.on("error",(err)=>{ 
            console.log("连接失败",err) 
        }) 
    }, 
    //发布主题信息 
    mqtt_send(send_topic,send_data){ 
        client.publish(send_topic,send_data,function(err){ 
            if(!err){ 
                console.log("成功发送主题信息:\n"+send_topic+" : "+send_data) 
            } 
        }) 
    } 
})
            

4、前端(JavaScript)连接示例
            

5、后台(Python)连接示例