mosca mqtt broker示例源码(nodejs 服务端源码)

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 receivedserver.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 readyfunction 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);//验证未通过}