redis Java工具類

[Java]代碼    

private static ShardedJedisPool sharedJedisPool;

    public synchronized static void init(Set<RedisDiamond> rediset)
    {
        //關閉之前的連接池
        if(sharedJedisPool!= null)
        {
            sharedJedisPool.destroy();
        }

        if(rediset.isEmpty())
        {
            System.err.println("嚴重錯誤,serious diamond setting error,取得UM not exist配置值不存在.");
        }
        else
        {
            List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();

            //使用多節點sharding初始化數據
            for(RedisDiamond redisDiamond : rediset)
            {
                JedisShardInfo jedisShardInfo =  new JedisShardInfo(redisDiamond.getIp(), redisDiamond.getPort(), redisDiamond.getTimeout(),redisDiamond.getWeight());
                if(!isBlank(redisDiamond.getPassword())){
                    jedisShardInfo.setPassword(redisDiamond.getPassword());
                }
                shards.add(jedisShardInfo);
            }

            sharedJedisPool = new ShardedJedisPool(RedisConfigurationAnalyzeUtil.getJedisPoolConfig(), shards);
        }
    }
    public static boolean isBlank(String str) {
        int strLen;
        if (str == null || (strLen = str.length()) == 0)
            return true;
        for (int i = 0; i < strLen; i++)
            if (!Character.isWhitespace(str.charAt(i)))
                return false;

        return true;
    }
    /**
     * 獲取jedis連接池
     * @return
     */
    public synchronized static ShardedJedisPool getJedisPool(){
        return sharedJedisPool;
    }

    /**
     * jedis 連接回收
     * @param jedis
     * @param isFalg
     */
    public static void returnResource(ShardedJedis jedis, boolean isFalg) {
        if (null == jedis) {
            return;
        }
        if (isFalg) {
            sharedJedisPool.returnBrokenResource(jedis);
        } else {
            sharedJedisPool.returnResource(jedis);
        }
    }