異常最詭異第二期之 Jedis pool.returnResource(jedis)

時間  2019-11-24
標籤 異常 詭異 二期 jedis pool.returnresource pool returnresource 简体版
原文   原文鏈接

# Redis 誰的問題最詭異第二期

commons-collections-3.2.jarhtml

# 1 Exception in thread "main"java.lang.NoClassDefFoundError: org/apache/commons/collections/CursorableLinkedList

分析：Redis的JavaAPI中Jedis錯誤，看到這個你確定會以爲這個問題有點低級，確實低級，不用看都知道是少導了jar包引發的，不過這不是重點，重點是Jedis中的一個方法：pool.returnResource(jedis);這個纔是重點中的重點，接下來咱們看看這個方法的描述：voidredis.clients.util.Pool.returnResource(Jedis jedis)能夠看出這裏面並無拋出異常的聲明子類的，那咱們就不會去try-catch了，不去try-catch的後果就是會出現莫名其妙的錯誤，不try-catch會出現一個java.lang.NullPointerExceptio這樣的空指針異常，這樣的信息給咱們是沒用的，這是咱們缺乏jar包致使的問題，這裏卻提示java.lang.NullPointerException這樣的空指針異常，這不是坑爹麼？（徹底不是咱們想要的東西）、、、而後就開始坑爹了，本身開始找錯誤了，運氣差的話找N久也找不出來，有一種怒砸電腦的衝動，運氣好的話一下就把錯誤找出來了，請看下面的代碼，不用try-catch跟使用try-catch的比較。餓當時就沒使用try-catch，由於這個方法pool.returnResource(jedis);沒有聲明有異常拋出，因此天然不會用。（坑爹啊！）java

緣由：缺乏commons-collections-3.2.jar這樣的jar包redis

解決：導入commons-collections-3.2.jar該jar包就好了apache

 

# 沒有使用try-catch的代碼已經相應的異常信息spa

# 沒有使用try-catch的代碼

