延遲隊(duì)列就是個(gè)帶延遲功能的消息隊(duì)列，相對于普通隊(duì)列，它可以在指定時(shí)間消費(fèi)掉消息。

延遲隊(duì)列的應(yīng)用場景：

1、新用戶注冊，10分鐘后發(fā)送郵件或站內(nèi)信。

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

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

<?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(){//獲取任務(wù)，以0和當(dāng)前時(shí)間為區(qū)間，返回一條記錄return $this->redis->zRangeByScore($this->key, 0, time(), ['limit' => [0, 1]]);}public function addTask($name, $time, $data){//添加任務(wù)，以時(shí)間作為score，對任務(wù)隊(duì)列按時(shí)間從小到大排序return $this->redis->zAdd($this->key,$time,json_encode(['task_name' => $name,'task_time' => $time,'task_params' => $data,], JSON_UNESCAPED_UNICODE));}public function run(){//每次只取一條任務(wù)$task = $this->getTask();if (empty($task)) {return false;}$task = $task[0];//有并發(fā)的可能，這里通過zrem返回值判斷誰搶到該任務(wù)if ($this->delTask($task)) {$task = json_decode($task, true);//處理任務(wù)echo '任務(wù)：' . $task['task_name'] . ' 運(yùn)行時(shí)間：' . 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']);

然后，我們寫一個(gè)php腳本，用來處理隊(duì)列中的任務(wù)。

<?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); }

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

PHP進(jìn)階架構(gòu)師>>>視頻、面試文檔免費(fèi)獲取?shimo.im

或 者關(guān)注咱們下面的知乎專欄

PHP7進(jìn)階架構(gòu)師?zhuanlan.zhihu.com

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。