欢迎来到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)连接示例