Jedis操作步驟如下:
1->獲取Jedis實體需要從JedisPool中獲取;
2->用完Jedis實體需要返還給JedisPool;
3->如果Jedis在使用程序中出錯,則也需要還給JedisPool;
代碼如下:
package com.ljq.utils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* Redis操作介面
*
* @author ZXB
* @version 1.0 2020-12-1 上午09:23:36
*/
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
轉載請註明出處,本文鏈接:https://www.uj5u.com/shujuku/229279.html
標籤:其他
上一篇:資料庫
