php使用redis的有序集合zset实现延迟队列应用示例
本文实例讲述了php使用redis的有序集合zset实现延迟队列。分享给大家供大家参考，具体如下：
延迟队列就是个带延迟功能的消息队列，相对于普通队列，它可以在指定时间消费掉消息。
延迟队列的应用场景：
1、新用户注册，10分钟后发送邮件或站内信。
2、用户下单后，30分钟未支付，订单自动作废。
我们通过redis的有序集合zset来实现简单的延迟队列，将消息数据序列化，作为zset的value，把消息处理时间作为score，每次通过zRangeByScore获取一条消息进行处理。
key=$this->prefix.$queue;
$this->redis=newRedis();
$this->redis->connect($config['host'],$config['port'],$config['timeout']);
$this->redis->auth($config['auth']);
}
publicfunctiondelTask($value)
{
return$this->redis->zRem($this->key,$value);
}
publicfunctiongetTask()
{
//获取任务，以0和当前时间为区间，返回一条记录
return$this->redis->zRangeByScore($this->key,0,time(),['limit'=>[0,1]]);
}
publicfunctionaddTask($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)
);
}
publicfunctionrun()
{
//每次只取一条任务
$task=$this->getTask();
if(empty($task)){
returnfalse;
}
$task=$task[0];
//有并发的可能，这里通过zrem返回值判断谁抢到该任务
if($this->delTask($task)){
$task=json_decode($task,true);
//处理任务
echo'任务：'.$task['task_name'].'运行时间：'.date('Y-m-dH:i:s').PHP_EOL;
returntrue;
}
returnfalse;
}
}
$dq=newDelayQueue('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脚本，用来处理队列中的任务。
'127.0.0.1',
'port'=>6379,
'auth'=>'',
'timeout'=>60,
]);
while(true){
$dq->run();
usleep(100000);
}
更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。