Jedis连接池工具类

import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisPoolUtil {

    private static JedisPool jedisPool;

    private static void initJedisPool() {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(100);
        poolConfig.setMaxIdle(5);
        poolConfig.setMinIdle(5);
        poolConfig.setBlockWhenExhausted(true);
        poolConfig.setMaxWaitMillis(2000);
        poolConfig.setTestOnBorrow(true);
        jedisPool = new JedisPool(poolConfig, "hadoop102", 6379, 10000);
    }

    public static JedisPool getJedisPool() {
        if (jedisPool == null) {
            initJedisPool();
        }
        // 获取Jedis客户端
        return jedisPool;
    }

}


版权声明:本文为qq_50408152原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。