通过批量操作redis数据，来减少网络io的次数，提高效率
package com.changgx;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
import java.util.List;
/**
* Created by Administrator on 2016/12/1.
*/
public class JedisUtil {
private static Jedis jedis;
public static Jedis getJedis(){
return new Jedis("localhost",6379);
}
public static void closeJedis(){
jedis.close();
}
public static void insert(){
Pipeline pipeline=JedisUtil.getJedis().pipelined();
for(int i=0;i<1000;i++){
pipeline.set("changgx"+i,"changgx"+i);
//设置过期时间
// pipeline.setex("changgx"+i,10,"changgx"+i);
}
//执行
pipeline.sync();
}
public static void find(){
Pipeline pipeline=JedisUtil.getJedis().pipelined();
for(int i=0;i<2000;i++){
pipeline.get("changgx"+i);
}
//执行并且返回结果
List list=pipeline.syncAndReturnAll();
for (int i = 0; i < list.size(); i++) {
//打印value
System.out.println(list.get(i));
}
}
public static void delete(){
Pipeline pipeline=JedisUtil.getJedis().pipelined();
for(int i=0;i<1000;i++){
pipeline.del("changgx"+i);
}
//执行
pipeline.sync();
}
public static void main(String[] args) {
insert();
// find();
// delete();
}
}