今天使用mosca 寫了一下基于MQTT的消息服務端，用于下一個項目的知識儲備；

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

1.?安裝?mosca

npm?install?mosca?--save

2. 創(chuàng)建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);

});

/**

*?監(jiān)聽MQTT主題消息

**/

MqttServer.on('published',?function(packet,?client)?{

var?topic?=?packet.topic;

switch(topic){

case?'pubMsg':

console.log('message-publish',?packet.payload.toString());

//MQTT轉(zhuǎn)發(fā)主題消息

MqttServer.publish({topic:?'other',?payload:?'sssss'});

//發(fā)送消息NODEJS

console.log('HD:?'+?YHSocketMap.get('1000'));

//發(fā)送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...');

});

總結(jié)

以上是生活随笔為你收集整理的mosca mysql_nodejs 完成mqtt服务端的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。