Redis集羣(九)：Redis Sharding集羣Redis節點主從切換後客戶端自動從新鏈接

時間 2019-12-17

標籤 redis 集羣 sharding 節點主從切換客戶端自動從新鏈接欄目 Redis 简体版

原文原文鏈接

上文介紹了Redis Sharding集羣的使用，點擊閱讀

本文介紹當某個Redis節點的Master節點發生問題，發生主從切換時，Jedis怎樣自動重連新的Master節點

1、步驟以下：

一、配置三組主從結構的redis集羣，參考

二、設置哨兵（某個master節點）：哨兵的做用主要是監控master節點的狀態，當master節點掛掉時經過選舉機制選出一個slave節點成爲一個新的master，哨兵的使用可參考

sentinel.conf配置說明，下面的mymaster很重要，表示是master節點的名稱，jedis指定master使用該名稱，而不是IP+端口

sentinel monitor mymaster 127.0.0.1 6379 1

三、使用ShardedJedisSentinelPool鏈接池

a) 該類是一個開源項目，地址爲： https://github.com/warmbreeze/sharded-jedis-sentinel-pool

b) ShardedJedisSentinelPool經過MasterListener線程（有幾個哨兵就有幾個線程）監控哨兵的狀態，若是對應的master節點發生問題，如主從切換，則經過redis的pub/sub該監聽器線程

c) MasterListener的run方法調用initPool重置鏈接池，即鏈接新的master機器

d) 調用pool.getResource() 前發生主從切換，當次redis操做使用新的master機器

e) 調用 pool.getResource()後發生主從切換，當次redis操做無效並拋出SocketException，下次redis恢復正常

2、示例代碼：因爲機器有限，只配置了一臺機器，多臺原理同樣

 
        public 
        class 
        ShardedSentinelTest { 
       
        public 
        static 
        void 
        main(String[] args) { 
       
        GenericObjectPoolConfig config =  
        new 
        GenericObjectPoolConfig(); 
       
        List<String> masters =  
        new 
        ArrayList<String>(); 
       
        masters.add( 
        "mymaster" 
        );  
       
        Set<String> sentinels =  
        new 
        HashSet<String>(); 
       
        sentinels.add( 
        "xxxxxx:29111" 
        ); 
       
        ShardedJedisSentinelPool pool =  
        new 
        ShardedJedisSentinelPool(masters, sentinels, config,  
        60000 
        ); 
       
        ShardedJedis jedis = pool.getResource(); 
       
        for 
        ( 
        int 
        i =  
        1 
        ; i <  
        10000 
        ; i++) { 
       
        String val = jedis.set( 
        "ss" 
        + i,  
        "vv" 
        + i); 
       
        System.out.println(jedis.get( 
        "ss" 
        + i)); 
       
        } 
       
        jedis.close(); 
       
        pool.destroy(); 
       
        } 
       
        }