如何下载
百度网盘链接:https://pan.baidu.com/s/1AixcifzQbiruDDEoesE5UQ
提取码:txtr
项目地址 MqttEmu: 物联网设备模拟器
界面
主界面大致分为功能区、链接区、桌面区三个部分。功能区为常用功能命令,例如:创建设备。链接区提供github及帮助链接。桌面区用于操作当前放入桌面设备。设备只有放入桌面才可以连接到物联网。
快速入门
本部分将会通过使用MqttEmu创建一个极简的物联网设备带你了解如何使用MqttEmu模拟物联网设备。
本部分使用阿里云作为物联网服务器,您需要首先使用阿里云物联网创建一个产品,并新建一个设备。
1. 创建虚拟设备
在阿里云创建完物联网设备后,回到我们的应用,点击主界面功能区的新设备打开设备创建窗口。
名称填写为您设备的名称,这里填写为test1,模式选择标准,生成器选择阿里云,ProductKey、DeviceName、DeviceSecret可以在您创建的阿里云物联网产品设备上找到,将这些信息填入对应区域。其他选项如下图所选,然后点击填充按钮,连接阿里云所需要的相关参数会自动进行填充。
其他暂时不需要填写,点击提交按钮,添加这个设备。
2. 将设备添加至桌面区
在主界面功能区点击设备列表,将打开设备列表面板,这里您将看到您刚刚创建的设备。
设备下面的三个功能按钮为 1:添加至桌面 2:编辑设备 3:删除设备
我们点击第一个按钮,将设备添加桌面区,然后关闭设备列表面板。
3. 设备上线
将设备添加至桌面后,会出现如图所示界面,1位置为设备功能区,2位置为上报订阅区,3位置为日志区
点击设备功能区的第一个连接按钮,设备即可上线。
4. 查看日志
日志区域分为左右两个部分,左侧为日志动作及日志时间,右侧为日志内容。
5. 编辑发布消息
点击上图所示1位置按钮,添加新的发布,此时会打开新发布面板。
在名称处填写您的发布名称,这里填写property.post,topic处填写
/sys/product_key/device_name/thing/event/property/post
此处product_key,device_name替换成您的阿里三要素信息,其他选择默认。
间隔为自动提交间隔时间,单位为秒
代码处填写以下内容
function transformPayload(rawData) {
var jsonObj = {
"id":123456,
"params":{
"CurrentHumidity":88,
"CurrentTemperature":38.8
},
"version":"1.0",
"method":"thing.event.property.post"
};
return jsonObj;
}
发布会计算函数运算结果,在标准模式下会将函数返回的文本数据或JSON对象发布到物联网服务器上。透传模式则发布Buffer数据到物联网服务器。模式是新建虚拟设备时设置的。
单击提交保存发布设置。
6. 自动手动发送消息
回到桌面区后,保持设备连接状态(参见步骤三)。新建消息会根据步骤5中上报间隔设置,定期上报。若想手动上报,可在上报订阅区右键点击新创建的上报消息,再点击出现菜单的上报菜单进行手动上报。
若需禁用自动上报,可以点击禁用菜单,禁用后,可以再次启用。 点编辑菜单可以编辑上报消息 删除可以删除该上报消息
传感器和公共脚本
传感器是使用js模拟现实设备传感器的模块,可以被上报、订阅消息重复使用。对于简单或不常用的模拟数据可以直接写到上报或订阅消息中。若传感器会被设备仿真器频繁使用,建议建立独立的传感器,供上报、订阅消息重复使用。
脚本为公共函数,可以被传感器及上传、订阅消息内的脚本所调用,通常完成一些常见操作,例如ID生成,数据格式转化等。
本部分通过建立一个简单的温湿度传感器,供上报消息使用来演示传感器和公共脚本如何使用。
1. 创建一个传感器
点击桌面区域功能区的传感器菜单,打开传感器列表面板,再点击右上方+号,新建传感器。
打开的传感器面板
名称填写温湿度传感器,备注填写读取本地温湿度,代码如下
function readSensor($) {
let res = {
Temperature : Number((Math.random()*50).toFixed(1)),
Humidity : Math.round((Math.random()*100))
};
return res;
}
该传感器返回两个数字量,一个温度,带1位小数浮点数,一个湿度,类型为整数。返回的结果是一个JSON对象。
所有传感器结果必须返回JSON对象,数值才能传送给上报消息使用。
点击提交保存结果后,您将在传感器列表面板找到新建的传感器。
2. 编辑公共脚本
点击主界面功能区脚本菜单,弹出脚本编辑面板,录入脚本如下:
//获取当前时间的时间戳 用于生成消息ID
function timestamp() {
return Math.round(new Date() / 1000);
}
点击提交保存结果。
3. 重新编译上报消息
在以上介绍的新建的上报消息property.post菜单上点击右键,点击编辑菜单,打开编辑消息面板。
在变量处选择温湿度传感器的两个变量,如图所示
点击蓝色按钮,使变量穿梭到右侧,如下所示
上下箭头按钮可以调节变量顺序,我们将湿度调节到上面,如下所示
代码区粘贴代码如下
/**
* 将设备raw数据转换为json格式数据
* 入参:rawData 数组
* 出参:jsonObj JSON对象 不能为空
*/
function transformPayload(rawData) {
var jsonObj = {
"id":timestamp(),
"params":{
"CurrentHumidity":rawData[0],
"CurrentTemperature":rawData[1]
},
"version":"1.0",
"method":"thing.event.property.post"
};
return jsonObj;
}
其中rawData数据来源于上面所设置的变量部分,数组内容顺序于所调整的一致。jsonObj属性id使用了公共库timestamp函数结果,点击提交保存结果。
回到桌面区,保持设备连接状态,自动或手动上报后,通过观察日志您将看到传感器和公共脚本上报结果。
订阅
1. 新建订阅
点击编辑发布消息部分2标记处按钮,打开新建订阅面板。
名称处填写 property.set,主题处填写 /sys/{product_key}/{device_name}/thing/service/property/set
此处product_key,device_name替换成您的阿里三要素信息
其他保持默认,点击提交保存订阅。
Publish用于收到订阅消息后进行上报,这里可以选择一个已保存的上报消息。通常将该类型的上报设置为禁用,只有在接受到对应订阅消息后才自动进行消息上报。在该类上报消息处理函数中会将订阅payload传入给第二个参数,以便进行相关操作。以下为订阅上报类消息函数模型
/**
* 将设备raw数据转换为json格式数据
* 入参:rawData 传感器数据对象
* 入参:subPayload 订阅payload对象
* 出参:jsonObj JSON对象 不能为空
*/
function transformPayload(rawData,subPayload) {
var jsonObj = {
"id":subPayload.id,
"params":{},
"version":"1.0",
"method":"thing.event.property.post"
};
if(subPayload.params.LowTemperature !== undefined)
jsonObj.params.LowTemperature = subPayload.params.LowTemperature;
if(subPayload.params.MaxTemperature !== undefined)
jsonObj.params.MaxTemperature = subPayload.params.MaxTemperature;
return jsonObj;
}
2. 订阅测试
回到主界面后,保持设备仿真器处于连接状态。手动发送消息或等待自动发送消息完成,您将在日志中观察到发布及订阅消息的结果。