当前位置：首页 > PHP

php 实现长轮询

2026-02-13 16:47:29PHP

PHP 实现长轮询的方法

长轮询（Long Polling）是一种服务器推送技术，客户端向服务器发送请求后，服务器保持连接开放，直到有数据可发送或超时。以下是实现长轮询的步骤和代码示例。

服务器端代码

创建一个 PHP 脚本（如 long_polling.php）处理长轮询请求。该脚本会检查数据更新，并在有更新或超时时返回响应。

<?php
// 设置脚本执行时间不受限制
set_time_limit(0);

// 模拟数据存储（实际应用中可能使用数据库或缓存）
$lastUpdate = isset($_GET['lastUpdate']) ? (int)$_GET['lastUpdate'] : 0;

// 长轮询超时时间（秒）
$timeout = 30;
$startTime = time();

// 检查数据是否更新
while (true) {
    // 模拟数据更新（实际应用中根据业务逻辑判断）
    $currentUpdate = filemtime('data.txt'); // 假设通过文件修改时间判断更新

    if ($currentUpdate > $lastUpdate) {
        // 返回新数据
        $response = [
            'status' => 'success',
            'data' => file_get_contents('data.txt'),
            'lastUpdate' => $currentUpdate
        ];
        echo json_encode($response);
        break;
    }

    // 检查是否超时
    if (time() - $startTime >= $timeout) {
        $response = ['status' => 'timeout'];
        echo json_encode($response);
        break;
    }

    // 减少 CPU 占用
    usleep(100000); // 0.1 秒
}
?>

客户端代码

使用 JavaScript 发起长轮询请求，并在收到响应后处理数据或重新发起请求。

function longPolling(lastUpdate = 0) {
    fetch(`long_polling.php?lastUpdate=${lastUpdate}`)
        .then(response => response.json())
        .then(data => {
            if (data.status === 'success') {
                console.log('New data:', data.data);
                // 处理新数据后继续轮询
                longPolling(data.lastUpdate);
            } else if (data.status === 'timeout') {
                // 超时后重新发起轮询
                longPolling(lastUpdate);
            }
        })
        .catch(error => {
            console.error('Polling error:', error);
            // 错误后重新发起轮询
            setTimeout(() => longPolling(lastUpdate), 1000);
        });
}

// 启动长轮询
longPolling();

实际应用优化

数据存储：替换文件操作为数据库或缓存（如 Redis），通过查询判断数据更新。
性能优化：避免频繁查询数据库，可以使用缓存或消息队列。
错误处理：增加客户端重试机制和服务器端日志记录。
安全性：验证客户端请求，防止恶意攻击。

示例：数据库实现

假设使用 MySQL 存储数据，通过检查 last_modified 字段判断更新：

<?php
set_time_limit(0);
$lastUpdate = isset($_GET['lastUpdate']) ? (int)$_GET['lastUpdate'] : 0;
$timeout = 30;
$startTime = time();

// 数据库连接
$db = new PDO('mysql:host=localhost;dbname=test', 'username', 'password');

while (true) {
    $stmt = $db->prepare("SELECT * FROM messages WHERE last_modified > ? LIMIT 1");
    $stmt->execute([$lastUpdate]);
    $data = $stmt->fetch(PDO::FETCH_ASSOC);

    if ($data) {
        echo json_encode([
            'status' => 'success',
            'data' => $data['content'],
            'lastUpdate' => $data['last_modified']
        ]);
        break;
    }

    if (time() - $startTime >= $timeout) {
        echo json_encode(['status' => 'timeout']);
        break;
    }

    usleep(100000);
}
?>

通过以上方法，可以实现高效的长轮询机制，适用于实时性要求较高的应用场景。

php 实现长轮询