MqttEmu 物联网设备模拟器

简介: MqttEmu是使用Electron构建桌面应用程序,允许运行在Windows、macOS和Linux上。MqttEmu是一个物联网设备仿真器,主要使用Mqtt协议进行网络通讯,实现物联网设备与物联网平台的消息通讯。MqttEmu适用于没有物联网硬件开发经验或者暂时不需要进行物联网硬件开发的人员,MqttEmu可以在没有物联网硬件的前提下进行网联网服务端开发,并进行服务端功能性测试。

如何下载

百度网盘链接: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. 订阅测试


回到主界面后,保持设备仿真器处于连接状态。手动发送消息或等待自动发送消息完成,您将在日志中观察到发布及订阅消息的结果。


相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
目录
相关文章
|
6天前
|
Web App开发 网络协议 安全
基于Web攻击的方式发现并攻击物联网设备介绍
基于Web攻击的方式发现并攻击物联网设备介绍
|
17天前
|
安全 物联网 物联网安全
智能物联网安全:物联网设备的防护策略与最佳实践
【10月更文挑战第26天】随着物联网(IoT)技术的快速发展,智能设备已广泛应用于智能家居、工业控制和智慧城市等领域。然而,设备数量的激增也带来了严重的安全问题,如黑客攻击、数据泄露和恶意控制,对个人隐私、企业运营和国家安全构成威胁。因此,加强物联网设备的安全防护至关重要。
42 7
|
18天前
|
监控 安全 物联网
确保互联世界中物联网设备安全的三个技巧
确保互联世界中物联网设备安全的三个技巧
|
1月前
|
物联网 5G 智能硬件
物联网卡:物联网卡不支持语音通话,是如何实现设备间的数据传输和通信的?
物联网卡(IoT SIM卡)通常被设计用于支持物联网(IoT)设备之间的数据传输,而不直接支持语音通话功能。这是因为物联网设备主要关注的是数据的收集、传输和处理,而不是语音通信。为了实现设备间的数据传输和通信,物联网卡及其背后的技术采用了多种方法,主要包括但不限于以下几种方式:
物联网卡:物联网卡不支持语音通话,是如何实现设备间的数据传输和通信的?
|
27天前
|
物联网
物联网卡不能使用在什么设备上
“物联网卡不能使用在什么设备上”这一操作或规定,通常基于物联网卡的特性、使用条款以及设备兼容性等因素。以下是对这一问题的详细分析和操作建议:
|
30天前
|
存储 监控 物联网
医疗物联网设备精细化管理系统解决方案
华汇数据智慧医院物联网管理系统解决方案是一种集物联网、云计算、大数据和人工智能等先进技术于一体的综合性解决方案,旨在提升医院的运营效率、医疗质量和患者满意度。
69 3
|
1月前
|
安全 物联网
物联网卡不能更换设备使用吗
物联网卡(IoT SIM卡)是否允许更换设备使用,这主要取决于物联网服务提供商的具体政策和服务条款。通常,物联网卡是为特定设备或应用场景设计的,因此一些服务提供商会限制卡的更换使用,主要是出于安全、管理、网络优化和避免滥用等考虑
|
16天前
|
安全 物联网 物联网安全
智能物联网安全:物联网设备的防护策略与最佳实践
【10月更文挑战第27天】随着物联网技术的快速发展,智能设备已广泛应用于生活和工业领域。然而,物联网设备的安全问题日益凸显,主要威胁包括中间人攻击、DDoS攻击和恶意软件植入。本文探讨了物联网设备的安全防护策略和最佳实践,包括设备认证和加密、定期更新、网络隔离以及安全标准的制定与实施,旨在确保设备安全和数据保护。
34 0
|
1月前
|
人工智能 安全 物联网
|
1月前
|
存储 安全 物联网

相关产品

  • 物联网平台