This is a benchmark tool for MQTT Broker implemented in golang. It can benchmark the throughput for publishing and subscribing. Forked originally from takanorig/mqtt-bench and modified for newer PAHO MQTT location on github https://github.com/eclipse/paho.mqtt.golang/. Translations still forthcoming
Supported benchmark pattern is:
- Parallel publish from clients
- Parallel subscribe from clients with publishing
This client is designed to work with the standard Go tools, so installation is as easy as:
go get github.com/talmai/mqtt-bench
The client depends on Eclipse's PAHO MQTT package, also easily installed with the command:
go get github.com/eclipse/paho.mqtt.golang
- Precondition
- The MQTT Broker is started.
$ mqtt-bench -broker=tcp://192.168.1.100:1883 -action=pub
2015-04-04 12:47:38.690896 +0900 JST Start benchmark
2015-04-04 12:47:38.765896 +0900 JST End benchmark
Result : broker=tcp://192.168.1.100:1883, clients=10, totalCount=1000, duration=72ms, throughput=13888.89messages/sec
- Precondition
- The MQTT Broker is started.
- Publishing to MQTT Broker.
(Publish the messages while subscribing)
$ mqtt-bench -broker=tcp://192.168.1.100:1883 -action=pub -count=10000
$ mqtt-bench -broker=tcp://192.168.1.100:1883 -action=sub
2015-04-04 12:50:27.188396 +0900 JST Start benchmark
2015-04-04 12:50:27.477896 +0900 JST End benchmark
Result : broker=tcp://192.168.1.100:1883, clients=10, totalCount=1000, duration=287ms, throughput=3484.32messages/sec
If the following message is output to the console, the count is over limit.
So, please set -intervalTime option.
panic: Subscribe error : Not finished in the max count. It may not be received the message.
Use -tls option.
- Server authentication
-tls=server:certFile
- Server and Client authentication
-tls=client:rootCAFile,clientCertFile,clientKeyFile
Usage of mqtt-bench
-action="p|pub or s|sub" : Publish or Subscribe (required)
-broker="tcp://{host}:{port}" : URI of MQTT broker (required)
-broker-password="" : Password for connecting to the MQTT broker
-broker-username="" : Username for connecting to the MQTT broker
-tls="" : TLS mode. 'server:certFile' or 'client:rootCAFile,clientCertFile,clientKeyFile'
-qos=0 : MQTT QoS(0|1|2)
-retain=false : MQTT Retain
-topic="/mqtt-bench/benchmark" : Base topic
-clients=10 : Number of clients
-count=100 : Number of loops per client
-size=1024 : Message size per publish (byte)
-pretime=3000 : Pre wait time (ms)
-intervaltime=0 : Interval time per message (ms)
-x=false : Debug mode