Testowanie wydajności RabbitMQ/MQTT

Question

Mam pomyślnie skonfigurowany klaster RabbitMQ, który obsługuje MQTT za pośrednictwem wtyczki MQTT. W tej chwili komunikaty MQTT przekazują wymianę tematów, która jest powiązana z kolejką roboczą. Tak więc wszystkie wiadomości MQTT są przechowywane w tej kolejce roboczej.

Teraz chciałbym przetestować wydajność wejścia tego klastra, analizując wykresy wtyczki zarządzania RabbitMQ. Mój plan polegał na założeniu 2 wydawców NodeJS MQTT wystrzeliwujących wiele komunikatów MQTT w pętli for, ale to się nie powiedzie.

Gdy do pętli działa ponad 3000 razy, nie wszystkie komunikaty przeżyć ... (Znajdź mój kod testowy poniżej) Chciałbym mieć swoje zdanie na ten temat:

1. Co może być powodem wiadomości nie przeżyjesz?
2. Jaki jest najlepszy sposób oceny wydajności RabbitMQ/MQTT?
3. Czy powinienem używać wielu wydawców? Gniazdo [kod] => [bufor pamięci klienta] => [send-System:

Kod:

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

wiadomości są pakowane do gniazda strumienia i rzeczywiste bajty danych są gdzieś na ścieżce buffer] => [bufor gniazda systemu recv] => [kod serwera].

Jeśli korzystasz z localhost, szansa na bufor gniazda dla wiadomości 3K jest minimalna, ale istnieje.

Nie jestem zaznajomiony z klientem mqqt nodeJS, ale jeśli wykonuje on client.end() z operacją zamykania gniazd, możliwe jest, że niektóre ramki mqtt po prostu nie docierają do serwera.

Masz kilka opcji do testu jak:

• spać nieco wcześniej client.end(), tylko trochę;
• używać QoS = 1 wiadomości, wciąż masz szansę na utratę niepotrzebnych bajtów, w zależności od konfiguracji rozmiaru okna mqtt;
• użycie smth bardziej odpowiednie, można google dla "generator obciążenia mqtt" dla próbek