rocketmq-benchmark

本地安装

下载对应版本的 all bin 正式包。

wget -c https://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip

发送消息脚本说明

benchmark/目录下

sh producer.sh -h

-k 是否使用message key，true则使用timestamp作为message的key

-n 指定nameserver地址， 例如：192.168.31.205:9876;192.168.31.206:9876;192.168.31.207:9876

-q 发送信息的条数，默认为0一直发送。

-s 指定消息大小，默认128字节

-t 指定topic，默认使用BenchmarkTest，如果指定其他记得先创建对应的topic

-w 开启的发送生产消息的线程数

发送消息基准测试

消息大小（字节）：2027

线程数：128

sh producer.sh \
-n "172.16.1.4:9876;172.16.1.16:9876;172.16.1.31:9876" \
-k true -s 2027 -t BenchmarkTest -w 128