package cn.com;import java.util.Arrays;import java.util.List;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisShardInfo;import redis.clients.jedis.Pipeline;import redis.clients.jedis.ShardedJedis;import redis.clients.jedis.ShardedJedisPipeline;public class Redis_Dispersed {	/**	 * 	分布式直连同步调用	 * */	public static void sync_dispersed(){		List
     
       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("userid" + i, "age" + i); 	    } 	    long end = System.currentTimeMillis(); 	    System.out.println("执行实行: " + ((end - start)/1000.0) + " seconds"); 	    sharding.disconnect(); 			}		/**	 * 分布式直连异步调用	 * */	public static void shardpipelined() { 		    List
      
        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 < 100; i++) { 		        pipeline.set("userid" + i, "age" + i); 		    } 		    List