当前位置：首页 > news >正文

TP8 定时任务yzh52521/http-crontab 教程

news 来源：原创 2024/7/2 23:16:07

官方文档：

https://www.thinkphp.cn/ext/36

源码仓：

http-crontab: 接口化秒级定时任务管理

GitHub - yuanzhihai/http-crontab: 接口化秒级定时任务管理

一、composer 安装

composer require yzh52521/http-crontab

二、启动yzh52521/http-crontab

一定要用composer来打来命令窗口

php think crontab start

三、在TP控制器中发起请求

发送GET、POST、PUT、DELETE等HTTP请求,在TP8的控制器中实现这些功能
HTTP客户端库，如Guzzle。如果之前没有安装，可以通过Composer安装：

要引入：

use GuzzleHttp\Client;

use think\facade\Config;

发起ping请求：

composer require guzzlehttp/guzzle

<?php
namespace app\admin\controller;
use think\facade\Config;
use GuzzleHttp\Client;/**
* @name 定时任务
* @author 峰神
* @date 2024-6-1
*/
class Crontab 
{public function index(){// 使用配置中的参数初始化Guzzle客户端$client = new Client(['base_uri' => config('crontab.base_url'),'timeout'  => 2.0,'headers' => ['key' => config('crontab.safe_key'), // 添加安全密钥到请求头部],]);// 定义任务详情$taskData = ['name'      => 'My New Cron Task','schedule'  => '* * * * *', // 每分钟执行一次'command'   => '/path/to/your/command', // 替换为实际的命令或控制器路由'arguments' => [], // 可选参数'times'     => 0, // 无限次执行];$method = 'GET';// 根据请求方法构造请求$uri = '/crontab/ping';$options = [];$taskData = [];if ('POST' === $method) {// 对于POST请求，我们需要在请求体中发送数据$options['json'] = $taskData;} elseif ('GET' === $method && !empty($taskData)) {// 对于GET请求，我们将数据附加到URL作为查询字符串$query = http_build_query($taskData);$uri .= '?' . $query;}try {// 发起请求$response = $client->request($method, $uri, $options);// 处理响应$responseBody = (string)$response->getBody();$arrayData = json_decode($responseBody, true);dump($arrayData);die;echo "Request response: " . $responseBody;} catch (\Exception $e) {echo "Error sending request: " . $e->getMessage();}}
}

打开/admin/crontab/index

返回：Request response: {"code":200,"data":"pong","msg":"\u4fe1\u606f\u8c03\u7528\u6210\u529f\uff01"}

成功

添加任务例子：

$client = new Client();// 发起POST请求$response = $client->post(config('crontab.base_url').''/crontab/add'', ['headers' => ['key' => Config::get('crontab.safe_key'),'Content-Type' => 'application/x-www-form-urlencoded',],'form_params' => $postData,//'timeout' => 10.0, // 设置请求超时时间（秒）]);// 处理响应$responseBody = (string)$response->getBody();$arrayData = json_decode($responseBody, true);

重点：'form_params' => $postData, $postData=数组

日志

			//日志列表if(!empty($postData['id']) && $url=='/crontab/flow'){// 发起请求$response = $client->request('GET', config('crontab.base_url').$url,['query' => ['page' => $page,'limit' => $limit,'filter' => json_encode(['crontab_id' => $postData['id']]), // 注意：这里假设服务器端能正确解析JSON格式的查询参数],'headers' => ['key' => Config::get('crontab.safe_key'),]]);}else{//其它$response = $client->request('GET', config('crontab.base_url').$url,['headers' => ['key' => Config::get('crontab.safe_key'),]]);}

TP8中引用组件(暂时用不到)