Тестирование производительности RabbitMQ/MQTT

Question

Я успешно сконфигурировал кластер RabbitMQ, который поддерживает MQTT через плагин MQTT. На данный момент сообщения MQTT проходят обмен темой, привязанный к рабочей очереди. Таким образом, все сообщения MQTT хранятся в этой рабочей очереди.

Теперь я хотел бы протестировать производительность ввода этого кластера, изучив графики в плагине управления RabbitMQ. Мой план состоял в том, чтобы создать 2 издателя NodeJS MQTT, отменяющих многие сообщения MQTT в цикле for, но это не удается.

Когда цикл работает более 3000 раз, не все сообщения выживают ... (Найти мой тестовый код ниже), я хотел бы иметь свое мнение по этому вопросу:

1. Что может быть причиной сообщения не выживают?
2. Каков наилучший способ оценить производительность RabbitMQ/MQTT?
3. Должен ли я использовать несколько издателей? Гнездо [код] => [клиент буфер памяти] => [отправить-систему:

Код:

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(); 

Answer 1

Сообщения которые упаковывались в потоке сокет и фактические байты данных находятся где-то на пути buffer] => [буфер буфера recv-system] => [код сервера].

Если вы используете localhost, вероятность наличия буфера сокета для сообщений 3K минимальна, но существует.

Я не очень хорошо знаком с mqqt nodeJS-клиентом, но если он делает client.end() с операцией отключения сокета, возможно, некоторые кадры mqtt просто не доходят до вашего сервера.

У вас есть несколько вариантов теста, как:

• сна немного, прежде чем client.end(), только немного;
• использовать QoS = 1 сообщение, все же у вас есть шанс потерять некоторые незакрепленные байты, в зависимости от конфигурации размера окна mqtt;
• использование более целесообразно чем-л, вы можете Google для «генератора нагрузки MQTT» для образцов