性能测试

    的运行依赖于 Erlang/OTP 21.2 以上版本运行环境，安装过程略过，详情请参考网上各个安装教程。

    Erlang 环境安装完成后，下载 emqtt-bench 最新代码，并编译：

    编译完成后，当前目录下会生成 一个名为emqtt_bench 的可执行脚本。执行以下命令，确认其能正常使用：

    1. ./emqtt_bench
    2. Usage: emqtt_bench pub | sub | conn [--help]

    输出以上内容，则证明 emqtt_bench 已正确安装到主机。

    emqtt_bench 共三个子命令：

    1. pub：用于创建大量客户端执行发布消息的操作。
    2. sub：用于创建大量客户端执行订阅主题，并接受消息的操作。

    执行 ./emqtt_bench pub --help 会得到可用的参数输出，此处整理：

    例如，我们启动 10 个连接，分别每秒向主题 t 发送 100 条 Qos0 消息，其中每个消息体的大小为 16 字节大小：

    1. ./emqtt_bench pub -t t -h emqx-server -s 16 -q 0 -c 10 -I 10

    订阅

    执行 ./emqtt_bench sub --help可得到该子命令的所有的可用参数。它们的解释已包含在上表中，此处略过。

    例如，我们启动 500 个连接，每个都以 Qos0 订阅 t 主题：

    1. ./emqtt_bench sub -t t -h emqx-server -c 500

    连接

    例如，我们启动 1000 个连接：

    1. ./emqtt_bench conn -h emqx-server -c 1000

    emqtt_bench 支持建立 SSL 的安全连接，并执行测试。

    单向证书，例如：

    双向证书，例如：

    1. ./emqtt_bench sub -c 100 -i 10 -t bench/%i -p 8883 --certfile path/to/client-cert.pem --keyfile path/to/client-key.pem
    2. ./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

    场景说明

    此处我们以 2 类最典型的场景来验证工具的使用：

    1. 连接量：使用 emqtt_bench 创建百万连接到 EMQX Broker。
    2. 吞吐量：使用 emqtt_bench 在 EMQX 中创建出 10W/s 的 Qos0 消息吞吐量。

    机器及部署拓扑图

    共需准备三台 8C16G 服务器，一台为 EMQX Broker，两台为 客户端压力机。其中：

    • 系统: CentOS Linux release 7.7.1908 (Core)

    • CPU: Intel Xeon Processor (Skylake) 主频: 2693.670 MHZ

    • 服务端： emqx-centos7-v4.0.2.zip

      • 每台压力机分别配置 10 张网卡，用于连接测试中建立大量的 MQTT 客户端连接

    拓扑结构如下：

    1.     +-----------------------+
    2.     | bench1: 192.168.0.100 | -------                    +--------------------------+
    3.     +-----------------------+        \----->  |            EMQX Broker             |
    4.     +-----------------------+        /----->  |       192.168.0.99           |
    5.     +-----------------------+

    客户端的压力机和服务端的机器都需要执行系统参数的调优，参见：系统调优

    连接量测试

    在执行完系统调优后，首先启动服务端：

    1. ./bin/emqx start

    然后在 上的每张网卡上启动 5w 的连接数，共计 50w 的连接：

    2. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.100
    3. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.101
    4. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.102
    5. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.103
    6. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.104
    7. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.105
    8. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.106
    9. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.107
    10. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.108
    11. ./emqtt_bench -h 192.168.0.99 -c 50000 --ifaddr 192.168.0.109

    在 bench2上也执行同样的操作。

    在所有连接建立完成后，执行 ./bin/emqx_ctl listeners，并找到以下的内容， 查看 EMQX 中连接数的信息：

    吞吐测试

    同样的，首先启动服务端：

    1. ./bin/emqx start

    在 bench1 启动 500 个订阅客户端：

    1. ./emqtt_bench sub -t t -h 192.168.0.99 -c 500

    然后再 bench2 上启动 20 个发布端，并且每秒发布 10 条消息：

    1. ./emqtt_bench pub -t t -h 192.168.0.99 -c 20 -I 100