今天使用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...');

});