要利用 PHP 實現任務隊列,你可以遵循以下步驟:
tasks
的表,其中包含 id
、task_name
和 status
等字段。CREATE TABLE tasks (
id INT AUTO_INCREMENT PRIMARY KEY,
task_name VARCHAR(255) NOT NULL,
status VARCHAR(50) NOT NULL DEFAULT 'pending'
);
// 使用 PDO
$dsn = 'mysql:host=localhost;dbname=your_database';
$username = 'your_username';
$password = 'your_password';
$options = [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
];
$db = new PDO($dsn, $username, $password, $options);
// 使用 mysqli
$servername = "localhost";
$username = "your_username";
$password = "your_password";
$dbname = "your_database";
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
die("連接失敗: " . $conn->connect_error);
}
tasks
表中。function addTaskToQueue($taskName) {
global $db;
$stmt = $db->prepare("INSERT INTO tasks (task_name, status) VALUES (:task_name, :status)");
$stmt->bindParam(':task_name', $taskName);
$stmt->bindParam(':status', 'pending');
$stmt->execute();
}
tasks
表中獲取所有狀態為 “pending” 的任務,并執行相應的操作。你還可以根據需要設置一個時間間隔來定期檢查新任務。function processTasks() {
global $db;
while (true) {
$stmt = $db->prepare("SELECT * FROM tasks WHERE status = 'pending'");
$stmt->execute();
$tasks = $stmt->fetchAll();
foreach ($tasks as $task) {
// 在這里執行任務操作,例如調用其他 PHP 腳本或 API
echo "Processing task: " . $task['task_name'] . PHP_EOL;
// 更新任務狀態為 "completed"
$updateStmt = $db->prepare("UPDATE tasks SET status = 'completed' WHERE id = :id");
$updateStmt->bindParam(':id', $task['id']);
$updateStmt->execute();
}
// 設置時間間隔,例如每分鐘檢查一次新任務
sleep(60);
}
}
addTaskToQueue()
函數將任務添加到隊列中,并使用 processTasks()
函數處理隊列中的任務。// 添加任務到隊列
addTaskToQueue("Example task");
// 處理隊列中的任務
processTasks();
這樣,你就可以利用 PHP 實現一個簡單的任務隊列系統了。請注意,這個示例僅用于演示目的,實際應用中可能需要考慮更多的因素,例如錯誤處理、日志記錄、分布式處理等。