redis延迟队列 实现_php使用redis的有序集合zset实现延迟队列

延迟队列就是个带延迟功能的消息队列，相对于普通队列，它可以在指定时间消费掉消息。

延迟队列的应用场景：

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实现延迟队列的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。