if("redis-cluster".equalsIgnoreCase(scheme)) {
            scheme = "redis";
            List<RedisURI> redisURIs = new ArrayList<>();
            String[] hostArray = hosts.split(",");
            for(String host : hostArray) {
            	String[] redisArray = host.split(":");
            	RedisURI uri = RedisURI.create(redisArray[0], Integer.valueOf(redisArray[1]));
            	uri.setDatabase(database);
            	uri.setPassword(password);
            	uri.setSentinelMasterId(sentinelMasterId);
            	redisURIs.add(uri);
            }
             RedisClusterClient.create(redisURIs); // 这里未初始化redisClient
        }
        else {
        	String[] redisArray = hosts.split(":");
        	RedisURI uri = RedisURI.create(redisArray[0], Integer.valueOf(redisArray[1]));
        	uri.setDatabase(database);
        	uri.setPassword(password);
        	redisClient = RedisClient.create(uri);
        }