【Redis】已解决：JedisExhaustedPoolException: Could not get a resource since the pool is exhausted

屿小夏

发布于 2024-08-11 08:21:42

2770

发布于 2024-08-11 08:21:42

文章被收录于专栏：IT杂谈学习

已解决：JedisExhaustedPoolException: Could not get a resource since the pool is exhausted

一、分析问题背景

JedisExhaustedPoolException 是在使用 Jedis 连接 Redis 时常见的异常。它表示连接池已经耗尽，无法再分配新的连接资源。这通常发生在高并发或连接未正确释放的情况下。下面是一个常见的场景：

场景：在一个Spring Boot项目中，开发者使用Jedis作为Redis客户端来缓存用户数据。然而，当并发请求增多时，出现了JedisExhaustedPoolException错误。

示例代码片段：

public class RedisCache {

    private JedisPool jedisPool;

    public RedisCache() {
        this.jedisPool = new JedisPool(new JedisPoolConfig(), "localhost");
    }

    public String getFromCache(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.get(key);
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
}

在上述代码中，如果并发请求过多，连接池可能会耗尽，导致无法获取新的连接资源，从而抛出JedisExhaustedPoolException异常。

二、可能出错的原因

导致JedisExhaustedPoolException报错的原因主要有以下几点：

高并发请求：大量并发请求同时访问Redis，导致连接池耗尽。
连接泄漏：未正确关闭Jedis连接，导致连接未返回池中。
连接池配置不当：连接池大小配置过小，无法满足应用需求。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

public class RedisCache {

    private JedisPool jedisPool;

    public RedisCache() {
        this.jedisPool = new JedisPool(new JedisPoolConfig(), "localhost");
    }

    public String getFromCache(String key) {
        Jedis jedis = jedisPool.getResource(); // 错误处理
        return jedis.get(key); // 未正确释放连接
    }
}

错误分析：

未正确释放连接：在未使用finally块确保连接关闭的情况下，可能会导致连接泄漏，耗尽连接池资源。

四、正确代码示例

为了解决该报错问题，我们可以优化连接池配置，并确保正确释放连接。以下是正确的代码示例：

public class RedisCache {

    private JedisPool jedisPool;

    public RedisCache() {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(128); // 设置最大连接数
        poolConfig.setMaxIdle(64);   // 设置最大空闲连接数
        poolConfig.setMinIdle(16);   // 设置最小空闲连接数
        poolConfig.setTestOnBorrow(true); // 在借用连接时进行测试
        this.jedisPool = new JedisPool(poolConfig, "localhost");
    }

    public String getFromCache(String key) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.get(key);
        } finally {
            if (jedis != null) {
                jedis.close(); // 确保连接被关闭
            }
        }
    }
}

通过上述代码，我们可以增加连接池的大小，并在借用和归还连接时进行必要的测试，从而避免JedisExhaustedPoolException异常。