在 PHP 中,實現單線程任務執行的監控有以下幾種方法:
在任務執行的每個階段,將關鍵信息記錄到日志文件中。例如,記錄開始時間、結束時間、執行結果等。這樣,你可以通過查看日志文件來了解任務的執行情況。
// 示例日志記錄函數
function log_message($message) {
$timestamp = date('Y-m-d H:i:s');
file_put_contents('task_log.txt', "[$timestamp] $message\n", FILE_APPEND);
}
// 任務開始執行
log_message("Task started.");
// 執行任務邏輯...
// 任務執行完畢
log_message("Task completed.");
將任務的執行情況存儲在數據庫中,可以更方便地查詢和分析任務進度。例如,創建一個名為 task_execution
的表,用于存儲任務的開始時間、結束時間、執行結果等信息。
CREATE TABLE task_execution (
id INT AUTO_INCREMENT PRIMARY KEY,
task_name VARCHAR(255) NOT NULL,
start_time TIMESTAMP NOT NULL,
end_time TIMESTAMP,
result TEXT,
status ENUM('pending', 'running', 'completed', 'failed') NOT NULL
);
在任務執行過程中,將相關信息插入到 task_execution
表中。
// 連接數據庫
$db = new PDO('mysql:host=localhost;dbname=mydb', 'username', 'password');
// 任務開始執行
$stmt = $db->prepare("INSERT INTO task_execution (task_name, start_time, status) VALUES (?, NOW(), 'running')");
$stmt->execute(['MyTask']);
// 執行任務邏輯...
// 任務執行完畢
$stmt = $db->prepare("UPDATE task_execution SET end_time = NOW(), result = ?, status = 'completed' WHERE id = ?");
$stmt->execute(['Task result', $taskId]);
如果你的任務需要與其他任務并發執行,可以使用信號量或互斥鎖來確保同一時間只有一個任務在執行。這可以通過 PHP 的 sem_acquire()
和 sem_release()
函數(使用信號量)或 mutex_lock()
和 mutex_unlock()
函數(使用 POSIX 互斥鎖)來實現。
// 使用信號量實現互斥鎖
$semaphore_id = ftok(__FILE__, 't');
$semaphore = sem_get($semaphore_id, 1, 0666, 1);
if (sem_acquire($semaphore)) {
// 獲取鎖,執行任務
// ...
// 釋放鎖
sem_release($semaphore);
} else {
// 無法獲取鎖,跳過執行任務
}
你還可以使用進程監控工具(如 Supervisor)來監控 PHP 腳本的任務執行情況。這些工具可以幫助你確保腳本始終在運行,并在發生故障時自動重啟。要使用 Supervisor,首先安裝并配置 Supervisor,然后創建一個 Supervisor 配置文件(如 /etc/supervisor/conf.d/my_php_task.conf
),指定 PHP 腳本的路徑和參數。
[program:my_php_task]
command=/usr/bin/php /path/to/your/php/script.php
autostart=true
autorestart=true
stderr_logfile=/var/log/my_php_task_error.log
stdout_logfile=/var/log/my_php_task_output.log
保存配置文件后,使用 supervisord
命令啟動并監控你的 PHP 任務。
通過以上方法,你可以有效地監控 PHP 單線程任務的執行情況。