首页 | 编程 | Java

使用JavaScript和MQTT开发物联网应用示例解析

2020年08月07日 作者：唐门教主原文

如果说Java和C#哪个是最好的开发语言，无疑会挑起程序员之间的相互怒怼，那如果说JavaScript是动态性最好的语言，相信大家都不会有太大的争议。随着越来越多的硬件平台和开发板开始支持JavaScript，JavaScript在硬件端以及物联网领域有了新的机会。

IoT应用开发的数据链路

图1是一个智能家居物联平台的数据链路。


图2 MQTT的数据链路图

MQTT被广泛使用的一个重要的原因是MQTT的生态非常完善，同时也支持JavaScript。因此图2所示的所有链路和模块，都可以通过JavaScript实现。

mosca是一个用JavaScript实现的MQTT Broker。不仅如此，mosca还增加了对数据库，如Redis、MongoDB的支持，用来实现消息数据的存储。

MQTT.js（https://github.com/mqttjs/MQTT.js）
MQTT.js是官网推荐的JavaScript实现的Client端。

KOA和Express
这两者都是非常主流的Node版本的Server，简单易用。

实战物联网应用

这节我们运用之前介绍的框架，自己动手完成一个简单的物联网应用。应用场景如图4所示，温度传感器用于接收温度，并把文档通过MQTT发送到Server端，在Server端进行业务处理，根据温度计算出穿衣提示，通过MQTT把数据发送到特定的Topic，App订阅Topic获取数据后进行展现。

图4 “穿衣提示”业务场景框架

Broker端的实现

Broker端使用mosca，参考网页https://github.com/mcollina/mosca。

安装mosca。

nmp install mosca --save

启动mosca。这里需要注意，如果本地没有配置MongoDB，则需要把ascoltatore中的内容全部注释掉。

var mosca = require('mosca');

var ascoltatore = {
 //using ascoltatore
 // type: 'mongo',
 // url: 'mongodb://localhost:27017/mqtt',
 // pubsubCollection: 'ascoltatori',
 // mongo: {}
};

var settings = {
 port: 1883,
 backend: ascoltatore
};

var server = new mosca.Server(settings);

server.on('clientConnected', function(client) {
 console.log('client connected', client.id);
});

// fired when a message is received
server.on('published', function(packet, client) {
 console.log('Published', packet.payload); //{"clientId":"mqttjs_02fea7b4","topic":"/tips"}
 // console.log('>>>packet', packet); //{"clientId":"mqttjs_02fea7b4","topic":"/tips"}
});

server.on('ready', setup);

// fired when the mqtt server is ready
function setup() {
 console.log('Mosca server is up and running');
}

代码完成后，启动文件，本地的一个Broker就跑在localhost的1883端口上了。

Client端的温度传感器实现

Client使用MQTT.js实现，参考网页https://github.com/mqttjs/MQTT.js

安装

npm install mqtt --save

启动

var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://localhost:1883');

client.on('connect', function () {
 console.log('>>> connected')
 // client.subscribe('/tips')
 setInterval(
  ()=>{client.publish('/temperature', '30');},
  3000
 );

})

client.on('message', function (topic, message) {
 // message is Buffer
 console.log(message.toString())
})

// client.end();

执行Node index后Client就启动了，可以看到在MQTT.connect方法中连接了上一节中启动的Broker地址，连接成功后，Client会输出日志，“>>> connected”，Broker的控制台也会输出Client的连接信息。

这里模拟了温度传感器，定时3秒向/temperature的Topic中发送温度数据。

本节的温度器可以在电脑中使用Node方式运行，也可以运行在支持JavaScript的开发板中，如RUFF、NodeMCU、Raspberry Pi，并且可以使用真实的传感器。

Server的实现

Server使用MQTT.js订阅Client发送到/temperature Topic的数据进行处理，把处理后的数据转译成JSON发送到另一业务主题/tips中。

实现代码如下：

'use strict'

const mqtt = require('mqtt');
var client = mqtt.connect('mqtt://localhost:1883');

client.on('connect', function () {
 console.log('>>> connected');
 client.subscribe('/temperature');
})

client.on('message', function (topic, message) {
 var temperature = parseInt(message.toString());
 var data = {temperature};

 if (temperature >= 60) {
  data.tips = "热... 500服务器故障";
 }
 else if (temperature >= 50) {
  data.tips = "今天天气非常热，建议不要穿衣服了";
 }
 else if (temperature >= 40) {
  data.tips = "今天天气十分的热，建议穿短袖T恤+短裤";
 }
 else if (temperature >= 30) {
  data.tips = "今天天气有点的热，建议穿短袖T恤";
 }
 else if (temperature >= 0) {
  data.tips = "今天天气正好，可以穿上一件薄衣服";
 }
 else if (temperature >= -10) {
  data.tips = "今天天气十分寒冷，棉袄可以穿上一件"; 
 }
 else {
  data.tips = "今天天气十分十分寒冷，棉袄可以穿上二件"; 
 }
 client.publish('/tips', JSON.stringify(data));
 // if (temperature+1) {}
 // message is Buffer
 console.log(JSON.stringify(data));
})

App的实现

Demo的App使用KOA启动一个Web，在Web中展现当前温度对应的穿衣提示，通过订阅tips获取数据。

安装koa

$ npm install koa

实现代码

'use strict'

const Koa = require('koa');
const mqtt = require('mqtt');
const app = new Koa();


var msg = {temperature:"-",tips:""};
// response
app.use(ctx => {
 ctx.body = "当前温度:" + msg.temperature + "度" + "\n" + '穿衣提示:'+msg.tips + "\n" ;
});

app.listen(3000);

//mqtt
var client = mqtt.connect('mqtt://localhost:1883');

client.on('connect', function () {
 console.log('>>> connected');
 client.subscribe('/tips');
})

client.on('message', function (topic, message) {
 var data = JSON.parse(message.toString());
 console.log(message.toString()); 
 console.log(data.tips); 
 msg = data;

 // if (temperature+1) {}
 // message is Buffer
 // let str = message.toString();
 // let data = JSON.parse(message);
 // console.log(data.tips);
 // msg = message.toString();
})

Demo小节

本章给出了一个简单的物联网业务的业务场景和实现逻辑，其中Client也可以运行在电脑上进行Demo查看，或是跑在真实物联设备或开发版上。如图5，笔者使用RUFF开发板实现了一次。

图5 Demo硬件演示

完整Demo代码已经分享在github中，大家可以输入URL下载。
https://github.com/coolnameismy/javascript-mqtt-demo-wearingTip

总结

本文和大家交流了物联网应用的一般数据链路、MQTT协议的架构，并基于MQTT实现了一个简单的物联网应用。

现在正是前端工程师的大好机会，越来越多的嵌入式设备都开始支持JavaScript，原因是现在有很多JavaScript引擎可以把JavaScript转换成各种平台的底层代码，比较有名的有Jerryscript、Duktape等。随着越来越多的JavaScript工程师进入嵌入式开发的领域，嵌入式应用开发也会出现前后端分离的情况（应用开发或是驱动开发），类似于Web开发的前后端分离。前端关注在应用、创意、数据链路、用户体现上，而后端则关心GPIO、I2C的底层数据接口和驱动，平台兼容性等方向。

到此这篇关于使用JavaScript和MQTT开发物联网应用示例解析的文章就介绍到这了,更多相关JavaScript和MQTT开发物联网应用内容请搜索来客网以前的文章或继续浏览下面的相关文章希望大家以后多多支持来客网！

相关链接