php mysql队列

基础概念

PHP MySQL队列是一种使用MySQL数据库来存储和管理任务队列的技术。它通常用于处理需要异步执行的任务，例如发送电子邮件、生成报告、处理图像等。队列允许将这些任务放入一个先进先出（FIFO）的队列中，然后由后台进程或服务器逐个处理。

类型

简单队列：基本的先进先出队列。
优先级队列：根据任务的优先级进行处理。
延迟队列：任务在指定的时间后才会被处理。

应用场景

后台任务处理：如发送电子邮件、生成报告等。
批处理任务：如数据导入、文件转换等。
实时数据处理：如日志处理、监控数据收集等。

示例代码

以下是一个简单的PHP MySQL队列示例：

<?php
// 数据库连接
$mysqli = new mysqli("localhost", "username", "password", "database");

if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}

// 插入任务到队列
function enqueue($mysqli, $task) {
    $sql = "INSERT INTO queue (task) VALUES (?)";
    $stmt = $mysqli->prepare($sql);
    $stmt->bind_param("s", $task);
    $stmt->execute();
}

// 从队列中取出任务并处理
function dequeue($mysqli) {
    $sql = "SELECT task FROM queue ORDER BY id ASC LIMIT 1 FOR UPDATE SKIP LOCKED";
    $result = $mysqli->query($sql);
    if ($result->num_rows > 0) {
        $row = $result->fetch_assoc();
        $task = $row['task'];
        $delete_sql = "DELETE FROM queue WHERE task = ?";
        $delete_stmt = $mysqli->prepare($delete_sql);
        $delete_stmt->bind_param("s", $task);
        $delete_stmt->execute();
        return $task;
    }
    return null;
}

// 示例任务
$task = "发送电子邮件";
enqueue($mysqli, $task);

// 处理任务
while ($task = dequeue($mysqli)) {
    echo "处理任务: " . $task . "\n";
    // 这里可以添加具体的任务处理逻辑
}

$mysqli->close();
?>