/**
 * 互斥鎖建立緩存
 *
 **/
public String get(String key) {
   // redis中查詢key對應(yīng)的value
   String value = redis.get(key);
   // 緩存未命中
   if (value == null) {
      // 互斥鎖
      String key_mutex_lock = "mutex:lock" + key; 
      // 互斥鎖加鎖成功
      if(redis.setnx(key_mutex_lock,"1")) { // 返回 0（false）,1（true）
          try {
              // 設(shè)置互斥鎖超時時間,這里設(shè)置的是鎖的失效時間,而不是key的失效時間
              redis.expire(key_mutex_lock,3*60);
              // 從數(shù)據(jù)庫查詢
              value = db.get(key);
              // 數(shù)據(jù)寫入緩存
              redis.set(key,value);
            
          } finally {
               // 釋放鎖
              boolean keyExist = jedis.exists(key_mutex_lock);
              if(keyExist){
                  redis.delete(key_mutex_lock);
               }
      } else { 
              // 加鎖失敗,線程休息50ms后重試
               Thread.sleep(50);
               return get(key); // 直接返回緩存結(jié)果  
     }
   }
}

/**
  *  異步重建緩存: ValueObject為對應(yīng)的封裝的實(shí)體模型
  *
  **/
public String get(String key) {
    // 重緩存中查詢key對應(yīng)的ValueObject對象
    ValueObject valueObject = redis.get(key);
    // 獲取存儲中對應(yīng)的value值
    String value = valueObject.getValue();
    // 獲取實(shí)體模型中的緩存過期的時間：timeOut = 設(shè)置緩存時的當(dāng)前時間+過期時間(如30秒,60秒等等)
    long logicTimeOut = valueObject.getTimeOut();  // 等位換算為long類型
    // 當(dāng)前可以在邏輯上失效
    if (logicTimeOut <= System.currentTimeMillis()) {
         // 異步更新緩存
         threadPool.execute(new Runnable() {
             String key_mutex_lock = "mutex_lock" + key;
              // 互斥鎖加鎖成功
      if(redis.setnx(key_mutex_lock,"1")) { // 返回 0（false）,1（true）
          try {
              // 設(shè)置互斥鎖超時時間,這里設(shè)置的是鎖的失效時間,而不是key的失效時間
              redis.expire(key_mutex_lock,3*60);
              // 從數(shù)據(jù)庫查詢
              dbValue = db.get(key);
              // 數(shù)據(jù)寫入緩存
              redis.set(key,dbValue);
            
          } finally {
              // 釋放鎖
              boolean keyExist = jedis.exists(key_mutex_lock);
              if(keyExist){
                  redis.delete(key_mutex_lock);
               }
             
         }
      } else { 
             
              
             }
             
         
         });
       return value; // 直接返回緩存結(jié)果  
    }
}