/**
   * 加鎖
   * @param [type] $name      鎖的標(biāo)識(shí)名
   * @param integer $timeout    循環(huán)獲取鎖的等待超時(shí)時(shí)間，在此時(shí)間內(nèi)會(huì)一直嘗試獲取鎖直到超時(shí)，為0表示失敗后直接返回不等待
   * @param integer $expire     當(dāng)前鎖的最大生存時(shí)間(秒)，必須大于0，如果超過(guò)生存時(shí)間鎖仍未被釋放，則系統(tǒng)會(huì)自動(dòng)強(qiáng)制釋放
   * @param integer $waitIntervalUs 獲取鎖失敗后掛起再試的時(shí)間間隔(微秒)
   * @return [type]         [description]
   */
  public function lock($name, $timeout = 0, $expire = 15, $waitIntervalUs = 100000) {
    if ($name == null) return false;

    //取得當(dāng)前時(shí)間
    $now = time();
    //獲取鎖失敗時(shí)的等待超時(shí)時(shí)刻
    $timeoutAt = $now + $timeout;
    //鎖的最大生存時(shí)刻
    $expireAt = $now + $expire;

    $redisKey = "Lock:{$name}";
    while (true) {
      //將rediskey的最大生存時(shí)刻存到redis里，過(guò)了這個(gè)時(shí)刻該鎖會(huì)被自動(dòng)釋放
      $result = $this->redisString->setnx($redisKey, $expireAt);

      if ($result != false) {
        //設(shè)置key的失效時(shí)間
        $this->redisString->expire($redisKey, $expireAt);
        //將鎖標(biāo)志放到lockedNames數(shù)組里
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      //以秒為單位，返回給定key的剩余生存時(shí)間
      $ttl = $this->redisString->ttl($redisKey);

      //ttl小于0 表示key上沒(méi)有設(shè)置生存時(shí)間（key是不會(huì)不存在的，因?yàn)榍懊鎠etnx會(huì)自動(dòng)創(chuàng)建）
      //如果出現(xiàn)這種狀況，那就是進(jìn)程的某個(gè)實(shí)例setnx成功后 crash 導(dǎo)致緊跟著的expire沒(méi)有被調(diào)用
      //這時(shí)可以直接設(shè)置expire并把鎖納為己用
      if ($ttl < 0) {
        $this->redisString->set($redisKey, $expireAt);
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      /*****循環(huán)請(qǐng)求鎖部分*****/
      //如果沒(méi)設(shè)置鎖失敗的等待時(shí)間 或者 已超過(guò)最大等待時(shí)間了，那就退出
      if ($timeout <= 0 || $timeoutAt < microtime(true)) break;

      //隔 $waitIntervalUs 后繼續(xù) 請(qǐng)求
      usleep($waitIntervalUs);

    }

    return false;
  }

/**
   * 解鎖
   * @param [type] $name [description]
   * @return [type]    [description]
   */
  public function unlock($name) {
    //先判斷是否存在此鎖
    if ($this->isLocking($name)) {
      //刪除鎖
      if ($this->redisString->deleteKey("Lock:$name")) {
        //清掉lockedNames里的鎖標(biāo)志
        unset($this->lockedNames[$name]);
        return true;
      }
    }
    return false;
  }
　　　　在貼上刪除掉所有鎖的方法，其實(shí)都一個(gè)樣，多了個(gè)循環(huán)遍歷而已。
/**
   * 釋放當(dāng)前所有獲得的鎖
   * @return [type] [description]
   */
  public function unlockAll() {
    //此標(biāo)志是用來(lái)標(biāo)志是否釋放所有鎖成功
    $allSuccess = true;
    foreach ($this->lockedNames as $name => $expireAt) {
      if (false === $this->unlock($name)) {
        $allSuccess = false;  
      }
    }
    return $allSuccess;
  }

/**
 *在redis上實(shí)現(xiàn)分布式鎖
 */
class RedisLock {
  private $redisString;
  private $lockedNames = [];

  public function __construct($param = NULL) {
    $this->redisString = RedisFactory::get($param)->string;
  }

  /**
   * 加鎖
   * @param [type] $name      鎖的標(biāo)識(shí)名
   * @param integer $timeout    循環(huán)獲取鎖的等待超時(shí)時(shí)間，在此時(shí)間內(nèi)會(huì)一直嘗試獲取鎖直到超時(shí)，為0表示失敗后直接返回不等待
   * @param integer $expire     當(dāng)前鎖的最大生存時(shí)間(秒)，必須大于0，如果超過(guò)生存時(shí)間鎖仍未被釋放，則系統(tǒng)會(huì)自動(dòng)強(qiáng)制釋放
   * @param integer $waitIntervalUs 獲取鎖失敗后掛起再試的時(shí)間間隔(微秒)
   * @return [type]         [description]
   */
  public function lock($name, $timeout = 0, $expire = 15, $waitIntervalUs = 100000) {
    if ($name == null) return false;

    //取得當(dāng)前時(shí)間
    $now = time();
    //獲取鎖失敗時(shí)的等待超時(shí)時(shí)刻
    $timeoutAt = $now + $timeout;
    //鎖的最大生存時(shí)刻
    $expireAt = $now + $expire;

    $redisKey = "Lock:{$name}";
    while (true) {
      //將rediskey的最大生存時(shí)刻存到redis里，過(guò)了這個(gè)時(shí)刻該鎖會(huì)被自動(dòng)釋放
      $result = $this->redisString->setnx($redisKey, $expireAt);

      if ($result != false) {
        //設(shè)置key的失效時(shí)間
        $this->redisString->expire($redisKey, $expireAt);
        //將鎖標(biāo)志放到lockedNames數(shù)組里
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      //以秒為單位，返回給定key的剩余生存時(shí)間
      $ttl = $this->redisString->ttl($redisKey);

      //ttl小于0 表示key上沒(méi)有設(shè)置生存時(shí)間（key是不會(huì)不存在的，因?yàn)榍懊鎠etnx會(huì)自動(dòng)創(chuàng)建）
      //如果出現(xiàn)這種狀況，那就是進(jìn)程的某個(gè)實(shí)例setnx成功后 crash 導(dǎo)致緊跟著的expire沒(méi)有被調(diào)用
      //這時(shí)可以直接設(shè)置expire并把鎖納為己用
      if ($ttl < 0) {
        $this->redisString->set($redisKey, $expireAt);
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      /*****循環(huán)請(qǐng)求鎖部分*****/
      //如果沒(méi)設(shè)置鎖失敗的等待時(shí)間 或者 已超過(guò)最大等待時(shí)間了，那就退出
      if ($timeout <= 0 || $timeoutAt < microtime(true)) break;

      //隔 $waitIntervalUs 后繼續(xù) 請(qǐng)求
      usleep($waitIntervalUs);

    }

    return false;
  }

  /**
   * 解鎖
   * @param [type] $name [description]
   * @return [type]    [description]
   */
  public function unlock($name) {
    //先判斷是否存在此鎖
    if ($this->isLocking($name)) {
      //刪除鎖
      if ($this->redisString->deleteKey("Lock:$name")) {
        //清掉lockedNames里的鎖標(biāo)志
        unset($this->lockedNames[$name]);
        return true;
      }
    }
    return false;
  }

  /**
   * 釋放當(dāng)前所有獲得的鎖
   * @return [type] [description]
   */
  public function unlockAll() {
    //此標(biāo)志是用來(lái)標(biāo)志是否釋放所有鎖成功
    $allSuccess = true;
    foreach ($this->lockedNames as $name => $expireAt) {
      if (false === $this->unlock($name)) {
        $allSuccess = false;  
      }
    }
    return $allSuccess;
  }

  /**
   * 給當(dāng)前所增加指定生存時(shí)間，必須大于0
   * @param [type] $name [description]
   * @return [type]    [description]
   */
  public function expire($name, $expire) {
    //先判斷是否存在該鎖
    if ($this->isLocking($name)) {
      //所指定的生存時(shí)間必須大于0
      $expire = max($expire, 1);
      //增加鎖生存時(shí)間
      if ($this->redisString->expire("Lock:$name", $expire)) {
        return true;
      }
    }
    return false;
  }

  /**
   * 判斷當(dāng)前是否擁有指定名字的所
   * @param [type] $name [description]
   * @return boolean    [description]
   */
  public function isLocking($name) {
    //先看lonkedName[$name]是否存在該鎖標(biāo)志名
    if (isset($this->lockedNames[$name])) {
      //從redis返回該鎖的生存時(shí)間
      return (string)$this->lockedNames[$name] = (string)$this->redisString->get("Lock:$name");
    }

    return false;
  }

}

/**
   * 入隊(duì)一個(gè) Task
   * @param [type] $name     隊(duì)列名稱
   * @param [type] $id      任務(wù)id（或者其數(shù)組）
   * @param integer $timeout    入隊(duì)超時(shí)時(shí)間(秒)
   * @param integer $afterInterval [description]
   * @return [type]         [description]
   */
  public function enqueue($name, $id, $timeout = 10, $afterInterval = 0) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || $timeout <= 0) return false;

    //加鎖
    if (!$this->_redis->lock->lock("Queue:{$name}", $timeout)) {
      Logger::get('queue')->error("enqueue faild becouse of lock failure: name = $name, id = $id");
      return false;
    }
    
    //入隊(duì)時(shí)以當(dāng)前時(shí)間戳作為 score
    $score = microtime(true) + $afterInterval;
    //入隊(duì)
    foreach ((array)$id as $item) {
      //先判斷下是否已經(jīng)存在該id了
      if (false === $this->_redis->zset->getScore("Queue:$name", $item)) {
        $this->_redis->zset->add("Queue:$name", $score, $item);
      }
    }
    
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return true;

  }

/**
   * 出隊(duì)一個(gè)Task，需要指定$id 和 $score
   * 如果$score 與隊(duì)列中的匹配則出隊(duì)，否則認(rèn)為該Task已被重新入隊(duì)過(guò)，當(dāng)前操作按失敗處理
   * 
   * @param [type] $name  隊(duì)列名稱 
   * @param [type] $id   任務(wù)標(biāo)識(shí)
   * @param [type] $score  任務(wù)對(duì)應(yīng)score，從隊(duì)列中獲取任務(wù)時(shí)會(huì)返回一個(gè)score，只有$score和隊(duì)列中的值匹配時(shí)Task才會(huì)被出隊(duì)
   * @param integer $timeout 超時(shí)時(shí)間(秒)
   * @return [type]      Task是否成功，返回false可能是redis操作失敗，也有可能是$score與隊(duì)列中的值不匹配（這表示該Task自從獲取到本地之后被其他線程入隊(duì)過(guò)）
   */
  public function dequeue($name, $id, $score, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || empty($score)) return false;
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name", $timeout)) {
      Logger:get('queue')->error("dequeue faild becouse of lock lailure:name=$name, id = $id");
      return false;
    }
    
    //出隊(duì)
    //先取出redis的score
    $serverScore = $this->_redis->zset->getScore("Queue:$name", $id);
    $result = false;
    //先判斷傳進(jìn)來(lái)的score和redis的score是否是一樣
    if ($serverScore == $score) {
      //刪掉該$id
      $result = (float)$this->_redis->zset->delete("Queue:$name", $id);
      if ($result == false) {
        Logger::get('queue')->error("dequeue faild because of redis delete failure: name =$name, id = $id");
      }
    }
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $result;
  }

