接着来看一下出队的代码分析：出队一个Task，需要指定它的$id 和 $score，如果$score与队列中的匹配则出队，否则认为该Task已被重新入队过，当前操作按失败处理。首先和对参数进行合法性检测，接着又用到加锁的功能了，然后及时出队了，先使用getScore()从Redis里获取到该id的score，然后将传入的$score和Redis里存储的score进行对比，如果两者相等就进行出队操作，也就是使用zset里的delete()方法删掉该任务id，最后当前就是解锁了。这就是出队的代码分析。

1 /** 2 * 出队一个Task，需要指定$id 和 $score 3 * 如果$score 与队列中的匹配则出队，否则认为该Task已被重新入队过，当前操作按失败处理 4 * 5 * @param [type] $name 队列名称 6 * @param [type] $id 任务标识 7 * @param [type] $score 任务对应score，从队列中获取任务时会返回一个score，只有$score和队列中的值匹配时Task才会被出队 8 * @param integer $timeout 超时时间(秒) 9 * @return [type] Task是否成功，返回false可能是redis操作失败，也有可能是$score与队列中的值不匹配（这表示该Task自从获取到本地之后被其他线程入队过） dequeue($name, $id, $score, $timeout = 10) { (empty($name) || empty($id) || empty($score)) return false; (!$this->_redis->lock->lock("Queue:$name", $timeout)) { 17 Logger:get('queue')->error("dequeue faild becouse of lock lailure:name=$name, id = $id"); ; 19 } 出队 = $this->_redis->zset->getScore("Queue:$name", $id); 24 $result = false; ($serverScore == $score) { = (float)$this->_redis->zset->delete("Queue:$name", $id); 29 if ($result == false) { 30 Logger::get('queue')->error("dequeue faild because of redis delete failure: name =$name, id = $id"); 31 } 32 } ->_redis->lock->unlock("Queue:$name"); ; 37 }

　　　　学过数据结构这门课的朋友都应该知道，队列操作还有弹出顶部某个值的方法等等，这里处理入队出队操作，我还实现了 获取队列顶部若干个Task 并将其出队的方法，想了解的朋友可以看这段代码，假如看不太明白就留言，这里我不再对其进行分析了。

1 /** 2 * 获取队列顶部若干个Task 并将其出队 3 * @param [type] $name 队列名称 4 * @param integer $count 数量 5 * @param integer $timeout 超时时间 6 * @return [type] 返回数组[0=>['id'=> , 'score'=> ], 1=>['id'=> , 'score'=> ], 2=>['id'=> , 'score'=> ]] pop($name, $count = 1, $timeout = 10) { (empty($name) || $count <= 0) return []; (!$this->_redis->lock->lock("Queue:$name")) { 14 Log::get('queue')->error("pop faild because of pop failure: name = $name, count = $count"); ; 16 } = []; 20 $array = $this->_redis->zset->getByScore("Queue:$name", false, microtime(true), true, false, [0, $count]); (=> $score) { 24 $result[] = ['id'=>$id, 'score'=>$score]; 25 $this->_redis->zset->delete("Queue:$name", $id); 26 } ->_redis->lock->unlock("Queue:$name"); == 1 ? (empty($result) ? false : $result[0]) : $result; 32 }