测试目的

测试EMQX企业版4.3.5单节点每秒10万QoS 1、payload 1KB的消息桥接至Kafka集群所需EMQX资源及响应时间等性能指标。

测试架构

EMQX 桥接 Pulsar 测试架构

测试环境、机器配置及测试工具

测试环境: 华为云 北京四区

测试工具: XMeter企业版v3.0

EMQX、Kafka集群配置、测试机配置

服务 数量 版本 操作系统 CPU 内存 云主机型号
EMQX 1 企业版v4.3.6 Centos 7.8 32核 64G C6.8xlarge2
Pulsar 1 2.8.1 Centos 7.8 16核 64G C6.4xlarge4
XMeter管理机 2 3.2.0 Centos 7.8 8核 16G C6.2xlarge2
XMeter压力机 10 / Centos 7.8 8核 16G C6.2xlarge2

测试场景

如测试架构图中所示,XMeter压力机模拟10万MQTT客户端向EMQX发起连接,新增连接速率为每秒2000,客户端心跳间隔(keep alive)300秒。所有连接成功后每个客户端每秒发送一条QoS为1、payload为1kB的消息,所有消息通过规则引擎桥接转发至Pulsar单节点。

测试执行1个小时,规则引擎配置如下。

Pulsar资源设置

Pulsar资源设置

规则设置

规则设置

Pulsar主题为10个分区,1个副本

Pulsar主题

测试结果

具体测试结果及EMQX资源使用截图如下:

EMQX Dashboard统计

EMQX Dashboard统计

EMQX节点资源使用

EMQX节点资源使用

详细测试结果

详细测试结果及系统调优脚本请填写右侧表单获取完整版 PDF 文件。

想要获取完整版?

下载地址将会发送至您填写的邮箱