/**
   * 獲取隊(duì)列頂部若干個(gè)Task 并將其出隊(duì)
   * @param [type] $name  隊(duì)列名稱
   * @param integer $count  數(shù)量
   * @param integer $timeout 超時(shí)時(shí)間
   * @return [type]      返回?cái)?shù)組[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]]
   */
  public function pop($name, $count = 1, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || $count <= 0) return []; 
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name")) {
      Log::get('queue')->error("pop faild because of pop failure: name = $name, count = $count");
      return false;
    }
    
    //取出若干的Task
    $result = [];
    $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]);

    //將其放在$result數(shù)組里 并 刪除掉redis對(duì)應(yīng)的id
    foreach ($array as $id => $score) {
      $result[] = ['id'=>$id, 'score'=>$score];
      $this->_redis->zset->delete("Queue:$name", $id);
    }

    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $count == 1 ? (empty($result) ? false : $result[0]) : $result;
  }

/**
 * 任務(wù)隊(duì)列
 * 
 */
class RedisQueue {
  private $_redis;

  public function __construct($param = null) {
    $this->_redis = RedisFactory::get($param);
  }

  /**
   * 入隊(duì)一個(gè) Task
   * @param [type] $name     隊(duì)列名稱
   * @param [type] $id      任務(wù)id（或者其數(shù)組）
   * @param integer $timeout    入隊(duì)超時(shí)時(shí)間(秒)
   * @param integer $afterInterval [description]
   * @return [type]         [description]
   */
  public function enqueue($name, $id, $timeout = 10, $afterInterval = 0) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || $timeout <= 0) return false;

    //加鎖
    if (!$this->_redis->lock->lock("Queue:{$name}", $timeout)) {
      Logger::get('queue')->error("enqueue faild becouse of lock failure: name = $name, id = $id");
      return false;
    }
    
    //入隊(duì)時(shí)以當(dāng)前時(shí)間戳作為 score
    $score = microtime(true) + $afterInterval;
    //入隊(duì)
    foreach ((array)$id as $item) {
      //先判斷下是否已經(jīng)存在該id了
      if (false === $this->_redis->zset->getScore("Queue:$name", $item)) {
        $this->_redis->zset->add("Queue:$name", $score, $item);
      }
    }
    
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return true;

  }

  /**
   * 出隊(duì)一個(gè)Task，需要指定$id 和 $score
   * 如果$score 與隊(duì)列中的匹配則出隊(duì)，否則認(rèn)為該Task已被重新入隊(duì)過(guò)，當(dāng)前操作按失敗處理
   * 
   * @param [type] $name  隊(duì)列名稱 
   * @param [type] $id   任務(wù)標(biāo)識(shí)
   * @param [type] $score  任務(wù)對(duì)應(yīng)score，從隊(duì)列中獲取任務(wù)時(shí)會(huì)返回一個(gè)score，只有$score和隊(duì)列中的值匹配時(shí)Task才會(huì)被出隊(duì)
   * @param integer $timeout 超時(shí)時(shí)間(秒)
   * @return [type]      Task是否成功，返回false可能是redis操作失敗，也有可能是$score與隊(duì)列中的值不匹配（這表示該Task自從獲取到本地之后被其他線程入隊(duì)過(guò)）
   */
  public function dequeue($name, $id, $score, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || empty($score)) return false;
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name", $timeout)) {
      Logger:get('queue')->error("dequeue faild becouse of lock lailure:name=$name, id = $id");
      return false;
    }
    
    //出隊(duì)
    //先取出redis的score
    $serverScore = $this->_redis->zset->getScore("Queue:$name", $id);
    $result = false;
    //先判斷傳進(jìn)來(lái)的score和redis的score是否是一樣
    if ($serverScore == $score) {
      //刪掉該$id
      $result = (float)$this->_redis->zset->delete("Queue:$name", $id);
      if ($result == false) {
        Logger::get('queue')->error("dequeue faild because of redis delete failure: name =$name, id = $id");
      }
    }
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $result;
  }

  /**
   * 獲取隊(duì)列頂部若干個(gè)Task 并將其出隊(duì)
   * @param [type] $name  隊(duì)列名稱
   * @param integer $count  數(shù)量
   * @param integer $timeout 超時(shí)時(shí)間
   * @return [type]      返回?cái)?shù)組[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]]
   */
  public function pop($name, $count = 1, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || $count <= 0) return []; 
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name")) {
      Logger::get('queue')->error("pop faild because of pop failure: name = $name, count = $count");
      return false;
    }
    
    //取出若干的Task
    $result = [];
    $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]);

    //將其放在$result數(shù)組里 并 刪除掉redis對(duì)應(yīng)的id
    foreach ($array as $id => $score) {
      $result[] = ['id'=>$id, 'score'=>$score];
      $this->_redis->zset->delete("Queue:$name", $id);
    }

    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $count == 1 ? (empty($result) ? false : $result[0]) : $result;
  }

  /**
   * 獲取隊(duì)列頂部的若干個(gè)Task
   * @param [type] $name 隊(duì)列名稱
   * @param integer $count 數(shù)量
   * @return [type]     返回?cái)?shù)組[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]]
   */
  public function top($name, $count = 1) {
    //合法性檢測(cè)
    if (empty($name) || $count < 1) return [];

    //取錯(cuò)若干個(gè)Task
    $result = [];
    $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]);
    
    //將Task存放在數(shù)組里
    foreach ($array as $id => $score) {
      $result[] = ['id'=>$id, 'score'=>$score];
    }

    //返回?cái)?shù)組 
    return $count == 1 ? (empty($result) ? false : $result[0]) : $result;    
  }
}

