借助Swoole定时过期未支付订单

借助Swoole定时过期未支付订单

author: he xiaodong date: 2019-02-24

借助 swoole 定时器和 redis 的 zset 来实现的定时检查并过期未支付订单

  起源于一个需求:将30分钟内未支付的订单过期处理成已失效状态。

  最常规简单的解决方案:在服务器上,跑一个定时任务,去数据表中查询数据,查到未支付的订单,update 一下这些数据的状态, 这些数据也可以存在在 redis 中,大致操作都是这样的。数据量少,服务器没有很多压力的时候,这几种方案不会突出优劣,想用哪个用哪个。

  另一种方案: 存储部分:借助 redis 的 zset 有序集合,订单产生的时候,zadd orders timestamp orderid 将 orderid 保存到对应的 orders 集合中,以时间戳作为他的 score 分值,存储部分是这样的,简单 + 占用空间内存极小。读取部分: 在 swoole 启动时,设置定时器,每分钟去 orders set 中读取设置的时间之前的数据,个人为了测试方便,设置的读取前一分钟到前三十分钟内的数据。获取到数据之后,根据业务逻辑处理数据,然后 zrem orders orderid 命令从集合中移除对应的 orderid。个人以为这个方案是内存占用和效率兼具的一个方案。 代码如下:

order.php

<?php
$server = new swoole_websocket_server("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 有序集合中不断写入新数据,效果如下图:

swoole 定时器查询需要处理的未支付订单

延伸阅读:

  1. swoole_timer_tick 文档
  2. laravel china上的相关文章

©原创文章