RabbitMQ/MQTT performansını test etme

Question

MQTT eklentisi aracılığıyla MQTT'yi destekleyen bir RabbitMQ kümesini başarıyla yapılandırdım. Şu anda MQTT mesajları, bir iş kuyruğuyla bağlanan bir konu değişimini iletmektedir. Bu yüzden tüm MQTT mesajları bu iş kuyruğunda saklanır.

Şimdi RabbitMQ yönetim eklentisindeki grafikleri inceleyerek bu kümenin Giriş performansını test etmek istiyorum. Planım, 2 NodeJS MQTT yayıncısının bir for döngüsü içinde birçok MQTT mesajını kapatmasını sağlamaktı ancak bu başarısız oldu.

1. Ne nedeni mesajları olabilir: döngü için 3000 defa, tüm iletiler yaşayamaz çalıştığında

   ... Bu konuda fikrinizi almak istiyorum (aşağıda benim test kodunu bulun) hayatta kalma

2. RabbitMQ/MQTT'nin performansını değerlendirmenin en iyi yolu nedir?
3. Birden çok yayımcı kullanmalı mıyım?
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

Mesaj akışı prize paketleniyor ve gerçek veri bayt yolda bir yerde şunlardır: [kodunuzu] => [müşterinin bellek tampon] => [send-sistem soket buffer] => [recv sistem soket arabelleği] => [sunucu kodu].

localhost kullanıyorsanız, 3K iletileri için yuva arabelleği olasılığı minimumdur, ancak var.

mqqt nodeJS istemcisine çok aşina değilim, ancak client.end() soket kapatma işlemiyle çalışıyorsa, bazı mqtt çerçevelerinin sunucunuza ulaşmaması mümkündür.

Sen gibi test için bazı seçenekler vardır:

• uyku client.end() önce biraz sadece biraz;
• QoS = 1 mesajlarını kullanın, yine de mqtt penceresinin boyutuna bağlı olarak bazı paketlenmemiş baytları kaybetme şansınız var;
• kullanım Tavsiyen daha uygun, sen numuneleri size 1 veya 2 bir QoS kullanmayı deneyin Can