Java在使用jedis操作redis資料時，遇到坑，各種查資料解決了將近1天才實現結果。



坑1：

直接在Idea裡面，建TestNG的Test類時，

裡面的多執行緒程式碼，一直會提示報錯，沒有任何提示，直接就test任務結束。

解決方案：使用main建入口的方式進行測試，千萬不要使用testng的@Test註解這種方式進行測試。



原因，估計是多執行緒引起的。怎麼弄還不明白，只能換成main方法裡面去執行多執行緒。



坑2：

多執行緒併發會造成衝突，會報各種錯。



解決方法：使用JRedisPool建立執行緒池。



而且在操作時，使用synchronized把操作方法進行封裝。否則依然會報錯。



坑3
 
：

超出執行緒池容量。1000個執行緒，會報大量的錯。



解決方法：

JedisPoolConfig裡面設定

 //Redis伺服器IP
    private static String ADDR_ARRAY = "127.0.0.1";

    //Redis的埠號
    private static int PORT = 6379;

    //訪問密碼
    private static String AUTH = "";

    //可用連線例項的最大數目，預設值為8；
    //如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis例項，則此時pool的狀態為exhausted(耗盡)。
 

    private static int MAX_ACTIVE = 500;

    //控制一個pool最多有多少個狀態為idle(空閒的)的jedis例項，預設值也是8。
    private static int MAX_IDLE = 100;

    //等待可用連線的最大時間，單位毫秒，預設值為-1，表示永不超時。如果超過等待時間，則直接丟擲JedisConnectionException；
    private static int MAX_WAIT = 10 * 1000;

    private static int TIMEOUT = 10 * 1000;//超時時間

    //在borrow一個jedis例項時，是否提前進行validate操作；如果為true，則得到的jedis例項均是可用的；
 

    private static boolean TEST_ON_BORROW = true;

    private static JedisPool jedisPool = null;

    /**
     * 初始化Redis連線池
     */
    private static void initialPool() {
        try {
            JedisPoolConfig config = new JedisPoolConfig();
            config.setMaxTotal(MAX_ACTIVE);
            config.setMaxIdle(MAX_IDLE);
            config.setMaxWaitMillis(MAX_WAIT);

            config.setTestOnBorrow(TEST_ON_BORROW);//使用時進行掃描，確保都可用

            config.setTestWhileIdle(true);//Idle時進行連線掃描

            config.setTestOnReturn(true);//還回執行緒池時進行掃描
//
////表示idle object evitor兩次掃描之間要sleep的毫秒數
//            config.setTimeBetweenEvictionRunsMillis(30000);
//
////表示idle object evitor每次掃描的最多的物件數
//            config.setNumTestsPerEvictionRun(10);
//
////表示一個物件至少停留在idle狀態的最短時間，然後才能被idle object evitor掃描並驅逐；這一項只有在timeBetweenEvictionRunsMillis大於0時才有意義
//            config.setMinEvictableIdleTimeMillis(60000);

            if (StringUtils.isNotBlank(AUTH)) {
                jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT, AUTH);
            } else {
                jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT);
            }

        } catch (Exception e) {
            logger.error("First create JedisPool error : " + e);
            try {
                //如果第一個IP異常，則訪問第二個IP
                JedisPoolConfig config = new JedisPoolConfig();
                config.setMaxTotal(MAX_ACTIVE);
                config.setMaxIdle(MAX_IDLE);
                config.setMaxWaitMillis(MAX_WAIT);
                config.setTestOnBorrow(TEST_ON_BORROW);
                jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[1], PORT, TIMEOUT, AUTH);
            } catch (Exception e2) {
                logger.error("Second create JedisPool error : " + e2);
            }
        }
    }

    /**
     * 在多執行緒環境同步初始化
     */
    private static synchronized void poolInit() {
        if (jedisPool == null) {
            initialPool();
        }
    }


    /**
     * 同步獲取Jedis例項
     *
     * @return Jedis
     */
    public synchronized static Jedis getJedis() {
        if (jedisPool == null) {
            poolInit();
        }

        Jedis jedis = null;
        try {
            if (jedisPool != null) {
                jedis = jedisPool.getResource();
            }
        } catch (Exception e) {
            logger.error("Get jedis Error : " + e.getMessage(), e);
        } finally {
            returnResource(jedis);//歸還到Redis池裡面
        }
        return jedis;
    }

    /**
     * 釋放jedis資源
     *
     * @param jedis
     */
    public static void returnResource(final Jedis jedis) {
        if (jedis != null && jedisPool != null) {
            jedisPool.returnResource(jedis);
        }
    }

    /**
     * 關閉連線池
     */
    public static void closePool() {
        if (jedisPool != null) {
            jedisPool.close();
        }
    }

    /**
     * 設定 String
     *
     * @param key
     * @param value
     */
    public synchronized static void setString(String key, String value) {
        try {
            value = StringUtils.isEmpty(value) ? "" : value;
            getJedis().set(key, value);
        } catch (Exception e) {
            logger.error("Set key error : " + e);
        }
    }

    /**
     * 設定 過期時間
     *
     * @param key
     * @param seconds 以秒為單位
     * @param value
     */
    public synchronized static void setString(String key, int seconds, String value) {
        try {
            value = StringUtils.isEmpty(value) ? "" : value;
            getJedis().setex(key, seconds, value);
        } catch (Exception e) {
            logger.error("Set keyex error : " + e);
        }
    }

    /**
     * 獲取String值
     *
     * @param key
     * @return value
     */
    public synchronized static String getString(String key) {
        if (getJedis() == null || !getJedis().exists(key)) {
            return null;
        }
        return getJedis().get(key);
    }

}