MQTT-Bench : MQTT Benchmark Tool

This is the benchmark tool for MQTT Broker implemented by golang. This can benchmark the throughput for publishing and subscribing.

Supported benchmark pattern is:

Parallel publish from clients
Parallel subscribe from clients with publishing

Getting started

Installation

Use go get and go install

$ go get github.com/takanorig/mqtt-bench
$ go install github.com/takanorig/mqtt-bench

Download here

https://github.com/takanorig/mqtt-bench/releases

Publish

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.

TLS mode

Use -tls option.

Server authentication

-tls=server:certFile

Server and Client authentication

-tls=client:rootCAFile,clientCertFile,clientKeyFile

Usage

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

Note

Using Apollo
If you use Apollo 1.7.x, the subscribed messages can't be output to console even if debug mode. If you want to output the subscribed messages, designate -support-unknown-received option.

gfechio/mqtt-bench