ActiveMQのパフォーマンスを検証する（その２）

カテゴリー： Javaチューニング, Webサイト開発日記

パフォーマンスを図る為にループ回数を変えつつ5回連続して実行させてみます。
5回連続実行の間、MessageBrokerのメッセージクリアせず、TestJmsServer2は順次メッセージの取得を行っています。

TestJmsLoop5.java

PLAIN TEXT

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 TestJmsLoop5 {
public static void main(String[] args){
for (int i = 0; i <5; i++) {
loops();
}
}
public static void loops() {
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("tmaru@inter-xxxx.com");
mailMessage.setToAddr("tmaru2@inter-xxxx.com");
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) );
}
}