Jedis连接池

一、前言为什么必须用连接池在 Java 应用中直接使用new Jedis()创建单连接操作 Redis看似简单但在高并发场景下会迅速崩溃❌ 每次请求新建 TCP 连接 → 耗时毫秒级❌ 频繁创建/销毁连接 → 系统资源耗尽文件描述符、内存❌ 无法控制并发连接数 → Redis 服务被压垮而Jedis 连接池JedisPool通过复用连接、限制资源、自动回收成为生产环境的唯一选择。本文将带你✅ 深入理解 JedisPool 工作原理✅ 掌握核心参数配置✅ 避免常见陷阱如连接泄漏✅ 实现生产级封装与监控二、JedisPool 核心原理JedisPool 基于Apache Commons Pool2实现其核心思想是预先创建一批 Jedis 连接放入“池”中业务需要时从池中借borrow用完归还return关键特性线程安全多个线程可并发 borrow/return自动检测可配置测试连接有效性资源隔离限制最大连接数防止单点打爆 Redis三、JedisPool 基础配置与使用3.1 Maven 依赖dependency groupIdredis.clients/groupId artifactIdjedis/artifactId version5.1.2/version /dependency !-- JedisPool 依赖 commons-pool2但 Jedis 已传递引入 --3.2 创建连接池带密码 超时import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisPoolManager { private static volatile JedisPool jedisPool null; public static JedisPool getJedisPool() { if (jedisPool null) { synchronized (JedisPoolManager.class) { if (jedisPool null) { jedisPool createJedisPool(); } } } return jedisPool; } private static JedisPool createJedisPool() { JedisPoolConfig config new JedisPoolConfig(); // 核心参数配置 config.setMaxTotal(50); // 最大连接数 config.setMaxIdle(20); // 最大空闲连接 config.setMinIdle(5); // 最小空闲连接保持 warm config.setMaxWaitMillis(2000); // 获取连接最大等待时间ms config.setTestOnBorrow(true); // 借出时检查有效性 config.setTestOnReturn(false); // 归还时不检查影响性能 config.setTestWhileIdle(true); // 空闲时检查配合 timeBetweenEvictionRunsMillis config.setTimeBetweenEvictionRunsMillis(30000); // 空闲检查周期 config.setMinEvictableIdleTimeMillis(60000); // 连接最小空闲时间才可被驱逐 // 创建连接池含密码、超时 return new JedisPool( config, 192.168.1.100, // Redis 地址 6379, // 端口 2000, // 连接超时ms your_password, // 密码无密码传 null 0 // database默认 0 ); } // 优雅关闭 public static void destroyPool() { if (jedisPool ! null) { jedisPool.close(); } } }四、正确使用连接池避免连接泄漏4.1 错误写法会导致连接泄漏// ❌ 危险未关闭连接 public String get(String key) { Jedis jedis JedisPoolManager.getJedisPool().getResource(); return jedis.get(key); // jedis 没有 close()连接永远不归还 → 池耗尽 }4.2 正确写法try-with-resources推荐// ✅ 推荐自动 close() public String get(String key) { try (Jedis jedis JedisPoolManager.getJedisPool().getResource()) { return jedis.get(key); } // 自动调用 jedis.close() → 归还连接 }4.3 手动 close兼容老版本 Java// ✅ 兼容 Java 7- public String get(String key) { Jedis jedis null; try { jedis JedisPoolManager.getJedisPool().getResource(); return jedis.get(key); } finally { if (jedis ! null) { jedis.close(); // 注意不是销毁而是归还 } } }关键点jedis.close()在连接池模式下 归还连接不是关闭 TCP五、生产级封装通用 Redis 工具类public class RedisUtils { private static final JedisPool jedisPool JedisPoolManager.getJedisPool(); // String public static void set(String key, String value) { try (Jedis jedis jedisPool.getResource()) { jedis.set(key, value); } } public static String get(String key) { try (Jedis jedis jedisPool.getResource()) { return jedis.get(key); } } // Hash public static void hset(String key, String field, String value) { try (Jedis jedis jedisPool.getResource()) { jedis.hset(key, field, value); } } public static String hget(String key, String field) { try (Jedis jedis jedisPool.getResource()) { return jedis.hget(key, field); } } // 带过期时间 public static void setEx(String key, int seconds, String value) { try (Jedis jedis jedisPool.getResource()) { jedis.setex(key, seconds, value); } } // 批量操作Pipeline public static void batchSet(MapString, String kvs) { try (Jedis jedis jedisPool.getResource()) { Pipeline p jedis.pipelined(); kvs.forEach(p::set); p.sync(); // 执行 } } }六、连接池参数调优指南参数默认值生产建议说明maxTotal850~200总连接数 QPS × 平均响应时间秒maxIdle8≈maxTotal避免频繁创建连接minIdle05~10保持 warm 连接应对突发流量maxWaitMillis-1无限1000~3000 ms防止线程无限阻塞testOnBorrowfalsetrue开发false生产借出时检查增加 RTtestWhileIdlefalsetrue后台定期清理无效连接计算 maxTotal 示例预期 QPS 1000Redis 平均响应时间 2ms→ 所需连接数 ≈ 1000 × 0.002 2但考虑峰值、网络抖动建议设为20~50七、监控与故障排查7.1 监控连接池状态JedisPool pool JedisPoolManager.getJedisPool(); GenericObjectPoolJedis internalPool pool.getPool(); System.out.println(活跃连接: internalPool.getNumActive()); System.out.println(空闲连接: internalPool.getNumIdle()); System.out.println(等待线程: internalPool.getNumWaiters());7.2 常见问题排查现象可能原因解决方案java.util.NoSuchElementException: Timeout waiting for idle object连接池耗尽增大maxTotal检查是否连接泄漏应用启动后 Redis 连接数暴增minIdle设置过高调整minIdle或延迟初始化偶尔读到旧数据连接未清理脏连接开启testWhileIdle 合理设置timeBetweenEvictionRunsMillis八、高级技巧多 Redis 实例支持// 支持多个 Redis 实例如 cache / session 分离 public class MultiJedisPoolManager { private static MapString, JedisPool poolMap new ConcurrentHashMap(); public static JedisPool getPool(String name) { return poolMap.computeIfAbsent(name, k - createPoolByConfig(k)); } private static JedisPool createPoolByConfig(String name) { // 根据 name 读取不同配置如从 application.yml // 返回对应 JedisPool } } // 使用 JedisPool cachePool MultiJedisPoolManager.getPool(cache); JedisPool sessionPool MultiJedisPoolManager.getPool(session);九、结语感谢您的阅读如果你有任何疑问或想要分享的经验请在评论区留言交流