本文例項講述了php使用redis的有序集合zset實現延遲佇列。分享給大家供大家參考，具體如下：

延遲佇列就是個帶延遲功能的訊息佇列，相對於普通佇列，它可以在指定時間消費掉訊息。

延遲佇列的應用場景：

1、新使用者註冊，10分鐘後傳送郵件或站內信。

2、使用者下單後，30分鐘未支付，訂單自動作廢。

我們通過redis的有序集合zset來實現簡單的延遲佇列，將訊息資料序列化，作為zset的value，把訊息處理時間作為score，每次通過zRangeByScore獲取一條訊息進行處理。

<?php
class DelayQueue
{
  protected $prefix = 'delay_queue:';
  protected $redis = null;
  protected $key = '';
  public function __construct($queue,$config = [])
  {
    $this->key = $this->prefix . $queue;
    $this->redis = new Redis();
    $this->redis->connect($config['host'],$config['port'],$config['timeout']);
    $this->redis->auth($config['auth']);
  }
  public function delTask($value)
  {
    return $this->redis->zRem($this->key,$value);
  }
  public function getTask()
  {
    //獲取任務，以0和當前時間為區間，返回一條記錄
    return $this->redis->zRangeByScore($this->key,time(),['limit' => [0,1]]);
  }
  public function addTask($name,$time,$data)
  {
    //新增任務，以時間作為score，對任務佇列按時間從小到大排序
    return $this->redis->zAdd(
      $this->key,json_encode([
        'task_name' => $name,'task_time' => $time,'task_params' => $data,],JSON_UNESCAPED_UNICODE)
    );
  }
  public function run()
  {
    //每次只取一條任務
    $task = $this->getTask();
    if (empty($task)) {
      return false;
    }
    $task = $task[0];
    //有併發的可能，這裡通過zrem返回值判斷誰搶到該任務
    if ($this->delTask($task)) {
      $task = json_decode($task,true);
      //處理任務
      echo '任務：' . $task['task_name'] . ' 執行時間：' . date('Y-m-d H:i:s') . PHP_EOL;
      return true;
    }
    return false;
  }
}
$dq = new DelayQueue('close_order',[
  'host' => '127.0.0.1','port' => 6379,'auth' => '','timeout' => 60,]);
$dq->addTask('close_order_111',time() + 30,['order_id' => '111']);
$dq->addTask('close_order_222',time() + 60,['order_id' => '222']);
$dq->addTask('close_order_333',time() + 90,['order_id' => '333']);

然後，我們寫一個php指令碼，用來處理佇列中的任務。

<?php
set_time_limit(0);
$dq = new DelayQueue('close_order',]);
while (true) {
  $dq->run();
  usleep(100000);
}

更多關於PHP相關內容感興趣的讀者可檢視本站專題：《php+redis資料庫程式設計技巧總結》、《php面向物件程式設計入門教程》、《PHP基本語法入門教程》、《PHP陣列(Array)操作技巧大全》、《php字串(string)用法總結》、《php+mysql資料庫操作入門教程》及《php常見資料庫操作技巧彙總》

希望本文所述對大家PHP程式設計有所幫助。