var mqtt = require('mqtt')
var options = {
username: 'abc',
password: 'xyz',
}
var client = mqtt.connect('mqtt:localhost:1883', options);
function authenteClient() {
// I need to call this function against the callback at server's
// authenticate function.
}在上面的代码中,我正在为这个mqtt客户端提供用户名和密码。
var mosca = require('mosca');
var ascoltatore = {
type: 'mongo',
url: 'mongodb://localhost:27017/mqtt',
pubsubCollection: 'ascoltatori',
mongo: {}
};
var settings = {
port: 1883,
backend: ascoltatore
};
var server = new mosca.Server(settings);
server.on('ready', setup);
function setup() {
server.authenticate = authenticate;
console.log('Mosca server is up and running');
}
var authenticate = function(client, username, password, callback) {
console.log(username, password);
callback(true);
}在这里,在authenticate函数的服务器端,我需要连接客户端的回调,这个回调被调用为callback(true)。
发布于 2018-04-19 06:44:51
如果客户端在代理端的身份验证失败,它将不会连接。
如果它通过,它将连接,并且可以使用client.on('connect',function(){})事件侦听器通知您。
发布于 2020-05-02 11:18:50
聚会晚了,但在客户端,您可以这样做:
//Handle errors
client.on("error", (error) => {
console.log("Error: ", error.message);
});服务器上的任何错误都可以在此阶段优雅地处理。
https://stackoverflow.com/questions/49914017
复制相似问题