使⽤Node.js实现mqtt协议
记录⼀下⾃⼰学习mqtt的过程，如何从零开始使⽤Node.js实现mqtt协议，实现⼀个web页⾯向android端或其他client端发送消息，并接收其他client端发送的消息显⽰在web页⾯上。
主要⽤到的node模块是mqtt、mosca，web端使⽤mosca的mqtt over websocket功能，搭建web server可以使⽤express，存储数据以及mosca的backen都采⽤mongodb。
1、什么是MQTT
参见这位博主翻译的⼀系列hiveMQ 的⽂档，MQTT Part 1 简介 - 简书，⾮常详尽了。
2、安装nodejs模块
默认看到这篇⽂章的⼈已经了解Node.js
npm install mqtt --save
npm install mosca --save
安装mosca时，可能会遇到缺少依赖和环境的问题，
可能碰到ERR! configure error gyp ERR! stack Error: Can't find Python executable "python", ，需要安装python 2.7的环境。
还有可能碰到error MSB3428: Could not load the Visual C++ component "".遇到这个问题请安装visual studio 2015，不要装2017，然后
npm config set msvs_version 2015 --global
安装好后打开ide随便新建⼀个project，这样你需要的⼀切其他配置所需⽂件都有了，否则还会遇到各种其他问题，⽐如
node-gyp configure build KeyError: '2017' gyp ERR! configure error vs版本错误
Error: `C:\Program Files (x86)\MSBuild\14.0\`
MSB8036: The Windows SDK version 8.1 was not found.  安装对应sdk版本或vs中建project解决
error TRK0005: Failed to locate: "CL.exe". The system cannot find the file  vs中建project解决
3、使⽤mqtt.js创建⼀个客户端⽤于测试
建⽴mqtt_client.js
这是MQTT.js⽂档中给出的example，看这⾥ GitHub - mqttjs/MQTT.js: The MQTT client for Node.js and the browser，连接到mosquitto的⼀个mqtt测试⽤server，subscribe订阅，publish发表，('connect')连接已建⽴，('message')收到订阅的消息，其他更多api等⽤法看⽂档。
运⾏响应可能有点慢，如果配置成功，以上代码运⾏成功会显⽰
4、建⽴mqtt服务端（broker）
mqtt本质上是client之间通过⼀个中间⼈即broker，来进⾏相互通信，之后通过websocket进⾏连接的web端也是⼀个client。服务端的搭建我们使⽤mosca，开源免费。⽂档什么的看这⾥Mosca basic usage · mcollina/mosca Wiki · GitHub
根据mosca的作者mcollina的解释，mosca只实现mqtt协议，⼤量的pub/sub服务需要⼀个backend作为⽀持。我们⾸先不使⽤backend，测试服务端与客户端的通信。建⽴mqtt_server.js
node运⾏后，cmd窗⼝会显⽰“Mosca server is up and running”，证明server已启动
5、测试客户端与服务端的通信
将第3步中的mqtt_client.js 第⼆⾏
var t('mqtt://')  修改为
var t('mqtt://localhost')
再打开新的cmd窗⼝运⾏客户端，就可以建⽴与第四步中的server之间的通信啦。
成功通信后client端会显⽰'hello mqtt',⽽server端会显⽰连接的client ID，以及订阅发布的主题等。
6、使⽤mongodb作为backend
⾸先当然要在本地配置mongodb，具体配置过程不表，有很多⽂章讲解。
修改mqtt_server.js ，添加backend设置
然后在mongodb中建⽴mqtt的database，建⽴ascoltatori的collection，注意这个collection必须是固定集合（capped），否则会报错
’Error: Cannot recover. Collection is not capped. mosca‘。
成功之后，在你建⽴的collection中就会存储所有连接的client的ID，sub/pub操作，topic等等。
7、通过server向client 发送消息
在server端的setup（）函数中添加publish的代码段，注意这⾥不能直接把⽂档中的⽰例代码直接复制过来跑，会报错 Cannot read property 'insert' of undefined at EventEmitter.MongoAscoltatore.publish
= =因为是异步执⾏所以不写在setup⾥可能server还没ready就publish了。
开源mqtt服务器
然后还要修改⼀下mqtt_client.js，把d()去掉，还要订阅message topic。
然后启动服务端客户端客户端，就能从客户端看到message⾥的信息了。
8、mqtt over websockets
在⼯程⽬录下新建index.html
那个src中的mqtt.js存在于你深深的node module⽂件夹⾥，node module/mosca/public
然后在mqtt.server.js中添加web server的信息
然后启动完服务端，浏览器打开localhost:3000/index.html就打开了web的client端啦，启动mqtt_client.js，两个client端可以实现通信了。先写到这⾥ ，之后或许使⽤express做路由分发，mongodb存储发送的信息，丰富html页⾯内容，有空再写。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。