redis ZSet php,php使用redis的有序集合zset实现延迟队列

一时失言乱红尘 2023-01-16 06:44 128阅读 0赞

搜索热词

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

延迟队列的应用场景：

1、新用户注册，10分钟后发送邮件或站内信。

2、用户下单后，30分钟未支付，订单自动作废。

我们通过redis的有序集合zset来实现简单的延迟队列，将消息数据序列化，作为zset的value，把消息处理时间作为score，每次通过zRangeByscore获取一条消息进行处理。

class 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,time(),\['limit' => \[0,1\]\]);

\}

public function addTask($name,$time,$data)

\{

//添加任务，以时间作为score，对任务队列按时间从小到大排序

return $this->redis->zAdd(

$this->key,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脚本，用来处理队列中的任务。

set\_time\_limit(0);

$dq = new DelayQueue('close\_order',\]);

while (true) \{

$dq->run();

usleep(100000);

\}

总结

如果觉得编程之家网站内容还不错，欢迎将编程之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。

发表评论取消回复

表情：

评论列表（有 0 条评论，128人围观）

还没有评论，来说两句吧...

相关阅读

相关【Redis】深入探索 Redis 的数据类型 —— 有序集合 ZSet

文章目录一、ZSet 类型介绍二、ZSet（有序集合）类型相关命令 2.1 ZADD 2.2 ZCARD 和 ZCOUNT

超、凢脫俗/ 2023年10月15日 22:56/ 0 赞/ 134 阅读

相关 redis ZSet php,php使用redis的有序集合zset实现延迟队列

搜索热词延迟队列就是个带延迟功能的消息队列，相对于普通队列，它可以在指定时间消费掉消息。延迟队列的应用场景： 1、新用户注册，10分钟后发送邮件或站内信。 2、用户

一时失言乱红尘/ 2023年01月16日 06:44/ 0 赞/ 129 阅读

相关 redis 有序集合zset命令

备注:测试版本 redis 4.0.9 文章目录有序集合(sorted set)命令概述 1.1 ZADD命令 1.2 ZCARD命令

怼烎@/ 2022年12月21日 03:15/ 0 赞/ 484 阅读

相关 redis：有序集合zset

介绍有序集合保留了集合不能有重复成员的特性，但不同的是，有序集合中的元素可以排序。但是它和列表使用索引下标作为排序依据不同的是，它给每个元素设置一个分数（score）作

怼烎@/ 2022年09月15日 06:13/ 0 赞/ 243 阅读

相关通过redis的zset实现延迟任务

需求背景：【已付款】的订单7天后自动变更为【已完成】。 @RunWith(SpringRunner.class) @SpringBootTest(classe

Bertha 。/ 2022年09月11日 08:19/ 0 赞/ 8 阅读

相关 Redis使用hash(哈希)和zset(有序集合)

1,hset 描述：将哈希表key中的域field的值设为value。如果key不存在，一个新的哈希表被创建并进行HSET操作。如果域field已经存在于哈希表中，旧值将被覆

旧城等待，/ 2022年03月21日 04:55/ 0 赞/ 400 阅读

相关 Redis基本数据类型-zset(有序集合)

文章目录 zset（有序列表）列表、集合和有序集合三者的异同点 zset使用方法 zadd zcount zr

喜欢ヅ旅行/ 2022年02月17日 10:23/ 0 赞/ 387 阅读

相关 Redis学习笔记 - 有序集合对象zset

参考：<<Redis设计与实现>> 注：这本书是基于Redis3.0版本写的，和后面的版本有点差异有序集合对象的编码是： zip

￡神魔★判官ぃ/ 2021年12月14日 12:37/ 0 赞/ 916 阅读

相关 python redis详解(七)ZSET有序集合

redis有序集合： Redis zset 和 set 一样也是string类型元素的集合,且不允许重复的成员。不同的是每个元素都会关联一个double类型的分数。red

我不是女神ヾ/ 2021年12月10日 11:39/ 0 赞/ 889 阅读

相关 redis之有序集合类型（Zset）——排行榜的实现

[https://blog.csdn.net/loophome/article/details/50373202][https_blog.csdn.net_loophome_a

偏执的太偏执、/ 2021年09月15日 18:10/ 0 赞/ 628 阅读