ActiveMQのパフォーマンスを検証する

JMSによる非同期処理の実装に引き続き、ActiveMQのパフォーマンスを検証してみたいと思います。

アプリケーションのパフォーマンスを計るため、MessageBroker とメッセージを処理するAPを別のPCで実行させる事にします。

TestJmsServer2.java
前回のTestJmsServerではメールを送信させていましたが、負荷テストでそれをやってしまうとメールサーバーが大変な事になってしまうので、変わりに1メッセージ辺り1秒のウェイトを入れる事にします。
また、処理したメッセージをコンソールに出力させます。

JAVA:

package test.server;
import javax.jms.JMSException;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import test.TestMessage;
public class TestJmsServer2 {
public static boolean bQuit = false;
public static void main(String[] args) {
QueueConnection connection = null;
QueueSession session = null;
QueueReceiver receiver = null;
try{
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
connection = factory.createQueueConnection();
session = connection.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("TestMailQueue");
receiver = session.createReceiver(queue);
connection.start();
while(!bQuit) {
ObjectMessage msg = (ObjectMessage)receiver.receive();
TestMessage mailMessage = (TestMessage)msg.getObject();
System.out.println(mailMessage.getMessage());
try {
Thread.sleep(1000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
}
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
if (receiver != null) {
receiver.close();
}
if (session != null) {
session.close();
}
if (connection != null) {
connection.close();
}
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}

TestJmsLoop.java
呼出側は1000回のメッセージをノーウェイトで実行させます。
また、個々のメッセージを識別出来る様にメッセージにループのインデックスを渡しています。

JAVA:

package test;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import org.apache.activemq.ActiveMQConnectionFactory;
public class TestJmsLoop {
public static void main(String[] args){
long startTime = System.currentTimeMillis();
QueueConnection connection = null;
QueueSession session = null;
QueueSender sender = null;
try {
QueueConnectionFactory factory = new ActiveMQConnectionFactory("tcp://MessageBrokerのアドレス:61616");
connection = factory.createQueueConnection();
session = connection.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("TestMailQueue");
sender= session.createSender(queue);
connection.start();
for (int i = 0; i <1000; i++) {
TestMessage mailMessage = new TestMessage();
mailMessage.setSubject("ActiveMQ test");
mailMessage.setFromAddr("送信者アドレス");
mailMessage.setToAddr("受信者アドレス");
mailMessage.setMessage("メールのテストです。:" + i);
Message msg = session.createObjectMessage(mailMessage);
sender.send(msg);
}
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
if (sender != null) {
sender.close();
}
if (session != null) {
session.close();
}
if (connection != null) {
connection.close();
}
} catch (JMSException e) {
e.printStackTrace();
}
}
long endTime = System.currentTimeMillis();
System.out.println( "TestJms:" + (endTime - startTime) );
}
}