更新时间:2024-05-14 GMT+08:00
分享

测试5.x版本RocketMQ实例性能

测试场景

本章节主要测试RocketMQ实例5.x版本不同产品规格在发送1KB大小的消息时,实例的生产速率、消费速率和平均生产时延。

测试环境

进行测试前,您需要先构建如下的测试环境:

  1. 购买如表1所示实例,购买步骤请参考购买实例
    表1 实例参数

    名称

    规格

    存储空间

    ACL访问

    公网访问

    rocketmq-01

    rocketmq.b2.large.4

    超高I/O 300GB

    关闭

    关闭

    rocketmq-02

    rocketmq.b2.large.8

    超高I/O 300GB

    关闭

    关闭

    rocketmq-03

    rocketmq.b2.large.12

    超高I/O 300GB

    关闭

    关闭

  2. 创建如表2所示Topic,创建步骤请参考创建Topic
    表2 Topic参数

    名称

    消息类型

    topic-01

    普通

  3. 创建如表3所示消费组,创建步骤请参考创建消费组
    表3 消费组参数

    名称

    最大重试次数

    是否允许以广播模式消费

    是否顺序消费

    group-01

    16

  4. 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器
  5. 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。
    export JAVA_HOME=/root/jdk1.8.0_231 
    export PATH=$JAVA_HOME/bin:$PATH
  6. 下载测试工具。
    wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip
  7. 解压测试工具。
    unzip rocketmq-all-5.1.4-bin-release.zip

测试命令

生产命令:

sh producer.sh -n "${连接地址}" -t ${Topic名称} -s ${消息大小} -w ${生产者线程数}
  • 连接地址:购买RocketMQ实例后,获取实例的连接地址。
  • Topic名称:创建Topic时设置的Topic名称。
  • 消息大小:1KB
  • 生产者线程数:256

消费命令:

sh consumer.sh -n "${连接地址}" -t ${Topic名称} -g ${消费组名称}

测试结果

表4 测试结果

性能指标

rocketmq.b2.large.4

rocketmq.b2.large.8

rocketmq.b2.large.12

实例生产速率

1008.500 Count/s

2019.710 Count/s

3011.640 Count/s

实例消费速率

1008.520 Count/s

2019.710 Count/s

3010.590 Count/s

平均生产时延

26.336 ms

8.788 ms

5.876 ms

分享:

    相关文档

    相关产品