RabbitMQ Performance App
A simple way to test the performance of your RabbitMQ Service
This project uses the RabbitMQ Performance Testing Tool to run benchmarks and to graph the results. I created a simple spring app that gives you an easy way to run benchmarks and graph results from the convenience of your browser!
Run the Web App Server
Docker
docker pull johnlonganecker/rmq-perf-app
docker run -p 8080:8080 johnlonganecker/rmq-perf-app
Command Line
Download latest release
java -jar rmq-perf-app.jar
Cloud Foundry
mvn install
cf push
cf bind-service rabbitmq-perf-app rmq-service
cf restage rabbitmq-perf-app
Releases
Download from the releases page
Compile and Package
Have Maven and Java Installed
mvn install
mvn package
Take it out for a spin
If you don't have a rabbitmq service running you can run one with docker
docker pull rabbitmq
docker run -d -p 5672:5672 rabbitmq
Run the RabbitMQ Performance App
java -jar rmq-perf-app.jar
The server will use rabbitmq's default URI to connect to the docker container. If you need to set your own URI read below.
You can find the WebApp at localhost:8080
Enter a performance Scenario config
and how you want to graph it by setting the Graph Config
You can find the documentation for both scenarios and graphs from this repo
Example Configs
Scenario
{
"name": "no-ack",
"type": "simple",
"params": [{"time-limit": 10}]
}
Graph
{
"type": "chart",
"fields": {
"data-type":"time",
"data-x-axis":"time (s)",
}
}
{
"type": "small-chart",
"fields": {
"data-type":"time",
"data-x-axis":"time (s)",
}
}
{
"type": "summary",
"fields": {}
}
Scenario
{
"name": "message-sizes-and-producers",
"type": "varying",
"params": [{"time-limit": 30,
"consumer-count": 0}],
"variables": [{"name": "min-msg-size",
"values": [0, 1000, 10000, 100000]},
{"name": "producer-count",
"values": [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]}]
}
Graph
{
"type": "chart",
"fields": {
"data-type": "series",
"data-x-key":"producerCount",
"data-x-axis":"producers",
"data-y-axis":"rate (msg/s)",
"data-plot-key":"send-msg-rate",
"data-series-key":"minMsgSize"
}
}
Scenario
{
"name": "message-sizes-large",
"type": "varying",
"params": [{"time-limit": 30}],
"variables": [{"name": "min-msg-size",
"values": [5000, 10000, 50000, 100000, 500000, 1000000]}]
}
Graph
{
"type": "chart",
"fields": {
"data-type": "x-y",
"data-x-key":"minMsgSize",
"data-plot-keys":"send-msg-rate send-bytes-rate",
"data-x-axis":"message size (bytes)",
"data-y-axis":"rate (msg/s)",
"data-y-axis2":"rate (bytes/s)",
"data-legend":"ne"
}
}
Scenario
{
"name": "rate-vs-latency",
"type": "rate-vs-latency",
"params": [{"time-limit": 30}]
}
Graph
{
"type": "chart",
"fields": {
"data-type":"r-l",
"data-x-axis":"rate attempted (msg/s)",
"data-y-axis":"rate (msg/s)"
}
}
Where do the host/user/pass/vhost get set?
In the scenario config
you can specify a uri
like this:
"uri": "amqp://user:password@host:port/vhost"
Cloud Foudry
If you bind a rabbitmq service (based on pivotal's rabbitmq release) to this app it will automatically get the credentials it needs to interact with rabbitmq.
You can of course override those credentials by adding the uri
field to the scenario config
Defaults
If no credentials are provided this app will use a default rabbitmq uri
to connect to the service
Report Bugs or Feature Requests
Submit a github issue
Contribute
Feel free to do something cool or grab something from the Todo list and just submit a Pull Request :)
ToDo
- Make a bunch of useful examples
- when creating new row have dialog box with pre-made exampels
- examples endpoint (list examples for dialog box)
- Make http server ports configurable through CLI
- unit/smoke/integration tests
- web app
- spring server
- Better Errors
- UI Display
- Messages from server
- Store results
- export results
- import results
- save results to PG/MySQL/other DB
- store info of system with results?
- number of nodes
- policy
- hostname (not full uri)