电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

PHP簡易延時隊列的實現流程詳解

瀏覽:138日期:2022-06-05 17:00:41
目錄
  • 需求說明
  • 設計思路
  • 實現
  • 最后說點

需求說明

  • 當用戶申請售后,商家未在n小時內處理,系統自動進行退款。
  • 商家拒絕后,用戶可申請客服介入,客服x天內超時未處理,系統自動退款。
  • 用戶收到貨物,x天自動確認收貨
  • 等等需要延時操作的流程……

設計思路

  • 設計一張隊列表,記錄所有隊列的參數,執行狀態,重試次數
  • 將創建隊列的id 存于redis 中,使用zset有序集合。按照時間戳進行排序
  • 使用croontab定時任務每分鐘執行一次

實現

新建隊列表

CREATE TABLE `delay_queue` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `params` varchar(512) DEFAULT NULL,
  `message` varchar(255) DEFAULT "" COMMENT "執行結果",
  `ext_string` varchar(255) DEFAULT "" COMMENT "擴展字符串,可用于快速檢索。取消該隊列",
  `retry_times` int(2) DEFAULT "0" COMMENT "重試次數",
  `status` int(2) NOT NULL DEFAULT "1" COMMENT "1 待執行, 10 執行成功, 20 執行失敗,30取消執行",
  `created` datetime DEFAULT NULL,
  `modified` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `ext_idx` (`ext_string`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

部分隊列的操作方法,新增隊列、取消隊列、隊列執行成功、隊列執行失敗、隊列重試【重試時間間隔抄的微信支付的異步通知時間】

class DelayQueueService
{
    // 重試時間,最大重試次數 15
    private static $retryTimes = [
15, 15, 30, 3 * 60, 10 * 60, 20 * 60, 30 * 60, 30 * 60, 30 * 60, 60 * 60,
3 * 60 * 60, 3 * 60 * 60, 3 * 60 * 60, 6 * 60 * 60, 6 * 60 * 60,
    ];
	/**
	 * @description 增加隊列至redis
	 * @param $queueId
	 * @param int $delay 需要延遲執行的時間。單位秒
	 * @return void
	 */
	public function addDelayQueue($queueId, int $delay)
	{
	    $time = time() + $delay;
	    $redis = RedisService::getInstance();
	    $redis->zAdd("delay_queue_job", $time, $queueId);
	}
	// 取消redis 隊列
	public function cancelDelayQueue($ext)
	{
	    $row = $query->getRow(); // 使用ext_string 快速檢索到相應的記錄
	    if ($row) {
	$redis = RedisService::getInstance();
	$redis->zRem("delay_queue_job", $row->id);
	$row->status = DelayQueueTable::STATUS_CANCEL;
	$table->save($row);
	    }
	}
	/**
	 * @description 執行成功
	 * @return void
	 */
	public static function success($id, $message = null)
	{
	    $table->update([
	"status" => DelayQueueTable::STATUS_SUCCESS,
	"message" => $message ?? "",
	"modified" => date("Y-m-d H:i:s"),
	    ], [
	"id" => $id,
	    ]);
	}
	/**
	 * @description 執行失敗
	 * @return void
	 */
	public static function failed($id, $message = null)
	{
	    $table->updateAll([
	"status" => DelayQueueTable::STATUS_FAILED,
	"message" => $message ?? "",
	"modified" => date("Y-m-d H:i:s"),
	    ], [
	"id" => $id,
	    ]);
	}
	/**
	 * @description 失敗隊列重試,最大重試15次
	 * @param $id
	 * @return void
	 */
	public static function retry($id)
	{
	    $info = self::getById($id);
	    if (!$info) {
	return;
	    }
	    $retryTimes = ++$info["retry_times"];
	    if ($retryTimes > 15) {
	return;
	    }
	    $entity = [
	"params" => $info["params"],
	"ext_string" => $info["ext_string"],
	"retry_times" => $retryTimes,
	    ];
	    $queueId = $table->save($entity);
	    self::addDelayQueue($queueId, self::$retryTimes[$retryTimes - 1]);
	}
}

在命令行進行任務的運行

public function execute(Arguments $args, ConsoleIo $io)
{
    $startTimestamp = strtotime("-1 days");
    $now = time();
    $redis = RedisService::getInstance();
    $queueIds = $redis->zRangeByScore("delay_queue_job", $startTimestamp, $now);
    if ($queueIds) {
foreach ($queueIds as $id) {
    $info = // 按照隊列id 獲取相應的信息
    if ($info["status"] === DelayQueueTable::STATUS_PADDING) {
$params = unserialize($info["params"]); // 創建記錄的時候,需要試用serialize 將類名,方法,參數序列化
$class = $params["class"];
$method = $params["method"];
$data = $params["data"];
try {
    call_user_func_array([$class, $method], [$data]);
    $redis->zRem("delay_queue_job", $id);
    $msg = date("Y-m-d H:i:s") . " [info] success: $id";
    DelayQueueService::success($id, $msg);
    $io->success($msg);
} catch (Exception $e) {
    $msg = date("Y-m-d H:i:s") . " [error] {$e->getMessage()}";
DelayQueueService::failed($id, $msg);
// 自定義異常code,不進行隊列重試
if (10000 != $e->getCode()) {
    DelayQueueService::retry($id);
}
$io->error($msg);
}
    }
}
    }
}

最后說點

  • 我這邊的系統對實時性要求不高,所以直接使用的是linuxcrond 服務,每分鐘運行一次。如需精確到秒級,可寫一個shell,一分鐘循環執行<=60
  • 因為目前的數據較少,延時隊列加入的只有小部分。所以就在command 里面直接執行更新操作了,后期如果隊列多,且有比較耗時的操作,可考慮把耗時操作單獨放置一個隊列中。本方法只用于將數據塞進隊列。

附上 shell 腳本 一分鐘執行60次

#!/bin/bash
step=2 #間隔的秒數,不能大于60
for (( i = 0; i < 60; i=(i+step) )); do
   echo $i # do something
   sleep $step
done 

到此這篇關于PHP簡易延時隊列的實現流程詳解的文章就介紹到這了,更多相關PHP延時隊列內容請搜索以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持!

標簽: PHP
主站蜘蛛池模板: 空气能暖气片,暖气片厂家,山东暖气片,临沂暖气片-临沂永超暖通设备有限公司 | 扬子叉车厂家_升降平台_电动搬运车|堆高车-扬子仓储叉车官网 | UV-1800紫外光度计-紫外可见光度计厂家-翱艺仪器(上海)有限公司 | 西安文都考研官网_西安考研辅导班_考研培训机构_西安在职考研培训 | 北京亦庄厂房出租_经开区产业园招商信息平台 | 齿轮减速机_齿轮减速电机-VEMT蜗轮蜗杆减速机马达生产厂家瓦玛特传动瑞环机电 | 齿轮减速马达一体式_蜗轮蜗杆减速机配电机-德国BOSERL齿轮减速电动机生产厂家 | YJLV22铝芯铠装电缆-MYPTJ矿用高压橡套电缆-天津市电缆总厂 | 涿州网站建设_网站设计_网站制作_做网站_固安良言多米网络公司 | 贝朗斯动力商城(BRCPOWER.COM) - 买叉车蓄电池上贝朗斯商城,价格更超值,品质有保障! | GEDORE扭力螺丝刀-GORDON防静电刷-CHEMTRONICS吸锡线-上海卓君电子有限公司 | 沈阳真空机_沈阳真空包装机_沈阳大米真空包装机-沈阳海鹞真空包装机械有限公司 | 合肥网带炉_安徽箱式炉_钟罩炉-合肥品炙装备科技有限公司 | 对辊式破碎机-对辊制砂机-双辊-双齿辊破碎机-巩义市裕顺机械制造有限公司 | 插针变压器-家用电器变压器-工业空调变压器-CD型电抗器-余姚市中驰电器有限公司 | 合肥礼品公司-合肥礼品定制-商务礼品定制公司-安徽柏榽商贸有限公司 | 泡沫消防车_水罐消防车_湖北江南专用特种汽车有限公司 | 无线联网门锁|校园联网门锁|学校智能门锁|公租房智能门锁|保障房管理系统-KEENZY中科易安 | 硅PU球场、篮球场地面施工「水性、环保、弹性」硅PU材料生产厂家-广东中星体育公司 | 郑州大巴车出租|中巴车租赁|旅游大巴租车|包车|郑州旅游大巴车租赁有限公司 | 溶氧传感器-pH传感器|哈美顿(hamilton) | 二手色谱仪器,十万分之一分析天平,蒸发光检测器,电位滴定仪-湖北捷岛科学仪器有限公司 | 艺术涂料|木纹漆施工|稻草漆厂家|马来漆|石桦奴|水泥漆|选加河南天工涂料 | 有机废气处理-rto焚烧炉-催化燃烧设备-VOC冷凝回收装置-三梯环境 | 灰板纸、灰底白、硬纸板等纸品生产商-金泊纸业 | 成都LED显示屏丨室内户外全彩led屏厂家方案报价_四川诺显科技 | 小学教案模板_中学教师优秀教案_高中教学设计模板_教育巴巴 | 下水道疏通_管道疏通_马桶疏通_附近疏通电话- 立刻通 | 环氧铁红防锈漆_环氧漆_无溶剂环氧涂料_环氧防腐漆-华川涂料 | 网带通过式抛丸机,,网带式打砂机,吊钩式,抛丸机,中山抛丸机生产厂家,江门抛丸机,佛山吊钩式,东莞抛丸机,中山市泰达自动化设备有限公司 | 保镖公司-私人保镖-深圳保镖公司【环宇兄弟保镖】 | 上海办公室装修,办公楼装修设计,办公空间设计,企业展厅设计_写艺装饰公司 | 旗帜网络笔记-免费领取《旗帜网络笔记》电子书 | 安徽控制器-合肥船用空调控制器-合肥家电控制器-合肥迅驰电子厂 安徽净化板_合肥岩棉板厂家_玻镁板厂家_安徽科艺美洁净科技有限公司 | 医学动画公司-制作3d医学动画视频-医疗医学演示动画制作-医学三维动画制作公司 | 防潮防水通风密闭门源头实力厂家 - 北京酷思帝克门窗 | 电加热导热油炉-空气加热器-导热油加热器-翅片电加热管-科安达机械 | 植筋胶-粘钢胶-碳纤维布-碳纤维板-环氧砂浆-加固材料生产厂家-上海巧力建筑科技有限公司 | 包塑丝_高铁绑丝_地暖绑丝_涂塑丝_塑料皮铁丝_河北创筹金属丝网制品有限公司 | 热闷罐-高温罐-钢渣热闷罐-山东鑫泰鑫智能热闷罐厂家 | 酒精检测棒,数显温湿度计,酒安酒精测试仪,酒精检测仪,呼气式酒精检测仪-郑州欧诺仪器有限公司 |