redisクラスタ接続プールの例

以前はスタンドアロン版のredis接続プールの例を書いていましたが、ここでは本機でテストとして3つのredisサービスを構築しました.接続プールの例:

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.apache.commons.lang.StringUtils;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedisPool;

public class JedisPool {
    //JedisPool   Redis，ShardedJedisPool Redis  ，                   ，           ，
    private static ShardedJedisPool pool;
    private static int MAXTOTAL=300;
    private static int MAXIDLE=200;
    private static int MINIDEL=10;
    private static int MAXWAIRMILLIS=1000;
    private static Boolean TESTONBORROW=true;
    private static Boolean TESTONRETURN=false;
    private static Boolean TESTWHILEIDLE=false;
    //            
    static {
        try {
            //          
            JedisPoolConfig config=initConfig();
            List shards=new ArrayList();
            String host="localhost:6379:testredis,localhost:6380:testredis,localhost:6381:testredis";//     ,  
            Set hosts=init(host);
            for (String hs:hosts){
                String[] values=hs.split(":");
                JedisShardInfo shard=new JedisShardInfo(values[0],Integer.parseInt(values[1]));
                if(values.length>2){
                    shard.setPassword(values[2]);
                }
                shards.add(shard);
            }
            pool=new ShardedJedisPool(config,shards);
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    //        
    private static JedisPoolConfig initConfig(){
        JedisPoolConfig config=new JedisPoolConfig();
        config.setMaxTotal(MAXTOTAL);
        config.setMaxIdle(MAXIDLE);
        config.setMinIdle(MINIDEL);
        config.setMaxWaitMillis(MAXWAIRMILLIS);
        config.setTestOnBorrow(TESTONBORROW);
        config.setTestOnReturn(TESTONRETURN);
        config.setTestWhileIdle(TESTWHILEIDLE);
        return config;
    }

    private static Set init(String values){
        if(StringUtils.isBlank(values)){
            throw new NullPointerException("redis host not found");
        }
        Set paramter=new HashSet();
        String[] sentinelArray=values.split(",");
        for(String str:sentinelArray){
            paramter.add(str);
        }
        return paramter;
    }

    public static ShardedJedisPool getShardedJedisPool(){
        return pool;
    }
}

呼び出し接続プールの例

import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;

public class RedisDataSource  {

    private static ThreadLocal jedisLocal = new ThreadLocal();
    private static ShardedJedisPool pool;
    static {
        pool = JedisPool.getShardedJedisPool();
    }

    public  ShardedJedis getClient() {
        ShardedJedis jedis = jedisLocal.get();
        if (jedis == null) {
            jedis = pool.getResource();
            jedisLocal.set(jedis);
        }
        return jedis;
    }

    //    
    public void returnResource() {
        ShardedJedis jedis = jedisLocal.get();
        if (jedis != null) {
            pool.destroy();
            jedisLocal.set(null);
        }
    }
}

私が会社で使用しているのはこのようなスライス式のメカニズムなので、redisの主従についても似ていますが、呼び出されたapiが異なるだけで、ここでは例を示して参考にします.