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

});

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。