我目前正处于一个项目的中间，其中包括使用MQTT。我正在用node.js编写我的应用程序。我的项目需要连接/通信到每个设备已指定的多个设备以及不同的主题。稍后，每个消息中的数据将存储到数据库（MongoDB）中。我正在使用npmjs.com 1的mqtt包。
以下是mqtt软件包代码的示例：
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://test.mosquitto.org');
client.on('connect', function () {
client.subscribe('presence');
client.publish('presence', 'Hello mqtt');
});
client.on('message', function (topic, message) {
// message is Buffer
console.log(message.toString());
client.end();
});
我的问题是我应该怎么做才能从设备中获取消息。我可以使用“＃”轻松列出单个主题，以获取所有主题，但是我必须手动对主题进行排序/拆分等。
但是，我在考虑另一种选择，其中我将为每个主题创建新的mqtt客户端实例，但是我不知道实例是否有限制。我可能会使用async包2中的forever函数。我的代码可能是这样的：
var async = require('async');
var mqtt = require('mqtt');
var client = mqtt.connect("URL of MQTT broker");
var _topic = "";
var Subscriber = function(topic){
this._topic = topic;
client.on('connect', function () {
client.subscribe(this.topic.setter);
});
async.forever(
function(next){
client.on('message', function (topic, message) {
// TO DO store message
});
},
function(err){
client.end();
}
);
};
module.exports = Subscriber;
有人有什么建议吗？
我不建议为您要进行的每个订阅创建单独的连接。每个连接都是一个新的TCP连接，将浪费您的应用程序和代理中的资源。
此处的正常模式是使用通配符订阅。消息回调处理程序将消息来自的主题传递给消息回调处理程序，因此，只要您合理地构造主题空间，那么在应用程序中适当地路由消息的开销就很小。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句