Spring Data Redis enableTransactionSupport连接未返回池

Question

当我将enableTransactionSupport设置为true时，连接不会返回到池。即使事务方法已经完成，连接也会绑定到线程，这是一个大问题，如何解决？我使用spring数据redis 2.7.2和jedis 2.8.1

<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <property name="maxTotal" value="${redis.maxTotal}" />
    <property name="maxIdle" value="${redis.maxIdle}" />
    <property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
    <property name="testOnBorrow" value="${redis.testOnBorrow}" />
    <property name="testOnReturn" value="false" />
</bean>

<bean id="jedisFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <property name="hostName" value="${redis.host}" /> 
    <property name="port" value="${redis.port}" />
    <property name="usePool" value="true" />
    <property name="poolConfig" ref="jedisPoolConfig" />
</bean>

<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
    <property name="connectionFactory" ref="jedisFactory" />
    <property name="enableTransactionSupport" value="true" />
    <property name="defaultSerializer">
    <bean class="com.wd.ics.util.CustomRedisSerializer" /> </property>    
</bean>

连接没有释放到redis池，如果我没有使用enableTransactionSupport，这是可以的。但它不支持Spring的Transactional。如何解决？

Answer 1

可以这样解除绑定连接。

RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());

如果您使用jedis。它将返回到池的连接。

if (pool != null) {
        if (!broken) {
            // reset the connection
            try {
                if (dbIndex > 0) {
                    jedis.select(0);
                }
                pool.returnResource(jedis);
                return;
            } catch (Exception ex) {
                DataAccessException dae = convertJedisAccessException(ex);
                if (broken) {
                    pool.returnBrokenResource(jedis);
                } else {
                    pool.returnResource(jedis);
                }
                throw dae;
            }
        } else {
            pool.returnBrokenResource(jedis);
            return;
        }
    }