Hi all,
I'm doing some stress testing on mqtt. I used the mosquitto service and python's paho-mqtt.
The experimental environment is: 2 computers with ubuntu(one as publisher , the other as subscriber and broker)
qos = 1
frequency = 10 msg/s for every publisher and msg size = 1MB
Bandwidth = 100M/s
For publisher I use while loop and time sleep to make it send msg continuously.
And I start about 50 publishers. After running 10 publishers on the publisher's computer, the bandwidth size is reached and the broker can no longer accept messages, at which point my publisher continues to store messages instead of hanging or queuing up to send them, causing the computer's memory usage to rise to 100%.
I don't know if this is a config issue or if I should add some interrupts to the code.
Looking forward to your comments and replies.
Best regards!