当前位置：首页 > PHP

php实现排队

2026-02-14 20:14:12PHP

PHP实现排队系统的方法

使用PHP实现排队系统可以通过数据库或内存存储队列数据，结合前端展示实现排队功能。

基于数据库的队列实现

创建数据库表存储队列信息：

CREATE TABLE queue (
    id INT AUTO_INCREMENT PRIMARY KEY,
    ticket_number VARCHAR(20) NOT NULL,
    status ENUM('waiting', 'processing', 'completed') DEFAULT 'waiting',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    processed_at TIMESTAMP NULL
);

添加新排队项：

function addToQueue($conn) {
    $ticketNumber = 'T-' . date('YmdHis');
    $sql = "INSERT INTO queue (ticket_number, status) VALUES (?, 'waiting')";
    $stmt = $conn->prepare($sql);
    $stmt->bind_param("s", $ticketNumber);
    $stmt->execute();
    return $ticketNumber;
}

获取当前队列：

function getQueue($conn) {
    $sql = "SELECT * FROM queue WHERE status = 'waiting' ORDER BY created_at ASC";
    $result = $conn->query($sql);
    return $result->fetch_all(MYSQLI_ASSOC);
}

处理队列项：

function processNext($conn) {
    $sql = "SELECT id FROM queue WHERE status = 'waiting' ORDER BY created_at ASC LIMIT 1";
    $result = $conn->query($sql);
    $row = $result->fetch_assoc();

    if ($row) {
        $updateSql = "UPDATE queue SET status = 'processing', processed_at = NOW() WHERE id = ?";
        $stmt = $conn->prepare($updateSql);
        $stmt->bind_param("i", $row['id']);
        $stmt->execute();
        return $row['id'];
    }
    return false;
}

基于Redis的队列实现

使用Redis的列表结构实现高效队列：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 入队
function enqueue($redis, $data) {
    $redis->rpush('queue', json_encode($data));
}

// 出队
function dequeue($redis) {
    $item = $redis->lpop('queue');
    return $item ? json_decode($item, true) : null;
}

// 查看队列
function viewQueue($redis) {
    $length = $redis->llen('queue');
    return $redis->lrange('queue', 0, $length - 1);
}

前端展示队列

使用AJAX定期更新队列状态：

function updateQueue() {
    $.get('get_queue.php', function(data) {
        $('#queue-list').html(data.map(item => 
            `<div class="queue-item">${item.ticket_number}</div>`
        ).join(''));
    });

    setTimeout(updateQueue, 5000);
}
updateQueue();

队列管理界面

创建管理界面处理队列：

// process_queue.php
if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $action = $_POST['action'] ?? '';

    if ($action === 'next') {
        $nextId = processNext($conn);
        echo json_encode(['success' => $nextId !== false]);
        exit;
    }
}