| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
9年前发布

nodejs 完成mqtt服务端

使用mosca 写了一下基于MQTT的消息服务端,用于下一个项目的知识储备;

该功能主要是基本 NODEJS 的 mosca 插件完成

    1. 安装 mosca

npm install mosca --save

    2. 创建mqtt服务端,端口为:8000

var 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'});       //发送消息NODEJS       console.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...');  });

 本文由用户 jopen 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1422347317658.html
消息系统 NodeJS