No description, website, or topics provided.
Java
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
src/info/jeffkit/rabbitmq
README

README

本项目用于对rabbitmq做性能测试。使用rabbitMQ的java 客户API。

依赖包:
commons-cl-1.1.jar
commons-io-1.2.jar
rabbitmq-client.jar

使用方法:

一、入队列测试命令:
cd rabbitmq-benchmark/bin/
java -cp .:../lib/commons-io-1.2.jar:../lib/commons-cli-1.1.jar:../lib/rabbitmq-client.jar info.jeffkit.rabbitmq.benchmark.Producer
接受下面四个参数:

1、队列名,默认为single。
2、每条消息大小,,默认值为1kByte。
3、消息是否持久化,默认为不持久化。
4、发送消息总条数,默认为10万条消息。
使用示例:Producer myqueue 1024 true 100000

二、出队测试命令:
cd rabbitmq-benchmark/bin/
java -cp .:../lib/commons-io-1.2.jar:../lib/commons-cli-1.1.jar:../lib/rabbitmq-client.jar info.jeffkit.rabbitmq.benchmark.Consumer
接受下面5个参数:
一、队列名,默认为single。
二、消费者个数,默认为1个,每个消费者使用一条线程。
三、QOS,表示每消费者同一时间能接收到消息数,默认为0,即无限制。
四、autoAck,默认为true,即自动发送回执,无事务。
五、是否持久化,默认为否。
使用示例 :Consumer myqueue 2 10 true true