当前位置：首页 > PHP

php 实现长轮询

2026-01-16 11:14:13PHP

PHP 实现长轮询的方法

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

基础实现代码

创建一个简单的长轮询 PHP 脚本（long_polling.php）：

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

// 模拟数据检查（实际应用可能查询数据库或外部API）
function checkForUpdates($lastUpdateTime) {
    // 这里用随机数模拟数据更新
    if (rand(0, 10) > 7) {
        return ['status' => 'updated', 'data' => 'New data at '.date('H:i:s')];
    }
    return null;
}

$lastUpdate = isset($_GET['lastUpdate']) ? $_GET['lastUpdate'] : 0;
$timeout = 30; // 超时时间（秒）
$startTime = time();

while (true) {
    $response = checkForUpdates($lastUpdate);
    if ($response) {
        echo json_encode($response);
        break;
    }

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

    // 减少CPU占用
    usleep(500000); // 0.5秒
    flush();
}
?>

客户端 JavaScript 调用

前端通过 AJAX 递归调用长轮询接口：

function longPoll() {
    fetch('long_polling.php?lastUpdate=' + lastUpdate)
        .then(response => response.json())
        .then(data => {
            if (data.status === 'updated') {
                console.log('Received:', data.data);
                lastUpdate = Date.now();
                // 处理新数据...
            }
            // 无论是否超时都立即发起新请求
            longPoll();
        })
        .catch(error => {
            console.error('Polling error:', error);
            setTimeout(longPoll, 5000); // 错误时延迟重试
        });
}

let lastUpdate = 0;
longPoll(); // 开始长轮询

优化建议

数据库驱动实现
实际应用通常基于数据库变更检测：

// 使用MySQL的UNIX_TIMESTAMP()比较
$query = "SELECT * FROM messages WHERE timestamp > FROM_UNIXTIME($lastUpdate)";
// 或使用专门的轮询表

连接管理
添加连接心跳检测防止中间设备断开：

// 客户端定时发送心跳
setInterval(() => {
    fetch('ping.php');
}, 25000);

性能优化
- 使用共享内存（APCu）替代数据库查询
- 设置适当的max_execution_time
- 考虑用session_write_close()释放会话锁

替代方案比较

WebSocket
更适合高频双向通信，但需要额外服务端支持（如Ratchet）
Server-Sent Events (SSE)
标准化的服务器推送技术，但部分旧浏览器不支持
定时短轮询
简单但效率低，适用于更新不频繁的场景

注意事项

Nginx/Apache 可能有默认超时限制（通常60秒），需调整配置：
```
location /poll {
    proxy_read_timeout 300s;
}
```
避免在长轮询期间进行会话操作，可能阻塞其他请求
生产环境建议添加客户端重连机制和错误处理

此实现适用于消息通知、实时状态更新等场景，可根据具体需求调整超时时间和数据检查逻辑。

php 实现长轮询

标签: php 长轮询

分享给朋友：

php实现文件下载

PHP 实现文件下载的方法使用 header() 函数强制下载设置正确的 HTTP 头信息，强制浏览器下载文件而不是直接打开。 $file = 'path/to/file.pdf'; if (…

php实现购物车

PHP实现购物车功能购物车功能是电商网站的核心模块之一，通常涉及商品添加、删除、数量修改和结算等操作。以下是使用PHP实现购物车功能的几种方法。使用Session存储购物车数据 Session是…

php实现树

PHP实现树结构的方法在PHP中实现树结构通常可以通过递归或迭代的方式完成。以下是几种常见的实现方法：递归实现树结构递归是处理树结构的自然方式，尤其适用于具有未知深度的树。 class Tr…

php实现递归

递归的基本概念递归是一种函数调用自身的技术，适用于解决可以分解为相同子问题的问题。在PHP中，递归需要明确的终止条件（基线条件），否则会导致无限循环。递归实现阶乘阶乘是经典的递归案例，n! =…

php 实现自动收货

PHP 实现自动收货功能自动收货功能通常用于电商系统，在订单超过一定时间未手动确认收货时自动完成订单。以下是实现方法：数据库设计需要订单表包含以下关键字段： CREATE TABLE o…

git php实现

Git 与 PHP 的集成实现使用 PHP 执行 Git 命令通过 PHP 的 exec()、shell_exec() 或 passthru() 函数可以直接调用 Git 命令，适用于服务器端操作…

php 实现长轮询