redis使用pipeline批量插入hash数据
import org.apache.commons.lang.math.RandomUtils;import redis.clients.jedis.Jedis;import redis.clients.jedis.Pipeline;public class RedisEasyTest {private static Jedis jedis = new Jedis("xx.xx.xx.xx");private static Pipeline p = jedis.pipelined();private static int KEY_COUNT = 10000;private static int FIELD_COUNT = 10;public void single() {for (int i = 0; i < KEY_COUNT; i++) {String key = RandomUtils.nextInt(5) + "";for (int j = 0; j < FIELD_COUNT; j++) {jedis.hset(key, j + "", i + j + "");jedis.expire(key, 3600);}}}public void batch() {int index = 0;for (int i = 0; i < KEY_COUNT; i++) {String key = RandomUtils.nextInt(5) + "";for (int j = 0; j < FIELD_COUNT; j++) {p.hset(key, j + "", i + j + "");p.expire(key, 3600);}if (++index % 1000 == 0) {p.sync();}}p.sync();}public static void main(String[] args) {long start = System.currentTimeMillis();RedisEasyTest r = new RedisEasyTest();r.single();System.out.printf("single use %d sec \n", (System.currentTimeMillis() - start) / 1000);start = System.currentTimeMillis();r.batch();System.out.printf("batch use %d sec \n", (System.currentTimeMillis() - start) / 1000);}}

输出结果：

single use 30 sec
batch use 0 sec

?

可以看到通过pipeline批量插入数据性能是非常不错的。

?

?

--end

?

?

?