public void jedisNormal() { 
 Jedis jedis = new Jedis("localhost"); 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  String result = jedis.set("n" + i, "n" + i); 
 } 
 long end = System.currentTimeMillis(); 
 System.out.println("Simple SET: " + ((end - start)/1000.0) + " seconds"); 
 jedis.disconnect(); 
} 
//每次set之后都可以返回结果，标记是否成功。 

public void jedisTrans() { 
 Jedis jedis = new Jedis("localhost"); 
 long start = System.currentTimeMillis(); 
 Transaction tx = jedis.multi(); 
 for (int i = 0; i < 100000; i++) { 
  tx.set("t" + i, "t" + i); 
 } 
 List<Object> results = tx.exec(); 
 long end = System.currentTimeMillis(); 
 System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds"); 
 jedis.disconnect(); 
} 
//我们调用jedis.watch(…)方法来监控key，如果调用后key值发生变化，则整个事务会执行失败。另外，事务中某个操作失败，并不会回滚其他操作。这一点需要注意。还有，我们可以使用discard()方法来取消事务。 

public void jedisPipelined() { 
 Jedis jedis = new Jedis("localhost"); 
 Pipeline pipeline = jedis.pipelined(); 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  pipeline.set("p" + i, "p" + i); 
 } 
 List<Object> results = pipeline.syncAndReturnAll(); 
 long end = System.currentTimeMillis(); 
 System.out.println("Pipelined SET: " + ((end - start)/1000.0) + " seconds"); 
 jedis.disconnect(); 
} 

public void jedisCombPipelineTrans() { 
 jedis = new Jedis("localhost"); 
 long start = System.currentTimeMillis(); 
 Pipeline pipeline = jedis.pipelined(); 
 pipeline.multi(); 
 for (int i = 0; i < 100000; i++) { 
  pipeline.set("" + i, "" + i); 
 } 
 pipeline.exec(); 
 List<Object> results = pipeline.syncAndReturnAll(); 
 long end = System.currentTimeMillis(); 
 System.out.println("Pipelined transaction: " + ((end - start)/1000.0) + " seconds"); 
 jedis.disconnect(); 
} 
//效率上可能会有所欠缺 

public void jedisShardNormal() { 
 List<JedisShardInfo> shards = Arrays.asList( 
   new JedisShardInfo("localhost",6379), 
   new JedisShardInfo("localhost",6380)); 
 
 ShardedJedis sharding = new ShardedJedis(shards); 
 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  String result = sharding.set("sn" + i, "n" + i); 
 } 
 long end = System.currentTimeMillis(); 
 System.out.println("Simple@Sharing SET: " + ((end - start)/1000.0) + " seconds"); 
 
 sharding.disconnect(); 
} 

public void jedisShardpipelined() { 
 List<JedisShardInfo> shards = Arrays.asList( 
   new JedisShardInfo("localhost",6379), 
   new JedisShardInfo("localhost",6380)); 
 
 ShardedJedis sharding = new ShardedJedis(shards); 
 
 ShardedJedisPipeline pipeline = sharding.pipelined(); 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  pipeline.set("sp" + i, "p" + i); 
 } 
 List<Object> results = pipeline.syncAndReturnAll(); 
 long end = System.currentTimeMillis(); 
 System.out.println("Pipelined@Sharing SET: " + ((end - start)/1000.0) + " seconds"); 
 
 sharding.disconnect(); 
} 

public void jedisShardSimplePool() { 
 List<JedisShardInfo> shards = Arrays.asList( 
   new JedisShardInfo("localhost",6379), 
   new JedisShardInfo("localhost",6380)); 
 
 ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards); 
 
 ShardedJedis one = pool.getResource(); 
 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  String result = one.set("spn" + i, "n" + i); 
 } 
 long end = System.currentTimeMillis(); 
 pool.returnResource(one); 
 System.out.println("Simple@Pool SET: " + ((end - start)/1000.0) + " seconds"); 
 
 pool.destroy(); 
} 

public void jedisShardPipelinedPool() { 
 List<JedisShardInfo> shards = Arrays.asList( 
   new JedisShardInfo("localhost",6379), 
   new JedisShardInfo("localhost",6380)); 
 
 ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards); 
 
 ShardedJedis one = pool.getResource(); 
 
 ShardedJedisPipeline pipeline = one.pipelined(); 
 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  pipeline.set("sppn" + i, "n" + i); 
 } 
 List<Object> results = pipeline.syncAndReturnAll(); 
 long end = System.currentTimeMillis(); 
 pool.returnResource(one); 
 System.out.println("Pipelined@Pool SET: " + ((end - start)/1000.0) + " seconds"); 
 pool.destroy(); 
} 

Transaction tx = jedis.multi(); 
 for (int i = 0; i < 100000; i++) { 
  tx.set("t" + i, "t" + i); 
 } 
 System.out.println(tx.get("t1000").get()); //不允许 
 
 List<Object> results = tx.exec(); 
 
 … 
 … 
 
 Pipeline pipeline = jedis.pipelined(); 
 long start = System.currentTimeMillis(); 
 for (int i = 0; i < 100000; i++) { 
  pipeline.set("p" + i, "p" + i); 
 } 
 System.out.println(pipeline.get("p1000").get()); //不允许 
 
 List<Object> results = pipeline.syncAndReturnAll();