mqtt

概述

MQTT是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。本插件通过startmqtt订阅，之后所有服务器过来的消息都在startmqtt的callback里呈现，其他的指令单独返回callback(一般只反馈接口是否调用成功)。所以建议在startmqtt的callback里处理服务器下发的数据.

###备注 不能同时添加的插件：fog2

startmqtt

建立MQTT连接

startmqtt(param, function(ret, err))

params

host：

  • 类型：字符串
  • 默认值：无
  • 描述：host,域名或者IP

port:

  • 类型：字符串
  • 默认值：无
  • 描述：端口，一般是1883

topic：

  • 类型：字符串
  • 默认值：无
  • 描述：监听的主题

username：

  • 类型：字符串
  • 默认值：无
  • 描述：用户名

password：

  • 类型：字符串
  • 默认值：无
  • 描述：用户密码

clientid：

  • 类型：字符串
  • 默认值：无
  • 描述：客户端ID

isencrypt：

  • 类型：boolean
  • 默认值：无
  • 描述：是否SSL加密(默认为false)

callback(ret,err)

ret：

  • 类型：JSON对象

内部字段：

//调用成功
{
  "message": "success",
  "code": 0
}

//连接成功
{
  "status": "connected",
  "code": 4210
}

//收到服务器的数据
{
  "topic": "d64f517c/c8934691813c/out/read",
  "payload": {"9": 3062},
  "code": 4200
}

err：

  • 类型：JSON对象

内部字段：

{
    code : 0,
    message:"Parameter is null"
}

示例代码

var mqtt = api.require('mqtt');
var param = {
    host: "api.easylink.io",
    port: "1883",
    topic: "d64f517c/c8934691813c/out/read/#",
    username: "admin",
    password: "admin",
    clientid: "f60e5d3c-65aa-11e6-9d95-00163e103941",
    isencrypt: false
};
mqtt.startmqtt(param, function(ret, err) {
    if (ret)
        api.alert({msg: JSON.stringify(ret)});
    else
        api.alert({msg: JSON.stringify(err)});
})

可用性

Android系统，iOS系统

可提供的1.0.0及更高版本

stopmqtt

断开MQTT连接

stopmqtt(function(ret, err))

callback(ret,err)

ret：

  • 类型：JSON对象

内部字段：

{
  "status": "stopped",
  "code": 4212
}

err：

  • 类型：JSON对象

内部字段：

{
  "message": "mqtt closed",
  "code": 4204
}

示例代码

mqtt.stopmqtt(function(ret, err) {
    if (ret)
        api.alert({msg: JSON.stringify(ret)});
    else
        api.alert({msg: JSON.stringify(err)});
});

可用性

Android系统，iOS系统

可提供的1.0.0及更高版本

publish

发送指令

publish(param, function(ret, err))

params

topic：

  • 类型：字符串
  • 默认值：无
  • 描述：发送指令的通道

command：

  • 类型：字符串
  • 默认值：无
  • 描述：指令

qos：

  • 类型：数字
  • 默认值：无
  • 描述：建议为0，QoS=0：最多一次，有可能重复或丢失；QoS=1：至少一次，有可能重复；QoS=2：只有一次，确保消息只到达一次（用于比较严格的计费系统）

retained：

  • 类型：boolean
  • 默认值：无
  • 描述：建议为false(设置是否在服务器中保存消息体)

callback(ret,err)

ret：

  • 类型：JSON对象

内部字段：

{
  "status": "publish success",
  "code": 4219
}

err：

  • 类型：JSON对象

内部字段：

{
  "message": "mqtt closed",
  "code": 4204
}

示例代码

var param = {
    topic: "d64f517c/c8934691813c/in/write/0012",
    command: '{"4":false}',
    // qos: 6,
    // retained: false
};
mqtt.publish(param, function(ret, err) {
    if (ret)
        api.alert({msg: JSON.stringify(ret)});
    else
        api.alert({msg: JSON.stringify(err)});
});

可用性

Android系统，iOS系统

可提供的1.0.0及更高版本

subscribe

增加订阅的通道

subscribe(param, function(ret, err))

params

topic：

  • 类型：字符串
  • 默认值：无
  • 描述：发送指令的通道

qos：

  • 类型：数字
  • 默认值：无
  • 描述：建议为0，QoS=0：最多一次，有可能重复或丢失；QoS=1：至少一次，有可能重复；QoS=2：只有一次，确保消息只到达一次（用于比较严格的计费系统）

callback(ret,err)

ret：

  • 类型：JSON对象

内部字段：

{
  "status": "subscribe success",
  "code": 4213
}

err：

  • 类型：JSON对象

内部字段：

{
  "message": "mqtt closed",
  "code": 4204
}

示例代码

var param = {
    topic: "d64f517c/c8934691813c/in/write/#",
    qos: 0,
};
mqtt.subscribe(param, function(ret, err) {
    if (ret)
        api.alert({msg: JSON.stringify(ret)});
    else
        api.alert({msg: JSON.stringify(err)});
});

可用性

Android系统，iOS系统

可提供的1.0.0及更高版本

unsubscribe

移除订阅的通道

unsubscribe(param, function(ret, err))

params

topic：

  • 类型：字符串
  • 默认值：无
  • 描述：发送指令的通道

callback(ret,err)

ret：

  • 类型：JSON对象

内部字段：

{
  "status": "unsubscribe success",
  "code": 4215
}

err：

  • 类型：JSON对象

内部字段：

{
  "message": "mqtt closed",
  "code": 4204
}

示例代码

var param = {
    topic: "d64f517c/c8934691813c/in/write/#"
};
mqtt.unsubscribe(param, function(ret, err) {
    if (ret)
        api.alert({msg: JSON.stringify(ret)});
    else
        api.alert({msg: JSON.stringify(err)});
});

可用性

Android系统，iOS系统

可提供的1.0.0及更高版本

状态码

状态码(code) | 说明(message) | 描述 :----------- | :-------------: 0 | success|请求成功 9001 | Parameter is null|参数为空 || 4201 |invalid param|各种参数错误（tag用来定位具体的参数） 4202 |invalid context | 无效的上下文 4203 |mqtt busy | MQTT正在工作中 4204 |mqtt closed | MQTT已经关闭 4205 |qos must within(0,1,2) |qos必须是0、1、2之一 4206 |exception | 异常 || 4210 |connected | MQTT连接成功 4211 |topic missing | 缺少topic参数 4212 |stopped | MQTT断开连接成功 4213 |subscribe success | 订阅成功 4214 |re-subscribe success | 重订阅成功 4215 |unsubscribe success | 取消订阅成功 4216 |connect exception | 连接异常 4217 |lost | 连接丢失 4218 |disconnected | 未连接 4219 |publish success | 发布成功

是否仍需要帮助？ 请保持联络！
最后更新于 2024/11/18