Become a sponsor

概述
定时任务系统由三部分组成:JobLogic(调度逻辑)+ BaseTask(任务处理器)+ JobRunCommand(命令行入口)。支持三种触发方式:Linux Crontab、Windows 计划任务、Daemon 守护进程。
┌─────────────────────────────────────────────────────────────────┐
│ 触发层(三选一) │
│ │
│ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │
│ │ Linux Crontab│ │Windows 计划 │ │ Daemon 守护 │ │
│ │ │ │任务 │ │ 进程 │ │
│ │ * * * * * │ │ schtasks │ │ php think │ │
│ │ php think │ │ │ │ job:daemon │ │
│ │ job:run │ │ │ │ │ │
│ └──────┬───────┘ └──────┬───────┘ └──────┬───────┘ │
│ │ │ │ │
│ └─────────────────┼─────────────────┘ │
│ │ │
│ ▼ │
│ ┌─────────────────────────┐ │
│ │ JobRunCommand │ │
│ │ php think job:run │ │
│ │ 或 php think job:daemon│ │
│ └────────────┬────────────┘ │
└───────────────────────────┼─────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────────┐
│ 调度层(JobLogic) │
│ │
│ runPending() shouldRun() │
│ ├─ 查询 status=1 的任务 ├─ 解析 cron 表达式 │
│ ├─ 逐个判断是否到执行时间 ├─ 分 时 日 月 周 逐段匹配 │
│ └─ 到期则执行 └─ 全部匹配返回 true │
│ │
│ executeJob($job) │
│ ├─ 检查执行策略(立即/排队/放弃) │
│ ├─ 调用 doExecute() 实际执行 │
│ ├─ 记录 JobLog 执行日志 │
│ └─ 返回执行结果 │
└───────────────────────────┼─────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────────┐
│ 执行层 │
│ │
│ doExecute($job) │
│ ├─ 判断 URL 类型 │
│ │ │
│ ├─ http:// / https:// → executeHttp() │
│ │ └─ curl 发起 HTTP GET/POST 请求 │
│ │ │
│ └─ 其它 → executeInternal() │
│ └─ 映射到 app\task\{Name}Task::run() │
│ │
│ 示例: │
│ url = "SendSms" → app\task\SendSmsTask::run() │
│ url = "Order/Close" → app\task\Order\CloseTask::run() │
│ url = "https://..." → HTTP GET/POST │
└─────────────────────────────────────────────────────────────────┘| 状态值 | 说明 | 可执行 | 可暂停 | 可启动 |
|---|---|---|---|---|
| 0 | 未发布 | ✗ | ✗ | ✓ |
| 1 | 运行中 | ✓ | ✓ | ✗ |
| 2 | 暂停 | ✗ | ✗ | ✓ |
| 3 | 已删除 | ✗ | ✗ | ✗ |
| 策略值 | 说明 | 行为 |
|---|---|---|
| 1 | 立即执行 | 丢弃之前的执行,立即运行 |
| 2 | 执行一次 | 等待上一次完成后执行 |
| 3 | 放弃执行 | 如果上一次还在运行则跳过 |
枚举文本自动翻译
JobLogic 配置了 serializeMaps,API 响应中会自动包含翻译后的文本字段:
| 原始字段 | 文本字段 | 字典编码 | 说明 |
|---|---|---|---|
status | statusText | job_status | 任务状态(未发布/运行中/暂停/删除) |
execute_policy | executePolicyText | job_execute_policy | 执行策略(立即执行/执行一次/放弃执行) |
字典数据在代码生成器自动创建,也可在「系统管理 → 字典管理」中手动维护。
标准 5 段格式:分 时 日 月 周
┌────────── 分钟(0-59)
│ ┌──────── 小时(0-23)
│ │ ┌────── 日(1-31)
│ │ │ ┌──── 月(1-12)
│ │ │ │ ┌── 周(0-6,0=周日)
│ │ │ │ │
* * * * *| 表达式 | 说明 |
|---|---|
* * * * * | 每分钟 |
0 * * * * | 每小时整点 |
0 0 * * * | 每天 0 点 |
0 2 * * * | 每天凌晨 2 点 |
0 0 * * 1 | 每周一 0 点 |
0 0 1 * * | 每月 1 号 0 点 |
*/5 * * * * | 每 5 分钟 |
0 */2 * * * | 每 2 小时 |
0 9-18 * * 1-5 | 工作日 9-18 点每小时 |
0 2 1,15 * * | 每月 1 号和 15 号凌晨 2 点 |
适用场景
Linux / macOS 服务器,最常用的定时任务触发方式。系统级 cron 每分钟触发一次 PHP 命令。
crontab -e# 每分钟执行一次(推荐)
* * * * * cd /www/api && php think job:run >> /dev/null 2>&1
# 每分钟执行一次,日志写入文件(调试用)
* * * * * cd /www/api && php think job:run >> /var/log/job.log 2>&1
# 每分钟执行一次,带环境变量
* * * * * cd /www/api && /usr/bin/php think job:run >> /dev/null 2>&1路径注意
cd /www/api 必须切换到项目根目录,否则 ThinkPHP 无法找到配置文件php 建议使用绝对路径(如 /usr/bin/php),避免 cron 环境变量不同导致找不到 PHP>> /dev/null 2>&1 表示丢弃输出,调试时可改为写入日志文件# 保存后 cron 自动生效
# 查看已配置的 cron
crontab -l
# 查看 cron 日志(确认是否正常触发)
tail -f /var/log/syslog | grep CRON
# 手动执行一次验证
cd /www/api && php think job:run# 确保 PHP 有权限执行
chmod +x /usr/bin/php
# 确保项目目录权限
chmod -R 755 /www/api/runtime/crontab -e # 编辑当前用户的 cron
crontab -l # 列出当前用户的 cron
crontab -r # 删除当前用户的所有 cron(慎用)
crontab -u username -l # 查看指定用户的 cron/etc/crontab # 系统级 cron 配置
/etc/cron.d/ # 额外的 cron 配置文件目录
/etc/cron.daily/ # 每天执行的脚本
/etc/cron.hourly/ # 每小时执行的脚本
/etc/cron.weekly/ # 每周执行的脚本
/etc/cron.monthly/ # 每月执行的脚本适用场景
Windows Server 或本地开发环境,通过任务计划程序定时触发。
方法1:Win + R → 输入 taskschd.msc → 回车
方法2:控制面板 → 管理工具 → 任务计划程序
方法3:开始菜单搜索"任务计划程序"RXThinkCMF 定时任务每分钟执行一次定时任务扫描1 分钟无限期C:\xampp\php\php.exethink job:runD:\xampp\htdocs\v3\thinkphp6# 手动运行测试
cd D:\xampp\htdocs\v3\thinkphp6
C:\xampp\php\php.exe think job:run
# 在任务计划程序中右键任务 → 运行
# 查看"上次运行结果"是否为 0x0# 创建每分钟执行的任务
schtasks /create /tn "RXThinkCMF_Job" /tr "C:\xampp\php\php.exe think job:run" /sc minute /mo 1 /st 00:00 /f
# 参数说明:
# /tn 任务名称
# /tr 要执行的命令
# /sc 频率:minute(分钟)、hourly(小时)、daily(天)
# /mo 间隔:1 表示每 1 分钟
# /st 开始时间
# /f 强制覆盖同名任务
# 创建任务(指定工作目录)
schtasks /create /tn "RXThinkCMF_Job" /tr "cmd /c cd /d D:\xampp\htdocs\v3\thinkphp6 && C:\xampp\php\php.exe think job:run" /sc minute /mo 1 /f
# 查询任务
schtasks /query /tn "RXThinkCMF_Job"
# 手动运行
schtasks /run /tn "RXThinkCMF_Job"
# 删除任务
schtasks /delete /tn "RXThinkCMF_Job" /f
# 查看所有任务
schtasks /query /fo table常见问题
php.exe 的完整路径>> log.txt 2>&1 重定向输出# 带日志输出的完整命令
schtasks /create /tn "RXThinkCMF_Job" /tr "cmd /c cd /d D:\xampp\htdocs\v3\thinkphp6 && C:\xampp\php\php.exe think job:run >> runtime\job.log 2>&1" /sc minute /mo 1 /f适用场景
需要更精确的执行时机(秒级),或不想依赖系统 cron 的场景。进程常驻内存,自行调度。
Daemon 进程启动
│
▼
┌─────────────────────┐
│ while (true) │ 无限循环
│ │ │
│ ├─ runPending() │ 扫描并执行到期任务
│ ├─ sleep(60) │ 休眠 60 秒
│ └─ 继续循环 │
└─────────────────────┘创建命令文件:
// app/command/JobDaemonCommand.php
<?php
declare(strict_types=1);
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use app\logic\JobLogic;
/**
* 定时任务守护进程命令
*
* 常驻内存运行,每分钟扫描并执行到期任务。
* 建议通过 Supervisor 管理,确保进程异常退出后自动重启。
*
* 用法:php think job:daemon
*/
class JobDaemonCommand extends Command
{
protected function configure(): void
{
$this->setName('job:daemon')
->setDescription('定时任务守护进程(常驻内存)');
}
protected function execute(Input $input, Output $output): void
{
$output->writeln('[' . date('Y-m-d H:i:s') . '] Daemon 启动...');
$logic = new JobLogic();
while (true) {
try {
$count = $logic->runPending();
if ($count > 0) {
$output->writeln('[' . date('Y-m-d H:i:s') . '] 执行了 ' . $count . ' 个任务');
}
} catch (\Exception $e) {
$output->writeln('[' . date('Y-m-d H:i:s') . '] 异常: ' . $e->getMessage());
}
// 休眠 60 秒
sleep(60);
}
}
}Supervisor 配置:
; /etc/supervisor/conf.d/rxthinkcmf-job.conf
[program:rxthinkcmf-job]
command=php /www/api/think job:daemon
directory=/www/api
autostart=true
autorestart=true
user=www-data
numprocs=1
redirect_stderr=true
stdout_logfile=/var/log/rxthinkcmf-job.log
stdout_logfile_maxbytes=10MB
stdout_logfile_backups=5启动:
# 重新加载配置
sudo supervisorctl reread
sudo supervisorctl update
# 启动
sudo supervisorctl start rxthinkcmf-job
# 查看状态
sudo supervisorctl status rxthinkcmf-job
# 重启
sudo supervisorctl restart rxthinkcmf-job
# 查看日志
tail -f /var/log/rxthinkcmf-job.log在项目根目录打开 CMD,执行以下命令:
:: 启动 Daemon(前台运行,关闭窗口则停止)
php think job:daemon
:: 停止 Daemon(另开一个 CMD 窗口执行)
php think job:daemon --stop启动成功输出:
[2026-09-23 09:06:07] Daemon 已启动 (PID: 22720)
[2026-09-23 09:06:07] 每分钟检查一次到期任务,按 Ctrl+C 优雅退出运行过程中的日志输出:
[2026-09-23 11:25:00] [执行] 定时任务演示 (cron: */5 * * * *)
[2026-09-23 11:25:00] [执行] 定时任务案例 (cron: */5 * * * *)
[2026-09-23 11:25:00] 本轮执行完成,共执行 2 个任务
[2026-09-23 11:30:00] [执行] 定时任务演示 (cron: */5 * * * *)
[2026-09-23 11:30:00] [跳过] 定时任务案例 - 当前分钟已执行过
[2026-09-23 11:30:00] 本轮执行完成,共执行 1 个任务日志类型说明:
| 标记 | 含义 |
|---|---|
[执行] | 任务已触发执行,括号内显示 cron 表达式 |
[跳过] | 同一分钟内该任务已执行过,自动跳过(防重复) |
[失败] | 任务执行异常,后跟错误信息 |
本轮执行完成 | 当前分钟的所有任务扫描完毕,显示执行数量 |
提示
[跳过] 是防重复机制,同一任务在同一分钟内只会执行一次[失败] 时检查对应的任务处理器代码,单个任务失败不影响其他任务前端联动: Daemon 启动后,后台管理系统的「定时任务」模块会自动检测到守护进程状态,页面顶部显示:
┌──────────────────────────────────────────────────────┐
│ [新增] [删除] [🟢 守护进程运行中 (PID: 22720)] │
└──────────────────────────────────────────────────────┘状态检测原理
前端通过 GET /api/job/daemonStatus 接口轮询状态,后端读取 runtime/job_daemon.lock 锁文件中的 PID 并检查进程是否存活。因此即使 Daemon 非正常退出(如强制杀进程),只要锁文件残留,前端仍可能显示「运行中」,此时需手动删除 runtime/job_daemon.lock 或执行 php think job:daemon --stop 清理。
Windows 注意事项
pcntl_signal,Ctrl+C 会强制终止进程而非优雅退出php think job:daemon --stop,或关闭 CMD 窗口runtime/job_daemon.lock)防止重复启动,启动前会自动检测并提示 Daemon 已在运行中 (PID: xxx)start /B php think job:daemon,停止时用 php think job:daemon --stop# 后台启动
nohup php /www/api/think job:daemon >> /var/log/job.log 2>&1 &
# 查看进程
ps aux | grep job:daemon
# 停止
kill $(pgrep -f "job:daemon"); /etc/systemd/system/rxthinkcmf-job.service
[Unit]
Description=RXThinkCMF Job Daemon
After=network.target mysql.service
[Service]
Type=simple
User=www-data
WorkingDirectory=/www/api
ExecStart=/usr/bin/php /www/api/think job:daemon
Restart=always
RestartSec=10
[Install]
WantedBy=multi-user.target# 启用并启动
sudo systemctl enable rxthinkcmf-job
sudo systemctl start rxthinkcmf-job
# 查看状态
sudo systemctl status rxthinkcmf-job
# 查看日志
sudo journalctl -u rxthinkcmf-job -f
# 重启
sudo systemctl restart rxthinkcmf-job| 特性 | Crontab | Windows 计划任务 | Daemon 守护进程 |
|---|---|---|---|
| 适用系统 | Linux / macOS | Windows | 全平台 |
| 最小间隔 | 1 分钟 | 1 分钟 | 1 秒 |
| 资源占用 | 低(按需启动) | 低(按需启动) | 常驻内存 |
| 可靠性 | 高 | 高 | 高(配合 Supervisor) |
| 配置复杂度 | 低 | 中 | 低 |
| 日志追踪 | 需重定向 | 任务计划程序 | 自带输出 |
| 推荐场景 | 生产环境 | Windows 生产 | 需要秒级精度 / 开发调试 |
推荐选择
<?php
// app/task/CleanLogTask.php
declare(strict_types=1);
namespace app\task;
/**
* 清理过期日志任务
*
* 数据库 url 字段:CleanLog
* 参数格式:{"days": 30}
*/
class CleanLogTask extends BaseTask
{
/**
* 执行任务
*
* @param array $params 任务参数
* @return string 执行结果消息
* @throws \Exception 执行失败时抛出
*/
public function run(array $params = []): string
{
$days = $params['days'] ?? 30;
$cutoffDate = date('Y-m-d H:i:s', strtotime("-{$days} days"));
// 清理登录日志
$loginCount = \app\model\LoginLog::where('create_time', '<', $cutoffDate)->delete();
// 清理操作日志
$operCount = \app\model\OperationLog::where('create_time', '<', $cutoffDate)->delete();
// 清理任务日志
$jobCount = \app\model\JobLog::where('start_time', '<', $cutoffDate)->delete();
return "已清理 {$days} 天前的日志:登录日志 {$loginCount} 条,操作日志 {$operCount} 条,任务日志 {$jobCount} 条";
}
}INSERT INTO think_job (
job_name, job_alias, job_group, job_trigger,
url, params, cron_expression,
execute_policy, status, is_sync,
is_delete, create_user, create_time
) VALUES (
'清理过期日志', 'CleanLog', '系统维护', 'cron',
'CleanLog', '{"days":30}', '0 2 * * *',
2, 1, 0,
0, 'admin', NOW()
);# 方式一:Linux Crontab
crontab -e
# 添加:* * * * * cd /www/api && php think job:run >> /dev/null 2>&1
# 方式二:Windows 计划任务
schtasks /create /tn "RXThinkCMF_Job" /tr "cmd /c cd /d D:\xampp\htdocs\v3\thinkphp6 && C:\xampp\php\php.exe think job:run" /sc minute /mo 1 /f
# 方式三:Daemon 守护进程
php think job:daemon
# 停止:php think job:daemon --stop| 方法 | 路径 | 权限码 | 说明 |
|---|---|---|---|
| GET | /api/job/page | sys:job:page | 分页列表 |
| GET | /api/job/list | sys:job:list | 全量列表 |
| GET | /api/job/detail/:id | sys:job:detail | 详情 |
| GET | /api/job/runOnce/:id | sys:job:execute | 手动执行一次 |
| GET | /api/job/pause/:id | sys:job:pause | 暂停任务 |
| GET | /api/job/resume/:id | sys:job:resume | 恢复任务 |
| GET | /api/job/daemonStatus | - | 守护进程状态 |
| POST | /api/job/add | sys:job:add | 新增任务 |
| POST | /api/job/status | sys:job:update | 设置状态 |
| PUT | /api/job/update | sys:job:update | 修改任务 |
| DELETE | /api/job/delete/:id | sys:job:delete | 删除任务 |
| DELETE | /api/job/batchDelete | sys:job:batchDelete | 批量删除 |
| 方法 | 路径 | 权限码 | 说明 |
|---|---|---|---|
| GET | /api/job/log/page | sys:job:log:page | 日志分页 |
| GET | /api/job/log/detail/:id | sys:job:log:detail | 日志详情 |
| DELETE | /api/job/log/delete/:id | sys:job:log:delete | 删除日志 |
| DELETE | /api/job/log/batchDelete | sys:job:log:batchDelete | 批量删除 |
// app/logic/JobLogic.php
/**
* 匹配 cron 字段
*
* 支持以下语法:
* - *:匹配所有
* - */n:每隔 n 个单位
* - n-m:范围匹配
* - n,m,...:逗号分隔的多值
* - n:单个值精确匹配
*/
protected function matchCronField(string $cronField, int $current): bool
{
if ($cronField === '*') {
return true;
}
// 处理 */n(每隔 n 分钟/小时等)
if (preg_match('/^\*\/(\d+)$/', $cronField, $m)) {
return $current % (int)$m[1] === 0;
}
// 处理 n-m(范围)
if (preg_match('/^(\d+)-(\d+)$/', $cronField, $m)) {
return $current >= (int)$m[1] && $current <= (int)$m[2];
}
// 处理逗号分隔的多个值
if (strpos($cronField, ',') !== false) {
$values = array_map('intval', explode(',', $cronField));
return in_array($current, $values);
}
// 单个值
return (int)$cronField === $current;
}/**
* 检查任务在当前分钟是否已执行过
*
* Daemon 模式下,防止同一分钟内重复执行。
*/
public function hasRunThisMinute(int $jobId): bool
{
$minuteStart = date('Y-m-d H:i') . ':00';
$minuteEnd = date('Y-m-d H:i') . ':59';
return JobLog::where('job_id', $jobId)
->where('start_time', '>=', $minuteStart)
->where('start_time', '<=', $minuteEnd)
->count() > 0;
}A: 检查以下几点:
1(运行中)php think job:run 是否正常A: Daemon 模式下检查 hasRunThisMinute 是否生效。Crontab 模式下确保只有一个 cron 在触发。
A: 检查 PHP 的 max_execution_time 配置,长时间任务建议使用 Daemon 模式或设置 set_time_limit(0)。
A: 两种方式:
[执行]、[跳过]、[失败] 等日志直接输出到终端/api/job/log/page 查询,或直接查 think_job_log 表A: 不是。Daemon 每分钟检查一次,没有到期任务时静默等待,不输出任何日志。这是正常行为,说明当前没有任务需要执行。
A: 在项目根目录打开 CMD:
:: 启动
php think job:daemon
:: 停止(另开一个 CMD 窗口)
php think job:daemon --stop启动成功输出:
[2026-09-23 09:06:07] Daemon 已启动 (PID: 22720)
[2026-09-23 09:06:07] 每分钟检查一次到期任务,按 Ctrl+C 优雅退出启动后,后台管理系统「定时任务」模块顶部会显示绿色「守护进程运行中」按钮(带 PID 提示),表示 Daemon 正常工作。
如提示 Daemon 已在运行中 (PID: xxx),先执行 php think job:daemon --stop 停止旧进程,或手动删除 runtime/job_daemon.lock 文件。