您的位置:首页 > 数据库 > Redis

php 利用 redis 有序集合 实现 延时消费 队列

2018-10-24 11:38 429 查看

      简单思路:将使用延时消费的信息存入redis的有序集合中,score 为消费时间,用定时器 根据score 取出符合消费的元素进行(zRangeByScore)

[code]
#延时消费简单逻辑代码
###############################################################
#生产
$key ='延时消费';
$score = time();//取当前时间为分数 score
#如果需要进行更多操作,集合中的元素使用josn 体
$redis->zAdd($key , $score + 10 , 'JOSN1');
$redis->zAdd($key , $score + 20 , 'JOSN2');
$redis->zAdd($key , $score + 30, 'JOSN3');

#消费
$key ='延时消费';
$score = "(" . time();//小于等于
#循环取出
$max_number = 9999;//设定每个进程最多消费数量
$number = 0;//消费数量计数
while ($data = $redis->zRangeByScore($key, 0, $score, ['limit' => [1, 1]])){

if($number++ >= $max_number){
exit;
}

#将分数设置设0,避免重复消费(业务也需要做处理)
$redis->zadd($key,0,$data[0]);
#TODO 处理业务处理 或者进行其他队列

#删除
$redis->zDelete($key,$data[0]);

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: