当前位置：首页 > 文章列表 > 文章 > php教程 > PHP实时更新方案：长轮询与WebSocket对比

PHP实时更新方案：长轮询与WebSocket对比

2026-04-02 15:46:29 0浏览收藏

PHP实现数据实时更新主要有长轮询和WebSocket（结合Swoole）两种主流方案：前者通过客户端持续发起HTTP请求、服务器挂起响应直至有更新，兼容性强但性能差、延迟高，适合低并发或受限环境；后者基于WebSocket协议实现真正的双向、低延迟通信，配合Swoole扩展可构建高性能实时服务，适用于聊天、通知等强实时场景，但需额外部署和运维支持。选择时应综合评估环境兼容性、实时性要求与技术栈能力，必要时也可借助Node.js或第三方推送服务作为替代方案。

PHP代码怎么实现数据实时更新功能_PHP长轮询与WebSocket方案

要实现数据的实时更新功能，PHP常见的方案有两种：长轮询（Long Polling）和WebSocket。虽然PHP本身是同步阻塞的脚本语言，不太适合处理高并发的实时通信，但通过合理设计，依然可以实现基本的实时功能。

1. 长轮询（Long Polling）实现

长轮询是一种模拟实时通信的技术。客户端发起请求后，服务器保持连接打开，直到有新数据或超时才返回响应。客户端收到响应后立即发起下一次请求，从而实现“伪实时”。

实现步骤：

客户端使用JavaScript定时或在响应后立即发起AJAX请求
服务器端PHP脚本监听数据变化（如数据库、文件、缓存等）
若无新数据，PHP保持连接不返回，每隔一段时间检查一次
一旦检测到更新，立即返回数据
客户端处理数据并重新请求

示例PHP代码（long_poll.php）：

<?php
// 设置超时时间
set_time_limit(30);
ignore_user_abort(true);

$lastUpdate = $_GET['last_update'] ?? 0;
$dataFile = 'data.txt'; // 模拟数据源

while (true) {
    $currentMtime = filemtime($dataFile);

    if ($currentMtime > $lastUpdate) {
        $content = file_get_contents($dataFile);
        echo json_encode([
            'update_time' => $currentMtime,
            'data' => $content
        ]);
        exit;
    }

    // 每秒检查一次
    sleep(1);
}
?>

前端JavaScript调用：

function poll(lastTime) {
    fetch(`long_poll.php?last_update=\${lastTime}`)
        .then(res => res.json())
        .then(data => {
            console.log('收到更新:', data);
            // 处理数据
            poll(data.update_time); // 继续下一轮
        })
        .catch(err => {
            console.error('请求失败，重试中...');
            setTimeout(() => poll(lastTime), 2000);
        });
}

// 启动轮询
poll(0);

优点：兼容性好，不需要额外服务；缺点：频繁请求增加服务器负担，延迟较高。

2. WebSocket + Swoole 实现真实时通信

WebSocket 是真正的双向通信协议。PHP 原生不支持 WebSocket，但可以通过扩展 Swoole 来实现高性能的 WebSocket 服务。

使用 Swoole 创建 WebSocket 服务器：

<?php
// websocket_server.php
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

$server->on('open', function (\$server, \$req) {
    echo "客户端 {\$req->fd} 已连接\n";
});

\$server->on('message', function (\$server, \$frame) {
    echo "接收消息: {\$frame->data}\n";

    // 广播给所有客户端
    foreach (\$server->connections as \$fd) {
        \$server->push(\$fd, "广播: {\$frame->data}");
    }
});

\$server->on('close', function (\$server, \$fd) {
    echo "客户端 {\$fd} 断开\n";
});

echo "WebSocket 服务器启动在 ws://0.0.0.0:9501\n";
\$server->start();
?>

前端连接 WebSocket：

const ws = new WebSocket("ws://your-server-ip:9501");

ws.onopen = () => {
    console.log("已连接到 WebSocket 服务器");
};

ws.onmessage = (event) => {
    console.log("收到消息:", event.data);
};

ws.onclose = () => {
    console.log("连接已关闭");
};

// 发送消息测试
setInterval(() => {
    ws.send("心跳 " + new Date().toLocaleTimeString());
}, 5000);

部署说明：