【每日一记10】+第4天:RabbitMQ吞吐量测试-PerfTest

安装

PerfTest也是从Bintray和 GitHub发布的二进制版本库中分发的 。 如果需要将它作为库，也可以在Maven Central上使用。

Bintray:https://bintray.com/rabbitmq/java-tools/perf-test

GitHub:https://github.com/rabbitmq/rabbitmq-perf-test/releases

要验证PerfTest安装，请使用

bin/runjava com.rabbitmq.perf.PerfTest --help

can@can:/usr/local/mq/rabbitmq_server-3.6.14/rabbitmq-perf-test-2.0.0.RC4$ bin/runjava com.rabbitmq.perf.PerfTest --help

usage: <program>

-?,--help show usage

-A,--multi-ack-every <arg> multi ack every

-a,--autoack auto ack

-ad,--auto-delete <arg> should the queue be auto-deleted,

default is true

-B,--body <arg> comma-separated list of files to use

in message bodies

-b,--heartbeat <arg> heartbeat interval

-C,--pmessages <arg> producer message count

-c,--confirm <arg> max unconfirmed publishes

-ct,--confirm-timeout <arg> waiting timeout for unconfirmed

publishes before failing (in seconds)

-D,--cmessages <arg> consumer message count

-d,--id <arg> test ID

-e,--exchange <arg> exchange name

-f,--flag <arg> message flag

-H,--uris <arg> connection URIs (separated by commas)

-h,--uri <arg> connection URI

-i,--interval <arg> sampling interval in seconds

-K,--random-routing-key use random routing key per message

-k,--routing-key <arg> routing key

-L,--consumer-latency <arg> consumer latency in microseconds

-l,--legacy-metrics display legacy metrics (min/avg/max

latency)

-M,--framemax <arg> frame max

-m,--ptxsize <arg> producer tx size

-ms,--use-millis should latency be collected in

milliseconds, default is false. Set to true if producers are consumers run

on different machines.

-n,--ctxsize <arg> consumer tx size

-o,--output-file <arg> output file for timing results

-p,--predeclared allow use of predeclared objects

-Q,--global-qos <arg> channel prefetch count

-q,--qos <arg> consumer prefetch count

-qa,--queue-args <arg> queue arguments as key/pair values,

separated by commas

-R,--consumer-rate <arg> consumer rate limit

-r,--rate <arg> producer rate limit

-S,--slow-start start consumers slowly (1 sec delay

between each)

-s,--size <arg> message size in bytes

-sb,--skip-binding-queues don't bind queues to the exchange

-T,--body-content-type <arg> body content-type

-t,--type <arg> exchange type

-u,--queue <arg> queue name

-udsc,--use-default-ssl-context use JVM default SSL context

-X,--producer-channel-count <arg> channels per producer

-x,--producers <arg> producer count

-Y,--consumer-channel-count <arg> channels per consumer

-y,--consumers <arg> consumer count

-z,--time <arg> run duration in seconds (unlimited by default)

./runjava com.rabbitmq.perf.PerfTest -h amqp://root:root@192.168.101.187:5672 -x 1 -y 1 -u "throughput-test-3" -a --id "test 3" -C 500000

选项说明：

-x,--producers <arg> producer count（生产者数量）

-y,--consumers <arg> consumer count（消费者数量）

-u,--queue <arg> queue name（队列名称）

-a,--autoack auto ack，客户端在处理完messages之后会给服务端返回一个ack确认信息，服务端在收到该ack信息之后才会把messages删除；

-d,--id <arg> test ID（本次测试的编号，身份标识）

-C,--pmessages <arg> producer message count（生产者要生成的消息的数量，译者注：在此次性能测试中，生产者一旦生成了指定数量的消息，就会停止）