基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

var mosca = require('mosca');
const StringDecoder = require('string_decoder').StringDecoder;
let decoder = new StringDecoder('utf8');
var ascoltatore = {
    type: 'redis',
    redis: require('redis'),
    db: 12,
    port: 6379,
    return_buffers: true, // to handle binary payloads
    host: "localhost"
};

var settings = {
    port: 11883,
    backend: ascoltatore
};

var server = new mosca.Server(settings);

server.on('clientConnected', function(client) {
    console.log('client connected', client.id);
});

// fired when a message is received
server.on('published', function(packet, client) {
    console.log('Published', packet.payload);
    console.log('topic',decoder.write(packet.topic));
    console.log('payload',decoder.write(packet.payload));
});

server.on('ready', setup);

// fired when the mqtt server is ready
function setup() {
    console.log('Mosca server is up and running');
    server.authenticate = authenticate;
}
var authenticate = function(client, username, password, callback) {
    console.log('authenticate---->' client.id ',' username ',' password);
    callback(null, true);//验证通过
    // callback(null, false);//验证未通过
}