本教程使用的定时任务基于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。记得用星星支持我们哦。
/** * 计算两点地理坐标之间的距离 * @param Decimal $longitude1 起点经度 * @param Decimal $lati...
项目需要使用websocket推送最新订单,客户服务器非linux不支持swoole,因此使用原生,直接上代码(1).PHP服务端<?php ini_set('error_reporting', E_ALL ^ E_NOTICE); ini_set...
使用php函数array_multisort()即可实现和SQL一样的order by排序. 例如我们需要对会员表按照主键降序排列,年龄升序排列://会员表数据 $list = []; $list[] = ['mid' =>&n...
php arrayaccess 官方的说法是让你能以数组的形式访问对象,对于这种php内置接口一直不太明白有什么用,坚持多看文章,终于理解,特来分享,思路不同,更易于理解。(1).创建一个学生类,并且实现arrayaccess 接口。<?php class studen...
【一】.迭代器迭代是指反复执行一个过程,每执行一次叫做一次迭代。比如下面的代码就叫做迭代:1. <?php 2. $data = ['1', '2', &...
有时候我们需要爬一个接口,但是这个接口需要很多参数,包括header和cookie要去编写,使用php curl模拟实在太慢。我们可以通过浏览器的network来复制请求为curl命令。例如我需要模拟请求接口地址:https://www.xkmz.cc/Ajax/Debug/delly,我们只需要在...