/**
 *在redis上實(shí)現(xiàn)分布式鎖
 */
class RedisLock {
  private $redisString;
  private $lockedNames = [];

  public function __construct($param = NULL) {
    $this->redisString = RedisFactory::get($param)->string;
  }

  /**
   * 加鎖
   * @param [type] $name      鎖的標(biāo)識(shí)名
   * @param integer $timeout    循環(huán)獲取鎖的等待超時(shí)時(shí)間，在此時(shí)間內(nèi)會(huì)一直嘗試獲取鎖直到超時(shí)，為0表示失敗后直接返回不等待
   * @param integer $expire     當(dāng)前鎖的最大生存時(shí)間(秒)，必須大于0，如果超過(guò)生存時(shí)間鎖仍未被釋放，則系統(tǒng)會(huì)自動(dòng)強(qiáng)制釋放
   * @param integer $waitIntervalUs 獲取鎖失敗后掛起再試的時(shí)間間隔(微秒)
   * @return [type]         [description]
   */
  public function lock($name, $timeout = 0, $expire = 15, $waitIntervalUs = 100000) {
    if ($name == null) return false;

    //取得當(dāng)前時(shí)間
    $now = time();
    //獲取鎖失敗時(shí)的等待超時(shí)時(shí)刻
    $timeoutAt = $now + $timeout;
    //鎖的最大生存時(shí)刻
    $expireAt = $now + $expire;

    $redisKey = "Lock:{$name}";
    while (true) {
      //將rediskey的最大生存時(shí)刻存到redis里，過(guò)了這個(gè)時(shí)刻該鎖會(huì)被自動(dòng)釋放
      $result = $this->redisString->setnx($redisKey, $expireAt);

      if ($result != false) {
        //設(shè)置key的失效時(shí)間
        $this->redisString->expire($redisKey, $expireAt);
        //將鎖標(biāo)志放到lockedNames數(shù)組里
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      //以秒為單位，返回給定key的剩余生存時(shí)間
      $ttl = $this->redisString->ttl($redisKey);

      //ttl小于0 表示key上沒(méi)有設(shè)置生存時(shí)間（key是不會(huì)不存在的，因?yàn)榍懊鎠etnx會(huì)自動(dòng)創(chuàng)建）
      //如果出現(xiàn)這種狀況，那就是進(jìn)程的某個(gè)實(shí)例setnx成功后 crash 導(dǎo)致緊跟著的expire沒(méi)有被調(diào)用
      //這時(shí)可以直接設(shè)置expire并把鎖納為己用
      if ($ttl < 0) {
        $this->redisString->set($redisKey, $expireAt);
        $this->lockedNames[$name] = $expireAt;
        return true;
      }

      /*****循環(huán)請(qǐng)求鎖部分*****/
      //如果沒(méi)設(shè)置鎖失敗的等待時(shí)間 或者 已超過(guò)最大等待時(shí)間了，那就退出
      if ($timeout <= 0 || $timeoutAt < microtime(true)) break;

      //隔 $waitIntervalUs 后繼續(xù) 請(qǐng)求
      usleep($waitIntervalUs);

    }

    return false;
  }

  /**
   * 解鎖
   * @param [type] $name [description]
   * @return [type]    [description]
   */
  public function unlock($name) {
    //先判斷是否存在此鎖
    if ($this->isLocking($name)) {
      //刪除鎖
      if ($this->redisString->deleteKey("Lock:$name")) {
        //清掉lockedNames里的鎖標(biāo)志
        unset($this->lockedNames[$name]);
        return true;
      }
    }
    return false;
  }

  /**
   * 釋放當(dāng)前所有獲得的鎖
   * @return [type] [description]
   */
  public function unlockAll() {
    //此標(biāo)志是用來(lái)標(biāo)志是否釋放所有鎖成功
    $allSuccess = true;
    foreach ($this->lockedNames as $name => $expireAt) {
      if (false === $this->unlock($name)) {
        $allSuccess = false;  
      }
    }
    return $allSuccess;
  }

  /**
   * 給當(dāng)前所增加指定生存時(shí)間，必須大于0
   * @param [type] $name [description]
   * @return [type]    [description]
   */
  public function expire($name, $expire) {
    //先判斷是否存在該鎖
    if ($this->isLocking($name)) {
      //所指定的生存時(shí)間必須大于0
      $expire = max($expire, 1);
      //增加鎖生存時(shí)間
      if ($this->redisString->expire("Lock:$name", $expire)) {
        return true;
      }
    }
    return false;
  }

  /**
   * 判斷當(dāng)前是否擁有指定名字的所
   * @param [type] $name [description]
   * @return boolean    [description]
   */
  public function isLocking($name) {
    //先看lonkedName[$name]是否存在該鎖標(biāo)志名
    if (isset($this->lockedNames[$name])) {
      //從redis返回該鎖的生存時(shí)間
      return (string)$this->lockedNames[$name] = (string)$this->redisString->get("Lock:$name");
    }

    return false;
  }

}

/**
 * 任務(wù)隊(duì)列
 */
class RedisQueue {
  private $_redis;

