我这样连接到 MQTT:
//mqtt.js
const mqtt = require('mqtt');
var options = {
//needed options
};
var client = mqtt.connect('mqtt://someURL', options);
client.on('connect', () => {
console.log('Connected to MQTT server');
});
我想导出client以此方式反对:
//mqtt.js
module.exports = client;
这样我就可以将其导入其他文件中并以这种方式使用它:
//anotherFile.js
const client = require('./mqtt');
client.publish(...)
然而,我们都知道这是行不通的!我怎样才能做到这一点?
Update
I tried promise并得到一个非常奇怪的行为。当我在同一个文件(mqtt.js)中使用承诺(如下面的代码)时,一切正常:
//mqtt.js
const mqtt = require('mqtt');
var mqttPromise = new Promise(function (resolve, reject) {
var options = {
//needed options
};
var client = mqtt.connect('mqtt://someURL', options);
client.on('connect', () => {
client.subscribe('#', (err) => {
if (!err) {
console.log('Connected to MQTT server');
resolve(client);
} else {
console.log('Error: ' + err);
reject(err);
}
});
});
});
mqttPromise.then(function (client) {
//do sth with client
}, function (err) {
console.log('Error: ' + err);
});
但是当我导出承诺并在另一个文件中使用它时,如下所示:
//mqtt.js
//same code to create the promise
module.exports = mqttPromise;
//anotherFile.js
const mqttPromise = require('./mqtt');
mqttPromise.then(function (client) {
//do sth with client
}, function (err) {
console.log('Error: ' + err);
});
我收到此错误:
类型错误:mqttPromise.then 不是函数