publicvoid hdel(String key, String field){.net

       JedisPoolpool =null;線程

       Jedisjedis =null;指針

       try {code

           pool= getJedisPool(key);htm

           jedis= pool.getResource();

           jedis.hdel(key,field);

       }catch (Exception e) {

           log.error("Redis hdel exception :" + key, e);

           pool.returnBrokenResource(jedis);

       }finally {

              pool.returnResource(jedis);

       }

# 異常信息

java.lang.NullPointerException

         atcn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils.hset(ConsistentHashRedisUtils.java:164)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorStoreRedis.userBehavior2Redis(UserBehaviorStoreRedis.java:58)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorAnalysisMainClass.main(UserBehaviorAnalysisMainClass.java:33)

# 使用了try-catch的代碼

public void hdel(String key, String field) {

       JedisPool pool =null;

       Jedis jedis =null;

       try {

           pool = getJedisPool(key);

           jedis = pool.getResource();

           jedis.hdel(key, field);

       } catch (Exception e) {

           log.error("Redis hdel exception : " +key, e);

           pool.returnBrokenResource(jedis);

       } finally {

           try {

              pool.returnResource(jedis);

           }catch(Exception e) {

             log.error("JdisreturnResource exception : ", e);

           }

       }

# 異常信息

[2014-07-1016:39:17,659].[ERROR].[cn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils]

    JdisreturnResource exception :

 

java.lang.NullPointerException

         atcn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils.hset(ConsistentHashRedisUtils.java:164)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorStoreRedis.userBehavior2Redis(UserBehaviorStoreRedis.java:58)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorAnalysisMainClass.main(UserBehaviorAnalysisMainClass.java:33)

Exception in thread"main" java.lang.NoClassDefFoundError:org/apache/commons/collections/CursorableLinkedList

         atorg.apache.commons.pool.impl.GenericObjectPool.<init>(GenericObjectPool.java:392)

         atorg.apache.commons.pool.impl.GenericObjectPool.<init>(GenericObjectPool.java:275)

         atredis.clients.util.Pool.<init>(Pool.java:14)

         atredis.clients.jedis.JedisPool.<init>(JedisPool.java:24)

         atredis.clients.jedis.JedisPool.<init>(JedisPool.java:29)

         atcn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils.getJedisPool(ConsistentHashRedisUtils.java:343)

         atcn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils.getJedisPool(ConsistentHashRedisUtils.java:317)

         atcn.adsit.iva.preroll.dp.synch.analysis.redis.util.ConsistentHashRedisUtils.hset(ConsistentHashRedisUtils.java:156)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorStoreRedis.userBehavior2Redis(UserBehaviorStoreRedis.java:58)

         atcn.adsit.iva.preroll.dp.synch.analysis.UserBehaviorAnalysisMainClass.main(UserBehaviorAnalysisMainClass.java:33)

Caused by:java.lang.ClassNotFoundException:org.apache.commons.collections.CursorableLinkedList

         atjava.net.URLClassLoader$1.run(URLClassLoader.java:217)

         atjava.security.AccessController.doPrivileged(Native Method)

 

         atjava.net.URLClassLoader.findClass(URLClassLoader.java:205)

         atjava.lang.ClassLoader.loadClass(ClassLoader.java:319)

         atjava.lang.ClassLoader.loadClass(ClassLoader.java:264)

         atjava.lang.ClassLoader.loadClassInternal(ClassLoader.java:332)

         ... 10more

 

    }

# 總結1

對比能夠知道，使用try-catch以後能夠看到原來看不到的更重要的異常信息：Caused by: java.lang.ClassNotFoundException:org.apache.commons.collections.CursorableLinkedList

，而後咱們就知道是導入commons-collections-3.2.jar這樣的jar包了，而後就搞定了，不解釋，一個坑爹的問題，缺乏jar包，也能夠說是本身粗心吧！

但願能夠幫到也碰到這樣問題的朋友、、、

 

 

public void testGet() {  
        Jedis jedis = null;   
        try {  
            // 從池中獲取一個jedis實例  
            jedis = jedisPool.getResource();  
            System.out.println(jedis.get("blog_pool"));  
        } catch (Exception e) {  
            // 銷燬對象  
            jedisPool.returnBrokenResource(jedis);  
            Assert.fail(e.getMessage());  
        } finally {  
            // 還會到鏈接池  
            jedisPool.returnResource(jedis);  
        }  
    }

 

package com.ljq.utils;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**   
 * Redis操做接口
 *
 * @author 林計欽
 * @version 1.0 2013-6-14 上午08:54:14   
 */
public class RedisAPI {
    private static JedisPool pool = null;
    
    /**
     * 構建redis鏈接池
     * 
     * @param ip
     * @param port
     * @return JedisPool
     */
    public static JedisPool getPool() {
        if (pool == null) {
            JedisPoolConfig config = new JedisPoolConfig();
            //控制一個pool可分配多少個jedis實例，經過pool.getResource()來獲取；
            //若是賦值爲-1，則表示不限制；若是pool已經分配了maxActive個jedis實例，則此時pool的狀態爲exhausted(耗盡)。
            config.setMaxActive(500);
            //控制一個pool最多有多少個狀態爲idle(空閒的)的jedis實例。
            config.setMaxIdle(5);
            //表示當borrow(引入)一個jedis實例時，最大的等待時間，若是超過等待時間，則直接拋出JedisConnectionException；
            config.setMaxWait(1000 * 100);
            //在borrow一個jedis實例時，是否提早進行validate操做；若是爲true，則獲得的jedis實例均是可用的；
            config.setTestOnBorrow(true);
            pool = new JedisPool(config, "192.168.2.191", 8888);
        }
        return pool;
    }
    
    /**
     * 返還到鏈接池
     * 
     * @param pool 
     * @param redis
     */
    public static void returnResource(JedisPool pool, Jedis redis) {
        if (redis != null) {
            pool.returnResource(redis);
        }
    }
    
    /**
     * 獲取數據
     * 
     * @param key
     * @return
     */
    public static String get(String key){
        String value = null;
        
        JedisPool pool = null;
        Jedis jedis = null;
        try {
            pool = getPool();
            jedis = pool.getResource();
            value = jedis.get(key);
        } catch (Exception e) {
            //釋放redis對象
            pool.returnBrokenResource(jedis);
            e.printStackTrace();
        } finally {
            //返還到鏈接池
            returnResource(pool, jedis);
        }
        
        return value;
    }
}


 

 

代碼說明：
a、獲取jedis實例時，實際上可能有兩類錯誤。
一類是pool.getReource()，得不到可用的jedis實例；
另外一類是jedis.set/get時出錯也會拋出異常；
爲了實現區分，因此根據instance是否爲null來實現，若是爲空就證實instance根本就沒初始化，也就不用return給pool；若是instance不爲null，則證實是須要返還給pool的；

b、在instance出錯時，必須調用returnBrokenResource返還給pool，不然下次經過getResource獲得的instance的緩衝區可能還存在數據，出現問題！

-------------------------------------------------

JedisPool的配置參數很大程度上依賴於實際應用需求、軟硬件能力。之前沒用過commons-pool，因此此次花了一成天專門看這些參數的含義。。。JedisPool的配置參數大部分是由JedisPoolConfig的對應項來賦值的。

maxActive：控制一個pool可分配多少個jedis實例，經過pool.getResource()來獲取；若是賦值爲-1，則表示不限制；若是pool已經分配了maxActive個jedis實例，則此時pool的狀態爲exhausted。

maxIdle：控制一個pool最多有多少個狀態爲idle(空閒)的jedis實例；

whenExhaustedAction：表示當pool中的jedis實例都被allocated完時，pool要採起的操做；默認有三種。
WHEN_EXHAUSTED_FAIL --> 表示無jedis實例時，直接拋出NoSuchElementException；
WHEN_EXHAUSTED_BLOCK --> 則表示阻塞住，或者達到maxWait時拋出JedisConnectionException；
WHEN_EXHAUSTED_GROW --> 則表示新建一個jedis實例，也就說設置的maxActive無用；

maxWait：表示當borrow一個jedis實例時，最大的等待時間，若是超過等待時間，則直接拋出JedisConnectionException；

testOnBorrow：在borrow一個jedis實例時，是否提早進行alidate操做；若是爲true，則獲得的jedis實例均是可用的；

testOnReturn：在return給pool時，是否提早進行validate操做；

testWhileIdle：若是爲true，表示有一個idle object evitor線程對idle object進行掃描，若是validate失敗，此object會被從pool中drop掉；這一項只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

timeBetweenEvictionRunsMillis：表示idle object evitor兩次掃描之間要sleep的毫秒數；

numTestsPerEvictionRun：表示idle object evitor每次掃描的最多的對象數；

minEvictableIdleTimeMillis：表示一個對象至少停留在idle狀態的最短期，而後才能被idle object evitor掃描並驅逐；這一項只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

softMinEvictableIdleTimeMillis：在minEvictableIdleTimeMillis基礎上，加入了至少minIdle個對象已經在pool裏面了。若是爲-1，evicted不會根據idle time驅逐任何對象。若是minEvictableIdleTimeMillis>0，則此項設置無心義，且只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

lifo：borrowObject返回對象時，是採用DEFAULT_LIFO（last in first out，即相似cache的最頻繁使用隊列），若是爲False，則表示FIFO隊列；

其中JedisPoolConfig對一些參數的默認設置以下： testWhileIdle=true minEvictableIdleTimeMills=60000 timeBetweenEvictionRunsMillis=30000 numTestsPerEvictionRun=-1

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程