RedisClient

RedisClient.java

public class RedisClient {


    private static RedissonClient redisClient;

    public static synchronized void newInstance(){
        if(redisClient==null) {
            Config config = new Config();
            config.setCodec(new StringCodec());
            config.setThreads(Integer.parseInt(System.getenv("threads")));
            config.setNettyThreads(Integer.parseInt(System.getenv("netty")));
            config.useClusterServers()
                    .addNodeAddress("redis://<host1>:6379")
                    .addNodeAddress("redis://<host2>:6379");
            redisClient = Redisson.create(config);
        }
    }

    public static RedissonClient getRedisClient() {
        return redisClient;
    }
}