MQTT是一种基于发布/订阅（publish/subscribe）模式的“轻量级”通信协议，它建立在TCP/IP协议之上，由IBM于1999年发布。MQTT最大的优势在于它可以以极少的代码和有限的带宽为连接的远程设备提供实时可靠的消息服务。作为一种低开销、低带宽的即时通讯协议，它在物联网、小型设备和移动应用中有着广泛的应用。1.引入mqttnpminstallmqtt-g2.使用1.注册varalias=Math.random().toString(16).substr(2,8)client=mqtt.connect(process.env.MQTT,{//注册地址username:process.env.MQ_NAME,//注册mqtt用户名password:process.env.MQ_PD,//注册mqtt密码protocolVersion:4,protocolId:'MQTT',clientId:alias,//保证全局唯一clean:true//控制是否接受离线消息，false可以接受离线消息})2.注册主题*（mqtt发送消息的主题）client.on('connect',function(){client.subscribe(userName,function(err){if(!err){console.log('Hellomqtt')client.publish('presence','Hellomqtt')}})})userName为主题名称（例如：用户名）3.接收消息客户端.on('message',function(topic,message){//console.log(topic)//console.log(message.toString())msg??=message})4.关闭mqttclient.on('end',function(err){client.end()})参考(https://github.com/mqttjs/MQT...)
