当前位置:首页 > PHP > 正文内容

thinkphp3定时任务,tp定时任务,thinkphp定时任务

高老师6年前 (2020-02-29)PHP2578

本教程使用的定时任务基于EasyTak,EasyTask官方文档:https://gitee.com/392223903/EasyTask

由于tp3.2.x官方开发未考虑命令行支持和绝对路径开发的标准,因此我编写了一个支持的类来运行。

1.在tp3.2.3根目录下安装easytask

composer require easy-task/easy-task

2.创建一个执行命令行的入口文件:console.php

<?php

class ThinkSupport
{
    /**
     * argv
     * @var mixed
     */
    private $argv;

    /**
     * argc
     * @var mixed
     */
    private $argc;

    /**
     * action
     * @var string
     */
    private $action;

    /**
     * force
     * @var string
     */
    private $force;

    /**
     * Support constructor.
     */
    public function __construct()
    {
        //重置工作目录(only_win_system)
        chdir(dirname(__FILE__));

        //保存Cli_Input
        $this->argv = $_SERVER['argv'];
        $this->argc = $_SERVER['argc'];

        //保存命令并清空Cli_Input
        $this->action = isset($_SERVER['argv']['1']) ? $_SERVER['argv']['1'] : '';
        $this->force = isset($_SERVER['argv']['2']) ? $_SERVER['argv']['2'] : '';
        $_SERVER['argv'] = [] && $_SERVER['argc'] = 0;

        //抑制Tp错误
        if (!isset($_SERVER['REMOTE_ADDR'])) $_SERVER['REMOTE_ADDR'] = '127.0.0.1';
        if (!isset($_SERVER['REQUEST_URI'])) $_SERVER['REQUEST_URI'] = 'localhost';
    }

    /**
     * 加载Think代码
     * @param Closure $think
     * @return ThinkSupport
     */
    public function invokeThink($think)
    {
        ob_start();
        $think();
        ob_get_clean();
        return $this;
    }

    /**
     * 加载你的代码
     * @param Closure $code
     */
    public function invokeYourCode($code)
    {
        //恢复Cli_Input.(方便自己扩展)
        $_SERVER['argv'] = $this->argv;
        $_SERVER['argc'] = $this->argc;

        //执行
        $code($this->action, $this->force);
    }
}

/**
 * Demo
 */
(new ThinkSupport())
    ->invokeThink(function () {
        //加载tp的代码
        require './index.php';
    })
    ->invokeYourCode(function ($action, $force) {

        // 加载Composer
        require './vendor/autoload.php';

        // 初始化
        $task = new \EasyTask\Task();

        // 设置项目名称
        $task->setPrefix('Think');

        // 设置后台运行
        $task->setDaemon(false);

        // 设置日志保存目录
        $task->setRunTimePath('./Application/Runtime/');

        // 添加闭包任务,开2个进程10s执行1次访问网址
        $task->addFunc(function () {
            @file_get_contents('http://xingxinghan.cn/?id=6');
        }, 'RenWu1', 10, 2);

        // 添加执行tp控制器的方法,开1个进程15s执行1次访问网址
        $task->addClass('\Home\Controller\IndexController', 'curl', 'RenWu2', 15, 1);

        // 添加执行系统命令的任务,启动2个进程每隔5s执行一次
        $task->addCommand('php D:/wwwroot/thinkphp_3.2.3_core/test.php', 'RenWu3', 5, 2);

        // 根据命令执行
        if ($action == 'start')
        {
            $task->start();
        }
        if ($action == 'status')
        {
            $task->status();
        }
        if ($action == 'stop')
        {
            $force = ($force == 'force'); //是否强制关闭
            $task->stop($force);
        }
    });

3.执行定时任务命令(windows用powershell执行)

php ./console.php  start

启动成功输出任务表格

4.查询定时任务(windows用powershell执行)

php ./console.php  status

成功输出任务表格

5.关闭定时任务(windows用powershell执行)

php ./console.php  stop

6.强制关闭定时任务(windows用powershell执行)

php ./console.php  stop  force

警告: 由于tp在命令行执行必须要加载一下自己的默认方法,默认方法就是index控制器的index方法,因此此方法必须存在。或者你可以把它设置为空方法。当然如果比并不需要再任务中执行tp的控制器方法,不需要加载tp的东西,可以不执行invokeThink方法。

提示:后台执行失败可修改为前台启动查看问题或者查看日志文件,有问题可以在qq群反馈bug。记得用星星支持我们哦。

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/124.html

分享给朋友:

“thinkphp3定时任务,tp定时任务,thinkphp定时任务” 的相关文章

php多进程,php多进程处理任务,php多进程应用场景

php多进程,php多进程处理任务,php多进程应用场景

php多进程应用场景主要是非web端,fpm下是不支持多进程的,非类linux操作系统都不支持,请在cli模式使用.可以使用多进程做任务分发,批量计算,批量文件处理,批量爬虫,网络运维等等。下面看一份简单的入门demo//创建子进程 $pid=pcntl_fork(); //返回-1,创建失败,不...

 php监听事件,php触发事件

php监听事件,php触发事件

逛公众号文章看到文章"php实现事件监听与触发的方法,你用过吗?",我就好奇了,php又不是asp.net的webform,哪里来的服务端事件监听。于是学习了一波。先看下监听类:class Event {     /** &nbs...

redis订阅和发布,redis消息订阅与发布, phpredis订阅和发布

redis订阅和发布,redis消息订阅与发布, phpredis订阅和发布

Redis提供了发布订阅功能,可以用于消息的传输,Redis的发布订阅机制包括三个部分,发布者(publisher),订阅者(subscriber)和频道(channel)。 发布者和订阅者都是Redis客户端,Channel则为Redis服务器端,发布者将消息发送到某个的频道,订阅了这个...

php多进程实现任务管理器,定时执行任务,支持守护

php多进程实现任务管理器,定时执行任务,支持守护

主要原理是通过PHP创建多个子进程,在子进程中发送进程闹钟信号,然后再监听闹钟信号中继续发送闹钟信号。同时通过父进程设置非阻塞运行。代码如下:<?php /**  * 订单任务  */ class Order {    &n...

php json_encode 使用注意

php json_encode 使用注意

参数中包含gb2312的字符串,返回结果是false或者null(不同PHP版本具有差异性)代码:<?php $dbms = 'mysql'; $host = '192.168.8.8'; $dbName =&n...

PHP最快方式模拟curl,PHP最快爬虫模拟方法

PHP最快方式模拟curl,PHP最快爬虫模拟方法

有时候我们需要爬一个接口,但是这个接口需要很多参数,包括header和cookie要去编写,使用php curl模拟实在太慢。我们可以通过浏览器的network来复制请求为curl命令。例如我需要模拟请求接口地址:https://www.xkmz.cc/Ajax/Debug/delly,我们只需要在...