Redis的分片（Sharding或者Partitioning）技術是指將資料分散到多個Redis例項中的方法，分片之後，每個redis擁有一部分原資料集的子集。在資料量非常大時，這種技術能夠將資料量分散到若干主機的redis例項上，進而減輕單臺redis例項的壓力。分片技術能夠以更易擴充套件的方式使用多臺計算機的儲存能力（這裡主要指記憶體的儲存能力）和計算能力：

（1）從儲存能力的角度，分片技術通過使用多臺計算機的記憶體來承擔更大量的資料，如果沒有分片技術，那麼redis的儲存能力將受限於單臺主機的記憶體大小。

（2） 從計算能力的角度，分片技術通過將計算任務分散到多核或者多臺主機中，能夠充分利用多核、多臺主機的計算能力。

採用分片之後，資料將被分散到4個redis例項中，對資料的操作也被分散到每個redis例項中，此時單臺主機的壓力將大大減輕。

因為使用了一致性哈稀進行分片，那麼不同的key分佈到不同的Redis-Server上，當我們需要擴容時，需要增加機器到分片列表中，這時候會使得同樣的key算出來落到跟原來不同的機器上，這樣如果要取某一個值，會出現取不到的情況。而且在正常運營環境中，一般所儲存的資料會逐漸增加，可能今天只要10個redis例項就能應付，但是到了一年以後就需要50個redis例項才能支撐，因此，redis的擴容是經常用到的功能，在redis的分散式部署中，有預分片技術是非常好用的方法之一；

（7）關掉被遷移走資料的原redis例項；

Jedis分片連線池

1. 部署2個Redis master節點。

2. 用ShardedJedisPool連線Redis maser節點，並將資料根據一致性雜湊演算法存放到不同的master節點，從而達成資料分片。

客戶端程式碼如下：

public class RedisShardPoolTest {
    static ShardedJedisPool pool;
    static{
        JedisPoolConfig config =new JedisPoolConfig();//Jedis池配置
        config.setMaxActive(500);//最大活動的物件個數
          config.setMaxIdle(1000 * 60);//物件最大空閒時間
          config.setMaxWait(1000 * 10);//獲取物件時最大等待時間
          config.setTestOnBorrow(true);
        String hostA = "10.7.12.52";
          int portA = 6379;
          String hostB = "10.7.112.52";
          int portB = 6379;
        List<JedisShardInfo> jdsInfoList =new ArrayList<JedisShardInfo>(2);
        JedisShardInfo infoA = new JedisShardInfo(hostA, portA);
        infoA.setPassword("redis.360buy");
        JedisShardInfo infoB = new JedisShardInfo(hostB, portB);
        infoB.setPassword("redis.360buy");
        jdsInfoList.add(infoA);
        jdsInfoList.add(infoB);
       
        pool =new ShardedJedisPool(config, jdsInfoList, Hashing.MURMUR_HASH,
Sharded.DEFAULT_KEY_TAG_PATTERN);
    }
   
    /**
     * @param args
     */
    public static void main(String[] args) {
        for(int i=0; i<100; i++){
           String key =generateKey();
           //key += "{aaa}";
           ShardedJedis jds =null;
           try {
               jds =pool.getResource();
               System.out.println(key+":"+jds.getShard(key).getClient().getHost());
               System.out.println(jds.set(key,"1111111111111111111111111111111"));
           }catch (Exception e) {
               e.printStackTrace();
           }
           finally{
               pool.returnResource(jds);
           }
        }
    }
 
    private static int index = 1;
    public static String generateKey(){
        return String.valueOf(Thread.currentThread().getId())+"_"+(index++);
    }
}