如果对几种方案没有很好的想法,可以先看一下延伸阅读里的其他方案,是一篇laravel china社区的讨论
借助 swoole 定时器和 redis 的 zset 来实现的定时检查并过期未支付订单
起源于一个需求:将30分钟内未支付的订单过期处理成已失效状态。
最常规简单的解决方案:在服务器上,跑一个定时任务,去数据表中查询数据,查到未支付的订单,update 一下这些数据的状态,
这些数据也可以存在在 redis 中,大致操作都是这样的。数据量少,服务器没有很多压力的时候,这几种方案不会突出优劣,想用哪个用哪个。
另一种方案: 存储部分: 借助 redis 的 zset 有序集合,订单产生的时候, zadd orders timestamp orderid 将 orderid 保存到对应的
orders 集合中,以时间戳作为他的 score 分值,存储部分是这样的,简单 + 占用空间内存极小。 读取部分: 在 swoole 启动时,设置定时器,每分钟去 orders set 中读取设置的时间之前的数据,个人为了测试方便,设置的读取前一分钟到前三十分钟内的数据。获取到数据之后,根据业务逻辑处理数据,然后 zrem orders orderid
命令从集合中移除对应的 orderid。 个人以为这个方案是内存占用和效率兼具的一个方案。 代码如下:
order.php
<"0.0.0.0", 9502); // 在定时器中使用协程需要增加此项配置 $server->set( [ 'enable_coroutine' => true ] ); $server->on('workerStart', function ($server, $workerId) { $redis = new Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); // tick 为持续触发的定时器 swoole_timer_tick(10000, function() use ($redis) { $upperLimitTime = strtotime('-1 minute'); $lowerLimitTime = strtotime('-30 minute'); echo '上限时间:' . $upperLimitTime . '下限时间:' . $lowerLimitTime; $result = $redis->zrangebyscore('orders', $lowerLimitTime, $upperLimitTime); var_dump($result); // 根据查询到的 id 进行业务处理,然后 zrem orders orderid 移除处理成功的 orderid }); }); $server->on('message', function (swoole_websocket_server $server, $request) { $server->push($request->fd, "hello"); }); $server->start();
测试过程: php order.php
开启 swoole 监听,然后新起终端,在 redis 的 orders 有序集合中不断写入新数据,效果如下图:
延伸阅读:
1.swoole_timer_tick 文档
2.laravel china上的相关文章
总结
以上所述是小编给大家介绍的使用swoole 定时器变更超时未支付订单状态的解决方案,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?