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

延遲隊列的應用場景：

1、新用戶注冊，10分鐘后發送郵件或站內信。

2、用戶下單后，30分鐘未支付，訂單自動作廢。

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

<?phpclass 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, 0, time(), ['limit' => [0, 1]]);}public function addTask($name, $time, $data){//添加任務，以時間作為score，對任務隊列按時間從小到大排序return $this->redis->zAdd($this->key,$time,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腳本，用來處理隊列中的任務。

<?phpset_time_limit(0);$dq = new DelayQueue('close_order', ['host' => '127.0.0.1','port' => 6379,'auth' => '','timeout' => 60, ]);while (true) {$dq->run();usleep(100000); }

以上內容希望幫助到大家，很多PHPer在進階的時候總會遇到一些問題和瓶頸，業務代碼寫多了沒有方向感，不知道該從那里入手去提升，對此我整理了一些資料，包括但不限于：分布式架構、高可擴展、高性能、高并發、服務器性能調優、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql優化、shell腳本、Docker、微服務、Nginx等多個知識點高級進階干貨需要的可以免費分享給大家，需要

PHP進階架構師>>>視頻、面試文檔免費獲取?shimo.im

或 者關注咱們下面的知乎專欄

PHP7進階架構師?zhuanlan.zhihu.com

總結

以上是生活随笔為你收集整理的redis延迟队列 实现_php使用redis的有序集合zset实现延迟队列的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。