| #!/bin/sh |
| # |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| # |
| |
| # This will run the following test cases defined below and produce |
| # a report in tabular format. |
| |
| QUEUE="queue;{create:always,node:{x-declare:{auto-delete:true}}}" |
| DURA_QUEUE="dqueue;{create:always,node:{durable:true,x-declare:{auto-delete:true}}}" |
| TOPIC="amq.topic/test" |
| DURA_TOPIC="amq.topic/test;{create:always,link:{durable:true}}" |
| |
| COMMON_CONFIG="-server -Durl=amqp://guest:guest@clientid/testpath?brokerlist='tcp://localhost:5672'" |
| |
| waitfor() { until grep -a -l "$2" $1 >/dev/null 2>&1 ; do sleep 1 ; done ; } |
| cleanup() |
| { |
| pids=`ps aux | grep java | grep Perf | awk '{print $2}'` |
| if [ "$pids" != "" ]; then |
| kill -3 $pids |
| kill -9 $pids >/dev/null 2>&1 |
| fi |
| } |
| |
| # $1 test name |
| # $2 consumer options |
| # $3 producer options |
| run_testcase() |
| { |
| sh run-sub $COMMON_CONFIG $2 > sub.out & |
| sh run-pub $COMMON_CONFIG $3 > pub.out & |
| waitfor pub.out "Controller: Completed the test" |
| sleep 2 #give a grace period to shutdown |
| print_result $1 |
| mv pub.out $1.pub.out |
| mv sub.out $1.sub.out |
| } |
| |
| print_result() |
| { |
| prod_rate=`cat pub.out | grep "Avg Producer rate" | awk '{print $5}'` |
| sys_rate=`cat pub.out | grep "System Throughput" | awk '{print $4}'` |
| cons_rate=`cat pub.out | grep "Avg Consumer rate" | awk '{print $5}'` |
| avg_latency=`cat pub.out | grep "Avg System Latency" | awk '{print $5}'` |
| min_latency=`cat pub.out | grep "Min System Latency" | awk '{print $5}'` |
| max_latency=`cat pub.out | grep "Max System Latency" | awk '{print $5}'` |
| |
| printf "|%-15s|%15.2f|%13.2f|%13.2f|%11.2f|%11.2f|%11.2f|\n" $1 $sys_rate $prod_rate $cons_rate $avg_latency $min_latency $max_latency |
| echo "------------------------------------------------------------------------------------------------" |
| } |
| |
| trap cleanup EXIT |
| rm -rf *.out #cleanup old files. |
| |
| echo "Test report on " `date +%F` |
| echo "================================================================================================" |
| echo "|Test |System throuput|Producer rate|Consumer Rate|Avg Latency|Min Latency|Max Latency|" |
| echo "------------------------------------------------------------------------------------------------" |
| |
| # The message counts and warmup counts are set to very low values for quick testing of the script. |
| # For a real performance run I recommend setting warmup count to 10k and message count in excess of 100k |
| # However for transactions, sync_publish and especially small durable transactions (which is quite slow) I recommend |
| # setting very low values to start with and experiment while increasing them slowly. |
| |
| # Test 1 Trans Queue |
| run_testcase "Trans_Queue" "-Daddress=$QUEUE" "-Daddress=$QUEUE -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 2 Dura Queue |
| run_testcase "Dura_Queue" "-Daddress=$DURA_QUEUE -Ddurable=true" "-Daddress=$DURA_QUEUE -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 3 Dura Queue Sync |
| run_testcase "Dura_Queue_Sync" "-Daddress=$DURA_QUEUE -Ddurable=true" "-Daddress=$DURA_QUEUE -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10 -Dsync_publish=persistent" |
| |
| # Test 4 Dura Queue Sync Publish and Ack |
| run_testcase "Dura_SyncPubAck" "-Daddress=$DURA_QUEUE -Ddurable=true -Dsync_ack=true" "-Daddress=$DURA_QUEUE -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10 -Dsync_publish=persistent" |
| |
| # Test 5 Topic |
| run_testcase "Topic" "-Daddress=$TOPIC" "-Daddress=$TOPIC -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 6 Durable Topic |
| run_testcase "Dura_Topic" "-Daddress=$DURA_TOPIC -Ddurable=true" "-Daddress=$DURA_TOPIC -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 7 Fanout |
| run_testcase "Fanout" "-Daddress=amq.fanout" "-Daddress=amq.fanout -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 8 Small TX |
| run_testcase "Small_Txs_2" "-Daddress=$DURA_QUEUE -Ddurable=true -Dtransacted=true -Dtrans_size=1" \ |
| "-Daddress=$DURA_QUEUE -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10 -Dtransacted=true -Dtrans_size=1" |
| |
| # Test 9 Large TX |
| run_testcase "Large_Txs_1000" "-Daddress=$DURA_QUEUE -Ddurable=true -Dtransacted=true -Dtrans_size=10" \ |
| "-Daddress=$DURA_QUEUE -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10 -Dtransacted=true -Dtrans_size=10" |
| |
| # Test 10 256 MSG |
| run_testcase "Msg_256b" "-Daddress=$QUEUE" "-Daddress=$QUEUE -Dmsg_size=256 -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 11 512 MSG |
| run_testcase "Msg_512b" "-Daddress=$QUEUE" "-Daddress=$QUEUE -Dmsg_size=512 -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 12 2048 MSG |
| run_testcase "Msg_2048b" "-Daddress=$QUEUE" "-Daddress=$QUEUE -Dmsg_size=2048 -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 13 Random size MSG |
| run_testcase "Random_Msg_Size" "-Daddress=$QUEUE" "-Daddress=$QUEUE -Drandom_msg_size=true -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 14 Random size MSG Durable |
| run_testcase "Rand_Msg_Dura" "-Daddress=$DURA_QUEUE -Ddurable=true" "-Daddress=$DURA_QUEUE -Ddurable=true -Drandom_msg_size=true -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 15 64K MSG |
| run_testcase "Msg_64K" "-Daddress=$QUEUE -Damqj.tcpNoDelay=true" "-Daddress=$QUEUE -Damqj.tcpNoDelay=true -Dmsg_size=64000 -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 16 Durable 64K MSG |
| run_testcase "Msg_Durable_64K" "-Daddress=$DURA_QUEUE -Ddurable=true -Damqj.tcpNoDelay=true" \ |
| "-Daddress=$DURA_QUEUE -Damqj.tcpNoDelay=true -Dmsg_size=64000 -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 17 500K MSG |
| run_testcase "Msg_500K" "-Daddress=$QUEUE -Damqj.tcpNoDelay=true" "-Daddress=$QUEUE -Damqj.tcpNoDelay=true -Dmsg_size=500000 -Dwarmup_count=1 -Dmsg_count=10" |
| |
| # Test 18 Durable 500K MSG |
| run_testcase "Msg_Dura_500K" "-Daddress=$DURA_QUEUE -Damqj.tcpNoDelay=true -Ddurable=true" \ |
| "-Daddress=$DURA_QUEUE -Damqj.tcpNoDelay=true -Dmsg_size=500000 -Ddurable=true -Dwarmup_count=1 -Dmsg_count=10" |