Test delle prestazioni di RabbitMQ/MQTT

Question

Ho configurato correttamente un cluster RabbitMQ che supporta MQTT tramite il plug-in MQTT. Al momento, i messaggi MQTT passano uno scambio di argomenti il ​​cui vincolo con una coda di lavoro. Quindi tutti i messaggi MQTT sono memorizzati in questa coda di lavoro.

Ora mi piacerebbe testare le prestazioni di Input di questo cluster studiando i grafici nel plugin di gestione RabbitMQ. Il mio piano era di installare 2 editori MQTT NodeJS che attivassero molti messaggi MQTT all'interno di un ciclo for, ma questo fallisce.

Quando il ciclo for viene eseguito più di 3000 volte, non tutti i messaggi sopravvivere ... (Trova il mio codice di prova di seguito) Mi piacerebbe avere la vostra opinione su questo:

1. Quali potrebbero essere i messaggi ragione non sopravvivere?
2. Qual è il modo migliore per valutare le prestazioni di RabbitMQ/MQTT?
3. Devo utilizzare più editori? Presa [il codice] => [buffer di memoria del cliente] => [inviare-system:

Codice:

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

messaggio vengono confezionati in presa ruscello e byte di dati effettivi sono da qualche parte sul percorso buffer] => [recv-system socket buffer] => [codice server].

Se si utilizza localhost, la possibilità per il buffer di socket per i messaggi 3K è minima, ma esiste.

Non ho molta familiarità con il client mqjt nodeJS, ma se sta eseguendo client.end() con l'operazione di spegnimento del socket è possibile che alcuni frame mqtt semplicemente non raggiungano il server.

avete alcune opzioni per il test come:

• sonno un po 'prima client.end(), solo un po';
• usa QoS = 1 messaggi, ancora hai la possibilità di perdere alcuni byte non compressi, a seconda della configurazione della dimensione della finestra mqtt;
• uso dovrebbe occupare più appropriato, è possibile google per "generatore di carico MQTT" per i campioni