  public function __construct($param = null) {
    $this->_redis = RedisFactory::get($param);
  }

  /**
   * 入隊(duì)一個(gè) Task
   * @param [type] $name     隊(duì)列名稱
   * @param [type] $id      任務(wù)id（或者其數(shù)組）
   * @param integer $timeout    入隊(duì)超時(shí)時(shí)間(秒)
   * @param integer $afterInterval [description]
   * @return [type]         [description]
   */
  public function enqueue($name, $id, $timeout = 10, $afterInterval = 0) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || $timeout <= 0) return false;

    //加鎖
    if (!$this->_redis->lock->lock("Queue:{$name}", $timeout)) {
      Logger::get('queue')->error("enqueue faild becouse of lock failure: name = $name, id = $id");
      return false;
    }
    
    //入隊(duì)時(shí)以當(dāng)前時(shí)間戳作為 score
    $score = microtime(true) + $afterInterval;
    //入隊(duì)
    foreach ((array)$id as $item) {
      //先判斷下是否已經(jīng)存在該id了
      if (false === $this->_redis->zset->getScore("Queue:$name", $item)) {
        $this->_redis->zset->add("Queue:$name", $score, $item);
      }
    }
    
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return true;

  }

  /**
   * 出隊(duì)一個(gè)Task，需要指定$id 和 $score
   * 如果$score 與隊(duì)列中的匹配則出隊(duì)，否則認(rèn)為該Task已被重新入隊(duì)過(guò)，當(dāng)前操作按失敗處理
   * 
   * @param [type] $name  隊(duì)列名稱 
   * @param [type] $id   任務(wù)標(biāo)識(shí)
   * @param [type] $score  任務(wù)對(duì)應(yīng)score，從隊(duì)列中獲取任務(wù)時(shí)會(huì)返回一個(gè)score，只有$score和隊(duì)列中的值匹配時(shí)Task才會(huì)被出隊(duì)
   * @param integer $timeout 超時(shí)時(shí)間(秒)
   * @return [type]      Task是否成功，返回false可能是redis操作失敗，也有可能是$score與隊(duì)列中的值不匹配（這表示該Task自從獲取到本地之后被其他線程入隊(duì)過(guò)）
   */
  public function dequeue($name, $id, $score, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || empty($id) || empty($score)) return false;
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name", $timeout)) {
      Logger:get('queue')->error("dequeue faild becouse of lock lailure:name=$name, id = $id");
      return false;
    }
    
    //出隊(duì)
    //先取出redis的score
    $serverScore = $this->_redis->zset->getScore("Queue:$name", $id);
    $result = false;
    //先判斷傳進(jìn)來(lái)的score和redis的score是否是一樣
    if ($serverScore == $score) {
      //刪掉該$id
      $result = (float)$this->_redis->zset->delete("Queue:$name", $id);
      if ($result == false) {
        Logger::get('queue')->error("dequeue faild because of redis delete failure: name =$name, id = $id");
      }
    }
    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $result;
  }

  /**
   * 獲取隊(duì)列頂部若干個(gè)Task 并將其出隊(duì)
   * @param [type] $name  隊(duì)列名稱
   * @param integer $count  數(shù)量
   * @param integer $timeout 超時(shí)時(shí)間
   * @return [type]      返回?cái)?shù)組[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]]
   */
  public function pop($name, $count = 1, $timeout = 10) {
    //合法性檢測(cè)
    if (empty($name) || $count <= 0) return []; 
    
    //加鎖
    if (!$this->_redis->lock->lock("Queue:$name")) {
      Logger::get('queue')->error("pop faild because of pop failure: name = $name, count = $count");
      return false;
    }
    
    //取出若干的Task
    $result = [];
    $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]);

    //將其放在$result數(shù)組里 并 刪除掉redis對(duì)應(yīng)的id
    foreach ($array as $id => $score) {
      $result[] = ['id'=>$id, 'score'=>$score];
      $this->_redis->zset->delete("Queue:$name", $id);
    }

    //解鎖
    $this->_redis->lock->unlock("Queue:$name");

    return $count == 1 ? (empty($result) ? false : $result[0]) : $result;
  }

  /**
   * 獲取隊(duì)列頂部的若干個(gè)Task
   * @param [type] $name 隊(duì)列名稱
   * @param integer $count 數(shù)量
   * @return [type]     返回?cái)?shù)組[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]]
   */
  public function top($name, $count = 1) {
    //合法性檢測(cè)
    if (empty($name) || $count < 1) return [];

    //取錯(cuò)若干個(gè)Task
    $result = [];
    $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]);
    
    //將Task存放在數(shù)組里
    foreach ($array as $id => $score) {
      $result[] = ['id'=>$id, 'score'=>$score];
    }

    //返回?cái)?shù)組 
    return $count == 1 ? (empty($result) ? false : $result[0]) : $result;    
  }
}