使用swoole 定時(shí)器變更超時(shí)未支付訂單狀態(tài)的解決方案

更新時(shí)間：2019年07月24日 10:01:59 作者：he_xd

本文主要是借助 swoole 定時(shí)器和 redis 的 zset 來實(shí)現(xiàn)的定時(shí)檢查并過期未支付訂單，感興趣的朋友跟隨小編一起看看吧

如果對幾種方案沒有很好的想法，可以先看一下延伸閱讀里的其他方案，是一篇laravel china社區(qū)的討論

借助 swoole 定時(shí)器和 redis 的 zset 來實(shí)現(xiàn)的定時(shí)檢查并過期未支付訂單

起源于一個需求：將30分鐘內(nèi)未支付的訂單過期處理成已失效狀態(tài)。

最常規(guī)簡單的解決方案：在服務(wù)器上，跑一個定時(shí)任務(wù)，去數(shù)據(jù)表中查詢數(shù)據(jù)，查到未支付的訂單，update 一下這些數(shù)據(jù)的狀態(tài)，

這些數(shù)據(jù)也可以存在在 redis 中，大致操作都是這樣的。數(shù)據(jù)量少，服務(wù)器沒有很多壓力的時(shí)候，這幾種方案不會突出優(yōu)劣，想用哪個用哪個。

另一種方案: 存儲部分：借助 redis 的 zset 有序集合，訂單產(chǎn)生的時(shí)候， zadd orders timestamp orderid 將 orderid 保存到對應(yīng)的

orders 集合中，以時(shí)間戳作為他的 score 分值，存儲部分是這樣的，簡單 + 占用空間內(nèi)存極小。讀取部分：在 swoole 啟動時(shí)，設(shè)置定時(shí)器，每分鐘去 orders set 中讀取設(shè)置的時(shí)間之前的數(shù)據(jù)，個人為了測試方便，設(shè)置的讀取前一分鐘到前三十分鐘內(nèi)的數(shù)據(jù)。獲取到數(shù)據(jù)之后，根據(jù)業(yè)務(wù)邏輯處理數(shù)據(jù)，然后 zrem orders orderid 命令從集合中移除對應(yīng)的 orderid。個人以為這個方案是內(nèi)存占用和效率兼具的一個方案。代碼如下：

order.php

<?php$server = new swoole_websocket_server("0.0.0.0", 9502);
// 在定時(shí)器中使用協(xié)程需要增加此項(xiàng)配置
$server->set(
  [
    'enable_coroutine' => true
  ]
);
$server->on('workerStart', function ($server, $workerId) {
  $redis = new Swoole\Coroutine\Redis();
  $redis->connect('127.0.0.1', 6379);
  // tick 為持續(xù)觸發(fā)的定時(shí)器
  swoole_timer_tick(10000, function() use ($redis) {
    $upperLimitTime = strtotime('-1 minute');
    $lowerLimitTime = strtotime('-30 minute');
    echo '上限時(shí)間:' . $upperLimitTime . '下限時(shí)間:' . $lowerLimitTime;
    $result = $redis->zrangebyscore('orders', $lowerLimitTime, $upperLimitTime);
    var_dump($result);
    // 根據(jù)查詢到的 id 進(jìn)行業(yè)務(wù)處理，然后 zrem orders orderid 移除處理成功的 orderid 
  });
});
$server->on('message', function (swoole_websocket_server $server, $request) {
  $server->push($request->fd, "hello");
});
$server->start();

測試過程： php order.php 開啟 swoole 監(jiān)聽，然后新起終端，在 redis 的 orders 有序集合中不斷寫入新數(shù)據(jù)，效果如下圖：