多种方式测试redis入库性能

? ? Transaction Pipeline 耗时（s） 测试一： N N 311 测试二： N Y 10 测试三： Y Y 7 测试四： Y N 10 ? 结论：Pipeline + Transaction方式是几种插入方式中性能最好的。虽然有点意外，但测试多次仍然是这个结论。 ? 测试代码如下： ? import org.apache.

?

?

结论：Pipeline + Transaction方式是几种插入方式中性能最好的。虽然有点意外，但测试多次仍然是这个结论。

?

测试代码如下：

?

import org.apache.commons.lang.RandomStringUtils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.Pipeline;
import redis.clients.jedis.Transaction;
public class RedisTransactionTest {
	private static String host = "xx.xx.xx.xx";
	private static JedisPool pool = new JedisPool(new JedisPoolConfig(), host);
	private long rowCount = 1000000; // 100万
	public static void main(String[] args) {
	long start = System.currentTimeMillis();
	new RedisTransactionTest().noTransactionNoPipeline();
	System.out.println("noTransactionNoPipeline use " + (System.currentTimeMillis() - start) / 1000);
	pool = new JedisPool(new JedisPoolConfig(), host);
	start = System.currentTimeMillis();
	new RedisTransactionTest().pipelineWithoutTransaction();
	System.out.println("pipelineWithoutTransaction use " + (System.currentTimeMillis() - start) / 1000);
	pool = new JedisPool(new JedisPoolConfig(), host);
	start = System.currentTimeMillis();
	new RedisTransactionTest().pipelineWithTransaction();
	System.out.println("pipelineWithTransaction use " + (System.currentTimeMillis() - start) / 1000);
	pool = new JedisPool(new JedisPoolConfig(), host);
	start = System.currentTimeMillis();
	new RedisTransactionTest().transactionNoPipeline();
	System.out.println("transactionNoPipeline use " + (System.currentTimeMillis() - start) / 1000);
	}
	public void pipelineWithoutTransaction() {
	Jedis jedis = pool.getResource();
	try {
	Pipeline p = jedis.pipelined();
	for (int i = 0; i < rowCount; i++) {
	String key = RandomStringUtils.randomAlphabetic(8);
	p.set(key, RandomStringUtils.randomNumeric(5));
	p.expire(key, 5 * 60);
	}
	p.sync();
	} catch (Exception e) {
	pool.returnResource(jedis);
	}
	}
	public void pipelineWithTransaction() {
	Jedis jedis = pool.getResource();
	try {
	Pipeline p = jedis.pipelined();
	p.multi();
	for (int i = 0; i < rowCount; i++) {
	String key = RandomStringUtils.randomAlphabetic(8);
	p.set(key, RandomStringUtils.randomNumeric(5));
	p.expire(key, 5 * 60);
	}
	p.exec();
	p.sync();
	} catch (Exception e) {
	pool.returnResource(jedis);
	}
	}
	public void noTransactionNoPipeline() {
	Jedis jedis = pool.getResource();
	try {
	for (int i = 0; i < rowCount; i++) {
	String key = RandomStringUtils.randomAlphabetic(8);
	jedis.set(key, RandomStringUtils.randomNumeric(5));
	jedis.expire(key, 5 * 60);
	}
	} catch (Exception e) {
	pool.returnResource(jedis);
	}
	}
	public void transactionNoPipeline() {
	Jedis jedis = pool.getResource();
	try {
	Transaction tx = jedis.multi();
	for (int i = 0; i < rowCount; i++) {
	String key = RandomStringUtils.randomAlphabetic(8);
	tx.set(key, RandomStringUtils.randomNumeric(5));
	tx.expire(key, 5 * 60);
	}
	tx.exec();
	} catch (Exception e) {
	pool.returnResource(jedis);
	}
	}
}

?--end

?

?

原文地址：多种方式测试redis入库性能, 感谢原作者分享。