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

Question

我用绝地武士连接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"));    
   }
}

我从redis获取多个密钥的mget方法如下

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

您可以使用适当的构造函数创建具有短超时的jedis连接。

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

Answer 2

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

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

Jedis具有以下默认配置

最大活动连接数=8

读取超时=2000

最大活动连接数是池可以同时保持的最大活动连接数。

读取超时是建立连接并准备通过建立的连接接收数据时设置的最长时间（毫秒）。

在我们的例子中，连接没有建立（对于前8个线程），并且它从未被杀死——连接是没有为这些连接设置超时。使get调用redis的其他线程现在转到parkWAIT状态。

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

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