从 JedisPool 获取资源时线程处于等待状态

Question

我正在使用 jedis 连接 redis 服务器。 Redis ip 值配置在单独的文件中，我正在尝试在初始化期间加载该文件

private static JedisPool pool;

public static void initRedisClient() throws Exception {
   String redisConfigPath = "/conf/redis.properties";
   Properties docsRedisProp = RedisUtils.loadProperties(redisConfigPath);
   pool = new JedisPool(docsRedisProp.getProperty("redisserver"));    
   }
}

而我的mget从redis中获取多个key的方法如下

public static List<String> mgetDataFromRedisCache(String[] keys) throws CacheException {
        Jedis jedisCon = null; 
        try {
            jedisCon = getJedis();
            jedisCon.select(1);
            return jedisCon.mget(keys);
        } catch (Exception e) {
            LOGGER.warning("Exception while fetching data from Redis Client. EXCEPTION=" + e.getMessage());
            e.printStackTrace();
        } finally {
            if (jedisCon != null) {
                returnJedis(jedisCon);
            }
        }
        return null;
    }

当我在属性文件中提供了不正确的 ip 值时 - 访问它的请求线程正在等待很长时间。我的请求不应该因为池中的资源不可用而停止。

这里我附上了停滞线程（即处于等待状态的线程）的线程转储

###_http-nio-8443-exec-140" #104908 daemon prio=5 os_prio=0 tid=0x00007f247805f000 nid=0x4266 waiting on condition [0x00007f220a4df000]
   java.lang.Thread.State: WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00000006fe438408> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
    at org.apache.commons.pool2.impl.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:524)
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:438)
    at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:361)
    at redis.clients.util.Pool.getResource(Pool.java:40)
    at redis.clients.jedis.JedisPool.getResource(JedisPool.java:84)
    at com.retail.store.RedisClient.getJedis(RedisClient.java:53)
    at com.retail.store.RedisClient.mgetDataFromRedisCache(RedisClient.java:82)

我怎样才能做到这一点？任何帮助深表感谢。在此先感谢:-)

Answer 1

redis 服务器 ip 维护在一个属性文件中，并在运行时加载它。

属性文件包含默认 ip。但是当我在我的开发设置中部署相同的内容时，redis ip 应该已经更改，但我错过了这样做。我的开发设置无法连接到给定的 ip。

Jedis 有以下默认配置

最大活动连接数 = 8

读取超时 = 2000

Maximum active connections 是池可以同时容纳的最大活动连接数。

read time out 是在建立连接并准备好通过已建立的连接接收数据时设置的最长时间（毫秒）。

在我们的例子中，连接没有建立（对于前 8 个线程）并且它从未被终止 - 连接是 timeout 没有为这些连接设置。使get 调用redis 的其他线程现在进入停放WAIT 状态。

通过设置以下池配置（即设置建立连接的最大等待时间），我们可以避免线程进入长时间等待状态

JedisPoolConfig jedisConfig = new JedisPoolConfig();
jedisConfig.setMaxWaitMillis(maxWaitInMillis);

Answer 2

您可以使用适当的constructor 创建具有短暂超时的绝地连接。

Jedis jedisCon = public Jedis(String host, int port, int timeout);