目前,我成功运营了一个蚊子经纪人,订阅主题并与本地网络中的客户发布消息.
如何与位于不同IP地址的其他本地网络进行通信?
我应该建立2个蚊子经纪人,每个地方网络一个吗?
我已经成功配置了一个通过MQTT插件支持MQTT的RabbitMQ集群.目前,MQTT消息传递一个与工作队列绑定的主题交换.因此,所有MQTT消息都存储在此工作队列中.
现在,我想通过研究RabbitMQ管理插件中的图表来测试此集群的输入性能.我的计划是设置2个NodeJS MQTT发布者在for循环中触发许多MQTT消息但是这失败了.
当for循环运行超过3000次时,并非所有消息都存在...(在下面找到我的测试代码)我想对此有你的意见:
码:
var quantity = 3000;
var mqtt = require('mqtt');
var options = {
host: 'localhost',
port: 1883,
protocolId: 'MQIsdp',
rejectUnauthorized: false,
protocolId: 'MQIsdp',
protocolVersion: 3
};
var client = mqtt.connect(options);
for(var x=0; x<quantity; x++)
{
client.publish('/WSN/N536,563E/dynamic',"22");
console.log(x);
}
client.end();
Run Code Online (Sandbox Code Playgroud)