前往小程序,Get更优阅读体验!
立即前往
发布
社区首页 >专栏 >老雷PHP教程之队列任务

老雷PHP教程之队列任务

作者头像
老雷PHP全栈开发
发布2021-01-04 11:29:19
发布2021-01-04 11:29:19
54600
代码可运行
举报
运行总次数:0
代码可运行

老雷PHP教程之队列任务

一、什么是队列任务

就是按照队列来执行任务,按照先进先出原则执行任务,通过异步执行提升用户体验。

二、实现步骤,以订单为例。

1、发布任务

用户下完单之后,可能需要短信通知商家,或者通知打印机打印订单。

2、获取任务

任务系统获取任务,然后分发给不同任务处理程序去执行。

3、执行任务

具体任务处理程序,接收来自队列任务的委派,然后执行,如果执行出错,判断是重新入队执行还是通知系统出现异常。

三、任务要常驻执行

执行任务的程序不能间断

windows系统 cmd 执行 php task.php

linux系统 php task.php &

代码语言:javascript
代码运行次数:0
复制
<?php
require "file.php";
$que=new queue();
$task=$que->rpop();

if(empty($task)){
    echo "任务执行完了";
}
switch($task["action"]){
    case "sendSms":
        $res=sendSms($que,$task);
        
        break;
    default:
        echo "执行任务";
        break;
}

function sendSms($que,$task){
    $conf=$task["data"];
    $res=rand(0,1);
    if(!isset($task["enum"])){
        $task["enum"]=1;
    }
    if(!$res){
        echo "执行任务出错,出错".$task["enum"]."次";
    }else{
        echo "给".$conf["telephone"]."发送了一条短息".$conf["content"];
    }
    
    if($res==false ){
        if($task["enum"]<3){
            $task["enum"]++;
            $que->rpush($task);
        }else{
            echo " 已将错误反馈给站长";
        }
        
    }
    
}

课后作业:

大家去动手操作队列任务

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2020-12-26,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 老雷PHP全栈开发 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档