如何使用swoole定時器變更超時未支付訂單狀態(tài)

這篇文章將為大家詳細講解有關如何使用swoole定時器變更超時未支付訂單狀態(tài)，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

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

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

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

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

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

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

order.php

<?php$server = new swoole_websocket_server("0.0.0.0", 9502);
// 在定時器中使用協(xié)程需要增加此項配置
$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ā)的定時器
  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);
    // 根據(jù)查詢到的 id 進行業(yè)務處理，然后 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ù)，效果如下圖：

關于“如何使用swoole定時器變更超時未支付訂單狀態(tài)”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。