Erlang MQTT Benchmark Tool

# centos 7sudo yum install libatomic

# ubuntu 20.04sudo apt install libatomic1 

make

BUILD_WITHOUT_QUIC=1 make

$ ./emqtt_bench conn --helpUsage: emqtt_bench conn [--help <help>] [-h [<host>]] [-p [<port>]]                        [-V [<version>]] [-c [<count>]]                        [-n [<startnumber>]] [-i [<interval>]]                        [-u <username>] [-P <password>]                        [-k [<keepalive>]] [-C [<clean>]] [-x [<expiry>]]                        [-S [<ssl>]] [--certfile <certfile>]                        [--keyfile <keyfile>] [--quic [<quic>]]                        [--ifaddr <ifaddr>] [--prefix <prefix>]                        [-l <lowmem>]  --help                help information  -h, --host            mqtt server hostname or IP address [default:                        localhost]  -p, --port            mqtt server port number [default: 1883]  -V, --version         mqtt protocol version: 3 | 4 | 5 [default: 5]  -c, --count           max count of clients [default: 200]  -n, --startnumber     start number [default: 0]  -i, --interval        interval of connecting to the broker [default: 10]  -u, --username        username for connecting to server  -P, --password        password for connecting to server  -k, --keepalive       keep alive in seconds [default: 300]  -C, --clean           clean session [default: true]  -x, --session-expiry  Set 'Session-Expiry' for persistent sessions                        (seconds) [default: 0]  -S, --ssl             ssl socoket for connecting to server [default:                        false]  --certfile            client certificate for authentication, if required                        by server  --keyfile             client private key for authentication, if required                        by server  --quic                QUIC transport [default: false]  --ifaddr              local ipaddress or interface address  --prefix              client id prefix  -l, --lowmem          enable low mem mode, but use more CPU

./emqtt_bench conn -c 50000 -i 10

$ ./emqtt_bench sub --helpUsage: emqtt_bench sub [--help <help>] [-h [<host>]] [-p [<port>]]                       [-V [<version>]] [-c [<count>]]                       [-n [<startnumber>]] [-i [<interval>]]                       [-t <topic>] [-q [<qos>]] [-u <username>]                       [-P <password>] [-k [<keepalive>]] [-C [<clean>]]                       [-x [<expiry>]] [-S [<ssl>]]                       [--certfile <certfile>] [--keyfile <keyfile>]                       [--ws [<ws>]] [--quic [<quic>]]                       [--ifaddr <ifaddr>] [--prefix <prefix>]                       [-l <lowmem>]  --help                help information  -h, --host            mqtt server hostname or IP address [default:                        localhost]  -p, --port            mqtt server port number [default: 1883]  -V, --version         mqtt protocol version: 3 | 4 | 5 [default: 5]  -c, --count           max count of clients [default: 200]  -n, --startnumber     start number [default: 0]  -i, --interval        interval of connecting to the broker [default: 10]  -t, --topic           topic subscribe, support %u, %c, %i variables  -q, --qos             subscribe qos [default: 0]  -u, --username        username for connecting to server  -P, --password        password for connecting to server  -k, --keepalive       keep alive in seconds [default: 300]  -C, --clean           clean start [default: true]  -x, --session-expiry  Set 'Session-Expiry' for persistent sessions                        (seconds) [default: 0]  -S, --ssl             ssl socoket for connecting to server [default:                        false]  --certfile            client certificate for authentication, if required                        by server  --keyfile             client private key for authentication, if required                        by server  --ws                  websocket transport [default: false]  --quic                QUIC transport [default: false]  --ifaddr              local ipaddress or interface address  --prefix              client id prefix  -l, --lowmem          enable low mem mode, but use more CPU

./emqtt_bench sub -c 50000 -i 10 -t bench/%i -q 2

$ ./emqtt_bench pub --helpUsage: emqtt_bench pub [--help <help>] [-h [<host>]] [-p [<port>]]                       [-V [<version>]] [-c [<count>]]                       [-n [<startnumber>]] [-i [<interval>]]                       [-I [<interval_of_msg>]] [-u <username>]                       [-P <password>] [-t <topic>] [-s [<size>]]                       [-q [<qos>]] [-r [<retain>]] [-k [<keepalive>]]                       [-C [<clean>]] [-x [<expiry>]] [-L [<limit>]]                       [-S [<ssl>]] [--certfile <certfile>]                       [--keyfile <keyfile>] [--ws [<ws>]]                       [--quic [<quic>]] [--ifaddr <ifaddr>]                       [--prefix <prefix>] [-l <lowmem>]  --help                 help information  -h, --host             mqtt server hostname or IP address [default:                         localhost]  -p, --port             mqtt server port number [default: 1883]  -V, --version          mqtt protocol version: 3 | 4 | 5 [default: 5]  -c, --count            max count of clients [default: 200]  -n, --startnumber      start number [default: 0]  -i, --interval         interval of connecting to the broker [default: 10]  -I, --interval_of_msg  interval of publishing message(ms) [default: 1000]  -u, --username         username for connecting to server  -P, --password         password for connecting to server  -t, --topic            topic subscribe, support %u, %c, %i variables  -s, --size             payload size [default: 256]  -q, --qos              subscribe qos [default: 0]  -r, --retain           retain message [default: false]  -k, --keepalive        keep alive in seconds [default: 300]  -C, --clean            clean start [default: true]  -x, --session-expiry   Set 'Session-Expiry' for persistent sessions                         (seconds) [default: 0]  -L, --limit            The max message count to publish, 0 means                         unlimited [default: 0]  -S, --ssl              ssl socoket for connecting to server [default:                         false]  --certfile             client certificate for authentication, if                         required by server  --keyfile              client private key for authentication, if                         required by server  --ws                   websocket transport [default: false]  --quic                 QUIC transport [default: false]  --ifaddr               One or multiple (comma-separated) source IP                         addresses  --prefix               client id prefix  -l, --lowmem           enable low mem mode, but use more CPU

./emqtt_bench pub -c 100 -I 10 -t bench/%i -s 256

./emqtt_bench pub --ifaddr 192.168.1.10./emqtt_bench sub --ifaddr 192.168.2.10

./emqtt_bench sub -c 100 -i 10 -t bench/%i -p 8883 -S./emqtt_bench pub -c 100 -I 10 -t bench/%i -p 8883 -s 256 -S

./emqtt_bench sub -c 100 -i 10 -t bench/%i -p 8883 --certfile path/to/client-cert.pem --keyfile path/to/client-key.pem./emqtt_bench pub -c 100 -i 10 -t bench/%i -s 256 -p 8883 --certfile path/to/client-cert.pem --keyfile path/to/client-key.pem

./emqtt_bench sub -c 200000 -t "perf/test" --ifaddr 192.168.200.18,192.168.200.19,192.168.200.20,192.168.200.21

ulimit -n 200000sudo sysctl -w net.ipv4.ip_local_port_range="1025 65534"