PHP编写命令行脚本的开发与定时任务实现方案
一、PHP命令行脚本开发基础
1.1 命令行环境搭建
PHP作为一门通用编程语言，不仅可用于Web开发，还能编写强大的命令行脚本。首先确保你的服务器已安装PHP CLI版本。
检查PHP CLI是否安装：
php -v
若未安装，可通过以下方式安装：
Ubuntu/Debian：apt-get install php-cli
CentOS/RHEL：yum install php-cli
Windows：下载PHP二进制包并配置环境变量
1.2 第一个PHP命令行脚本
创建简单的问候脚本 greet.php：
<?php
// greet.php - 简单的命令行问候脚本
if ($argc >= 2) {
$name = $argv[1];
echo "Hello, " . $name . "!\n";
} else {
echo "Usage: php greet.php [name]\n";
}
?>运行脚本：
php greet.php John # 输出: Hello, John!
1.3 命令行参数处理
PHP提供了两个全局变量处理命令行参数：
$argc：参数数量（包括脚本名）
$argv：参数数组（$argv[0]是脚本名）
更健壮的参数解析示例：
<?php
// parse_args.php - 命令行参数解析示例
$options = getopt("n:a:", ["name:", "age:"]);
if (isset($options["n"]) || isset($options["name"])) {
$name = $options["n"] ?? $options["name"];
echo "Name: " . $name . "\n";
}
if (isset($options["a"]) || isset($options["age"])) {
$age = $options["a"] ?? $options["age"];
echo "Age: " . $age . "\n";
}
?>使用长选项运行：
php parse_args.php --name=John --age=30
1.4 标准输入输出
PHP CLI支持标准输入、输出和错误流：
<?php // io_demo.php - 标准输入输出演示 echo "请输入您的姓名: "; $name = trim(fgets(STDIN)); echo "您好, " . $name . "!\n"; fprintf(STDOUT, "这是标准输出\n"); fprintf(STDERR, "这是错误输出\n"); ?>
二、PHP定时任务实现方案
2.1 使用Cron实现定时任务
Cron是Linux/Unix系统下最常用的定时任务调度器，通过crontab命令管理任务。
2.1.1 Crontab基本语法
Cron表达式格式：分 时 日 月 周 命令
| 字段 | 范围 | 说明 |
|---|---|---|
| 分 | 0-59 | 每小时的第几分钟 |
| 时 | 0-23 | 每天的第几小时 |
| 日 | 1-31 | 每月的第几天 |
| 月 | 1-12 | 每年的第几月 |
| 周 | 0-7 | 每周的第几天（0和7都代表周日） |
2.1.2 编辑Crontab
打开当前用户的crontab编辑器：
crontab -e
添加PHP定时任务：
# 每天凌晨1点执行备份脚本 0 1 * * * /usr/bin/php /path/to/backup.php # 每5分钟执行一次数据同步 */5 * * * * /usr/bin/php /path/to/sync.php # 每周一上午9点发送周报 0 9 * * 1 /usr/bin/php /path/to/weekly_report.php
2.1.3 查看和管理Crontab
查看当前用户的crontab：crontab -l
删除当前用户的crontab：crontab -r
编辑其他用户的crontab（需root权限）：crontab -u username -e
2.2 PHP内置Web服务器定时任务
对于没有Cron权限的环境，可以使用PHP内置Web服务器结合无限循环模拟定时任务。
简单定时任务脚本：
<?php
// simple_scheduler.php - 简单定时任务调度器
set_time_limit(0); // 取消脚本执行时间限制
$tasks = [
['time' => '* * * * *', 'script' => '/path/to/task1.php'], // 每分钟执行
['time' => '*/5 * * * *', 'script' => '/path/to/task2.php'], // 每5分钟执行
];
while (true) {
$current_time = date('i G j n Y'); // 分 时 日 月 年
foreach ($tasks as $task) {
if (shouldRun($task['time'], $current_time)) {
exec('/usr/bin/php ' . $task['script'] . ' > /dev/null 2>&1 &');
}
}
sleep(60); // 每分钟检查一次
}
function shouldRun($schedule, $current) {
// 简化的Cron表达式解析
list($minute, $hour, $day, $month, $year) = explode(' ', $schedule);
list($curr_min, $curr_hour, $curr_day, $curr_month, $curr_year) = explode(' ', $current);
return ($minute == '*' || $minute == $curr_min) &&
($hour == '*' || $hour == $curr_hour) &&
($day == '*' || $day == $curr_day) &&
($month == '*' || $month == $curr_month) &&
($year == '*' || $year == $curr_year);
}
?>2.3 使用第三方库实现定时任务
PHP有许多优秀的定时任务库，如cron-expression、php-cron-scheduler等。
使用cron-expression库的示例：
<?php
// composer require dragonmantank/cron-expression
require_once 'vendor/autoload.php';
use Cron\CronExpression;
$cron = CronExpression::factory('*/5 * * * *'); // 每5分钟执行一次
if ($cron->isDue()) {
echo "执行定时任务...\n";
// 执行具体任务逻辑
}
?>2.4 数据库驱动的定时任务
对于复杂的定时任务系统，可以使用数据库存储任务配置和执行状态。
数据库表结构：
CREATE TABLE scheduled_tasks ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255) NOT NULL, schedule VARCHAR(50) NOT NULL, script_path VARCHAR(500) NOT NULL, is_active BOOLEAN DEFAULT TRUE, last_run DATETIME, next_run DATETIME, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP );
基于数据库的定时任务调度器：
<?php
// database_scheduler.php - 基于数据库的定时任务调度器
require_once 'db_config.php'; // 数据库连接配置
class DatabaseScheduler {
private $db;
public function __construct($db) {
$this->db = $db;
}
public function run() {
set_time_limit(0);
while (true) {
$tasks = $this->getActiveTasks();
foreach ($tasks as $task) {
if ($this->shouldRunTask($task)) {
$this->executeTask($task);
$this->updateTaskSchedule($task);
}
}
sleep(60); // 每分钟检查一次
}
}
private function getActiveTasks() {
$stmt = $this->db->prepare("SELECT * FROM scheduled_tasks WHERE is_active = 1");
$stmt->execute();
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
private function shouldRunTask($task) {
$cron = CronExpression::factory($task['schedule']);
$now = new DateTime();
return $cron->isDue($now) &&
(!$task['last_run'] || strtotime($task['last_run']) < $cron->getPreviousRunDate()->getTimestamp());
}
private function executeTask($task) {
echo "执行任务: " . $task['name'] . " at " . date('Y-m-d H:i:s') . "\n";
// 异步执行任务脚本
exec('/usr/bin/php ' . $task['script_path'] . ' > /dev/null 2>&1 &');
// 记录任务执行时间
$stmt = $this->db->prepare("UPDATE scheduled_tasks SET last_run = NOW() WHERE id = ?");
$stmt->execute([$task['id']]);
}
private function updateTaskSchedule($task) {
$cron = CronExpression::factory($task['schedule']);
$nextRun = $cron->getNextRunDate();
$stmt = $this->db->prepare("UPDATE scheduled_tasks SET next_run = ? WHERE id = ?");
$stmt->execute([$nextRun->format('Y-m-d H:i:s'), $task['id']]);
}
}
// 使用示例
$scheduler = new DatabaseScheduler($db);
$scheduler->run();
?>三、PHP命令行脚本最佳实践
3.1 错误处理与日志记录
命令行脚本应具备完善的错误处理和日志记录机制。
带日志功能的脚本示例：
<?php
// logger.php - 带日志功能的命令行脚本
class Logger {
private $log_file;
public function __construct($log_file) {
$this->log_file = $log_file;
}
public function log($level, $message) {
$timestamp = date('Y-m-d H:i:s');
$log_entry = "[$timestamp] [$level] $message\n";
file_put_contents($this->log_file, $log_entry, FILE_APPEND | LOCK_EX);
// 同时输出到控制台
if ($level == 'ERROR') {
fprintf(STDERR, $log_entry);
} else {
echo $log_entry;
}
}
}
// 使用示例
$logger = new Logger('/var/log/my_script.log');
try {
// 业务逻辑
$logger->log('INFO', '脚本开始执行');
if (!file_exists('/path/to/file')) {
throw new Exception('文件不存在');
}
$logger->log('INFO', '脚本执行完成');
} catch (Exception $e) {
$logger->log('ERROR', '错误: ' . $e->getMessage());
exit(1);
}
?>3.2 信号处理
处理系统信号以实现优雅退出。
<?php
// signal_handler.php - 信号处理示例
declare(ticks=1); // 启用信号 tick
$running = true;
// 注册信号处理器
pcntl_signal(SIGTERM, "signalHandler");
pcntl_signal(SIGINT, "signalHandler");
function signalHandler($signo) {
global $running;
switch ($signo) {
case SIGTERM:
case SIGINT:
echo "接收到终止信号，正在退出...\n";
$running = false;
break;
}
}
// 主循环
while ($running) {
// 执行任务
echo "工作中...\n";
sleep(1);
}
echo "脚本已退出\n";
?>3.3 性能优化
避免在循环中执行耗时操作
合理使用缓存减少IO操作
批量处理数据而非逐条处理
使用适当的数据结构和算法
四、常见问题与解决方案
4.1 权限问题
确保PHP CLI有权限读取脚本文件和写入日志文件：
chmod +x /path/to/script.php chown www-data:www-data /path/to/script.php # 根据实际用户调整
4.2 路径问题
在命令行脚本中使用绝对路径避免路径错误：
<?php
// 获取脚本所在目录的绝对路径
define('SCRIPT_DIR', dirname(__FILE__));
// 使用绝对路径包含文件
require_once SCRIPT_DIR . '/config.php';
require_once SCRIPT_DIR . '/functions.php';
// 使用绝对路径操作文件
$log_file = SCRIPT_DIR . '/logs/app.log';
?>4.3 内存管理
长时间运行的脚本需注意内存泄漏：
<?php // 手动释放不再使用的变量 $data = getData(); processData($data); unset($data); // 释放内存 // 定期重启脚本避免长时间运行导致的内存问题 // 可在Cron中设置每天重启一次脚本 ?>
五、总结
PHP命令行脚本开发为企业级应用提供了强大的后台处理能力，结合定时任务可以实现自动化运维、数据处理、报表生成等多种功能。通过合理选择定时任务实现方案、遵循最佳实践，可以构建稳定高效的命令行应用。在实际项目中，应根据具体需求选择合适的方案，并注意错误处理、日志记录和性能优化，确保系统的可靠性和可维护性。