使用 Redis 实现延时队列
使用 Redis 实现延时队列
场景描述：订单在下单之后一定时间内没有支付，则关闭该订单
实现方式：用户下单-> 生成订单记录-> 将订单信息推入延时队列任务中-> 到时间检查订单的支付状态(未支付则关闭订单)
使用redis 实现延时队列 的功能
思路： 用户在调用延时任务的方法时，需要传入两个参数（任务脚本，延时时间）。
通过redis 有序集合来存储执行时间，每次取出第一个元素，执行时间与当前时间对比，如果小于等于当前时间则执行改脚本。并且移除改元素。 由于redis 集合具有唯一性，所以不能放在一个表里。
- string 类型的message_id 用来实现生成唯一id ，作为2和3连接的枢纽
- 有序集合类型 message_delay 存储执行时间
- hash 类型存储任务
首先，创建一个queue 文件：
//连接Redis
$redis = new Redis();
$redis->connect('107.0.0.1', 6379);//这里没有设置登录账号
//这里只是用来测试，job 应是一个实例
$job = 4;
$delay = 10*60; //延时时间单位改为分钟。
queue($job,$delay,$redis);
//入队列
function queue($job,$delay,$redis){
$num = $redis->INCR("message_id");
$redis->ZADD("message_delay", time()+$delay, $num);
$redis->HSET("messages",$num,$job);
}创建job 文件
//连接Redis
$redis = new Redis();
$redis->connect('107.0.0.1', 6379);//这里没有设置登录账号
function queuePush($redis){
$uids_d = $redis->ZRANGE("message_delay", 0, 0, TRUE);//取出一个元素
foreach($uids_d as $key => $val){
if($val <= time()){
//移除delay 和 message 数据
$redis->zrem("message_delay",$key);
$redis->HDEL("messages",$key);
return queuePush($redis); //递归调用
}else{
return false;
}
}
}最后将你的 job.php 文件放到定时任务中就可以了。
这里只是一个实现思路，实际中应该使用面向对象的方法去实现。并且进行优化。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2020-05-23，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis（TencentDB for Redis）是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备，提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。