redis之Jedis使用

Redis的Java用戶端Jedis：

Jedis所需要的jar包，commons-pool-1.6.jar、jedis-2.1.0.jar

Jedis常用操作： 測試連通性、 5+1（一個key、五大資料類型）、 事務送出（日常、加鎖） 主從複制，6379,6380啟動，先各自先獨立，主寫、從讀；

JedisPool 擷取Jedis執行個體需要從JedisPool中擷取 用完Jedis執行個體需要返還給JedisPool 如果Jedis在使用過程中出錯，則也需要還給JedisPool 案例見代碼：JedisPoolUtil、jedisPool.getResource(); 配置總結all： 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：獲得一個jedis執行個體的時候是否檢查連接配接可用性（ping()）；如果為true，則得到的jedis執行個體均是可用的； testOnReturn：return 一個jedis執行個體給pool時，是否檢查連接配接可用性（ping()）； 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

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

public class JedisPoolUtil { private static volatile JedisPool jedisPool = null; private JedisPoolUtil(){} public static JedisPool getJedisPoolInstance() { if(null == jedisPool) { synchronized (JedisPoolUtil.class) { if(null == jedisPool) { JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxActive(1000); poolConfig.setMaxIdle(32); poolConfig.setMaxWait(100*1000); poolConfig.setTestOnBorrow(true); jedisPool = new JedisPool(poolConfig,"127.0.0.1",6379); } } } return jedisPool; }

public static void release(JedisPool jedisPool, Jedis jedis) { if(null != jedis) { jedisPool.returnResourceObject(jedis); } } }