ActiveMQ性能测试

工作之余，公司想对ActiveMQ进行一番性能测试，

测试环境：

 硬盘：1T,5400  (效果不佳)

 

 

得出了一个异样的测试结果：

 

持久： 

插入200000条JSON，共消耗：25.175 s

平均：7944.389275074478 条/秒

 

插入200000条JSON，共消耗：34.47 s

平均：5802.146794313896 条/秒

 

插入200000条JSON，共消耗：29.937 s数量：1400000

平均：6680.696128536593 条/秒

 

插入200000条JSON，共消耗：29.094 s

平均：6874.269608854059 条/秒

 

 

 

非持久：

插入200000条JSON，共消耗：11.35 s数量：1800000

平均：17621.14537444934 条/秒

 

插入200000条JSON，共消耗：10.714 s

平均：18667.16445771887 条/秒

 

插入200000条JSON，共消耗：11.153 s

平均：17932.394871335066 条/秒

 

插入200000条JSON，共消耗：10.717 s数量：2400000

平均：18661.93897545955 条/秒

 

 

主要在自己本地测试，最终祸首是硬盘不给力啊；

在进行持久化操作时，ActiveMQ默认是kahadb管理

log的默认大小是32MB,当超过之后会新建一个新的log文件，完成操作后，activeMQ又将旧的log删除了。

 

 

 

代码贴上：

public class Sender {

	static int size = 200000;
	static Session session;
	static MessageProducer producer;
	static Topic topic;
	static Connection connection;
	static String str = "[{'flag':'1','value':'8854c92e92404b188e63c4031db0eac9','label':'交换机(虚机)'},{'flag':'1','value':'3f367296c2174b7981342dc6fcb39d64','label':'防火墙'},{'flag':'1','value':'8a3e05eeedf54f8cbed37c6fb38c6385','label':'负载均衡'},{'flag':'1','value':'4f0ebc601dfc40ed854e08953f0cdce8','label':'其他设备'},{'flag':'1','value':'6','label':'路由器'},{'flag':'1','value':'4','label':'交换机'},{'flag':'1','value':'b216ca1af7ec49e6965bac19aadf66da','label':'服务器'},{'flag':'1','value':'7','label':'安全设备'},{'flag':'1','value':'cd8b768a300a4ce4811f5deff91ef700','label':'DWDM\\SDH'},{'flag':'1','value':'5','label':'防火墙(模块)'},{'flag':'1','value':'01748963956649e589a11c644d6c09b5','label':'机箱'}]";

	public static void init_connection() throws Exception {
		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
		connection = factory.createConnection();
		connection.start();
		session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		topic = session.createTopic("java.activemq.tps");
		producer = session.createProducer(topic);
		producer.setDeliveryMode(DeliveryMode.PERSISTENT);
	}

	public static void sendMessage(String msg) {
		TextMessage message;
		try {
			message = session.createTextMessage();
			message.setText(str);
			producer.send(message);
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}

	public static void close() throws Exception {
		connection.close();
	}

	public static void main(String[] arg) throws Exception {
		long start = System.currentTimeMillis();
		ExecutorService es = Executors.newFixedThreadPool(10);
		final CountDownLatch cdl = new CountDownLatch(size);
		init_connection();
		for (int a = 0; a < size; a++) {
			es.execute(new Runnable() {
				@Override
				public void run() {
					sendMessage(str);
					cdl.countDown();
				}
			});
		}
		cdl.await();
		es.shutdown();
		long time = System.currentTimeMillis() - start;
		System.out.println("插入" + size + "条JSON，共消耗：" + (double)time / 1000 + " s");
		System.out.println("平均：" + size / ((double)time/1000) + " 条/秒");
		close();
	}
}

 

 

 

评论

3 楼 youarepp 2016-01-13  

用PC测单个，差不多了，现网的环境服务器肯定更好，而且还可以做集群，水平拓展这都不是问题

2 楼 sbl2255 2014-12-22  

milanACmilan 写道

问个问题：测试时activeMQ的配置文件和启动脚本中的JVM参数是否有改动？有的话，是怎么改动的？

优化JVM资料很多的，这里都是默认配置，性能这东西我觉得硬件才是王道。

1 楼 milanACmilan 2014-12-18  

问个问题：测试时activeMQ的配置文件和启动脚本中的JVM参数是否有改动？有的话，是怎么改动的？