Redis.clients.jedis.exceptions.JedisException：无法从池中获取资源

Question

Redis.Properties

#jedisPoolConfig
redis.minIdle=100
redis.maxIdle=500
redis.maxTotal=50000 
redis.maxWaitMillis=10000  
redis.testOnBorrow=true


#jedisPool
redis.host=192.168.13.169
redis.port=6379
redis.timeout=3000

redis.port2=6380

#redis-sentinel
redis.sentinel=192.168.13.169:26379
redis.master=mymaster

spring-redis.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xmlns:p="http://www.springframework.org/schema/p"
   xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans.xsd">

<!--properties配置-->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="locations">
        <list>
            <value>classpath:redis.properties</value>
        </list>
    </property>
    <property name="ignoreUnresolvablePlaceholders" value="true"/>
</bean>

<!-- 连接池配置信息 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <property name="maxIdle" value="${redis.maxIdle}" />
    <property name="maxTotal" value="${redis.maxTotal}" />
    <property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
    <property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>

<!--初级版：单实例-->
<bean id="jedisPool" class="redis.clients.jedis.JedisPool" scope="singleton">
    <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
    <constructor-arg name="host" value="${redis.host}" />
    <constructor-arg name="port" value="${redis.port}" type="int" />
</bean>

<!--主从-->
<bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool">
    <constructor-arg index="0" ref="jedisPoolConfig" />
    <constructor-arg index="1">
        <list>
            <bean class="redis.clients.jedis.JedisShardInfo">
                <constructor-arg name="host" value="${redis.host}" />
                <constructor-arg name="port" value="${redis.port}" />
                <constructor-arg name="timeout" value="${redis.timeout}" />
                <constructor-arg name="name" value="master" />
            </bean>
            <bean class="redis.clients.jedis.JedisShardInfo">
                <constructor-arg name="host" value="${redis.host}" />
                <constructor-arg name="port" value="${redis.port2}" />
                <constructor-arg name="timeout" value="${redis.timeout}" />
                <constructor-arg name="name" value="slave1" />
            </bean>
        </list>
    </constructor-arg>
</bean>

<!--sentinel模式-->
<bean id="redisSentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
    <constructor-arg name="master" value="${redis.master}" />
    <constructor-arg name="sentinelHostAndPorts">
        <set>
            <value>${redis.sentinel}</value>
        </set>
    </constructor-arg>
</bean>

<!--Jedis连接池-->
<bean id="jedisConnFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" p:use-pool="true">
    <property name="hostName" value="${redis.host}"/>
    <constructor-arg ref="redisSentinelConfiguration" />
    <constructor-arg ref="jedisPoolConfig" />
</bean>

<!-- redis template definition -->
<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" p:connection-factory-ref="jedisConnFactory"/>

<bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

代码

控制器

@Controller
public class JedisController {
......
@Autowired
private RedisService redisService;
@RequestMapping(value = "test2")
@ResponseBody
public String test2(){
    redisService.set("key2","v2");
    return redisService.get("key1");
}
......
}

@Service
public class RedisService extends BinaryRedisService {
public RedisService() {}

public String set(final String key, final String value) {
    return (String)this.execute(new Function<ShardedJedis, String>() {
        public String callBack(ShardedJedis shardedJedis) {
            return shardedJedis.set(key, value);
        }
    });
}
......
}

public class BinaryRedisService {
@Autowired
protected ShardedJedisPool shardedJedisPool;

public BinaryRedisService() {
}

protected <T> T execute(Function<ShardedJedis, T> fun) {
    ShardedJedis shardedJedis = null;
    T t = null;

    try {
        shardedJedis = this.shardedJedisPool.getResource();
        t = fun.callBack(shardedJedis);
    } catch (Exception var8) {
        var8.printStackTrace();
    } finally {
        if(null != shardedJedis) {
            shardedJedis.close();
        }

        return t;
    }
}
......
}

Answer 1

您需要确保a）Redis正在运行b）它能够接受来自远程主机的连接，c）如果您启用了密码保护，请在代码中提供密码。

为了确保它能够接受来自远程主机的连接，您必须查看redis.conf文件。找到带有绑定地址的行（应该类似于:bind127.0.0.1)并注释掉它（这样它就可以接受来自所有远程主机的请求-不建议用于生产，但可以用于测试），或者添加您希望Redis服务接受连接的远程IP。