cms网站建站流程,镇江网站设计,阜阳企业做网站,邮箱域名指的是什么今天使用mosca 写了一下基于MQTT的消息服务端#xff0c;用于下一个项目的知识储备#xff1b;该功能主要是基本 NODEJS 的 mosca 插件完成1. 安装 moscanpm install mosca --save2. 创建mqtt服务端#xff0c;端口为#xff1a;8000var mosca require(mosca);var MqttSer…今天使用mosca 写了一下基于MQTT的消息服务端用于下一个项目的知识储备该功能主要是基本 NODEJS 的 mosca 插件完成1. 安装 moscanpm install mosca --save2. 创建mqtt服务端端口为8000var mosca require(mosca);var MqttServer new mosca.Server({port: 8000});3. mqtt服务端部分逻辑处理MqttServer.on(clientConnected, function(client){console.log(client connected, client.id);});/*** 监听MQTT主题消息**/MqttServer.on(published, function(packet, client) {var topic packet.topic;switch(topic){case pubMsg:console.log(message-publish, packet.payload.toString());//MQTT转发主题消息MqttServer.publish({topic: other, payload: sssss});//发送消息NODEJSconsole.log(HD: YHSocketMap.get(1000));//发送socket.io消息//io.sockets.socket(YHSocketMap.get(1000)).emit(subState, packet);break;case other:console.log(message-123, packet.payload.toString());break;}});MqttServer.on(ready, function(){console.log(mqtt is running...);});
