如何将JedisCluster获取的连接优雅放回连接池而非关闭？

核心问题 #

直接调用 getConnectionFromSlot 获取的 Connection 不会自动归还到连接池，手动关闭会销毁连接无法复用，必须通过对应节点的 JedisPool 执行归还操作。

具体实现（Kotlin） #

利用反射获取 JedisCluster 内部维护的节点-连接池映射，找到当前连接所属的池，调用官方归还方法：

import redis.clients.jedis.JedisCluster
import redis.clients.jedis.JedisPool
import redis.clients.jedis.Connection
import java.lang.reflect.Field

// 业务代码中获取连接并使用
val connection = jedisCluster.getConnectionFromSlot(slotNumber)
try {
    // 执行底层连接操作，示例：
    connection.set("custom-key".toByteArray(), "custom-value".toByteArray())
} finally {
    // 确保无论是否异常都归还连接
    returnConnectionToPool(jedisCluster, connection)
}

/**
 * 将连接归还到对应的Jedis连接池
 */
private fun returnConnectionToPool(jedisCluster: JedisCluster, connection: Connection) {
    // 反射获取JedisCluster私有字段nodeToPool（节点到连接池的映射）
    val nodeToPoolField = JedisCluster::class.java.getDeclaredField("nodeToPool")
    nodeToPoolField.isAccessible = true
    @Suppress("UNCHECKED_CAST")
    val nodeToPoolMap = nodeToPoolField.get(jedisCluster) as Map<String, JedisPool>
    
    // 拼接当前连接的节点标识（host:port）
    val nodeIdentifier = "${connection.host}:${connection.port}"
    // 获取对应节点的连接池并归还连接
    nodeToPoolMap[nodeIdentifier]?.returnResourceObject(connection)
}

关键说明 #

• 反射的必要性：nodeToPool 是 JedisCluster 的私有成员，用于维护集群节点与连接池的对应关系，反射是最直接的获取方式（若需避免反射，需自行维护集群节点与池的映射，但需同步集群拓扑变化，成本较高）。
• 归还方法：returnResourceObject 是 Apache Commons Pool2 提供的官方归还接口，会将连接放回空闲队列，而非关闭连接，保证后续可复用。
• 异常安全：必须在 finally 块中执行归还，防止业务代码抛出异常导致连接泄漏。

更优替代方案 #

如果业务操作无需直接操作底层 Connection，优先使用 JedisCluster 提供的高层API，它会自动完成连接的获取与归还，完全无需手动管理：

// 示例：直接用JedisCluster的set方法，自动管理连接池
jedisCluster.set("test-key", "test-value")

内容的提问来源于stack exchange，提问作者SerhiiH