当前位置:首页 > 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(); // 开始长轮询

优化建议

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

    // 使用MySQL的UNIX_TIMESTAMP()比较
    $query = "SELECT * FROM messages WHERE timestamp > FROM_UNIXTIME($lastUpdate)";
    // 或使用专门的轮询表
  2. 连接管理
    添加连接心跳检测防止中间设备断开:

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

    • 使用共享内存(APCu)替代数据库查询
    • 设置适当的max_execution_time
    • 考虑用session_write_close()释放会话锁

替代方案比较

  1. WebSocket
    更适合高频双向通信,但需要额外服务端支持(如Ratchet)

  2. Server-Sent Events (SSE)
    标准化的服务器推送技术,但部分旧浏览器不支持

  3. 定时短轮询
    简单但效率低,适用于更新不频繁的场景

注意事项

  • Nginx/Apache 可能有默认超时限制(通常60秒),需调整配置:

    location /poll {
        proxy_read_timeout 300s;
    }
  • 避免在长轮询期间进行会话操作,可能阻塞其他请求

  • 生产环境建议添加客户端重连机制和错误处理

    php 实现长轮询

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

标签: php长轮询
分享给朋友:

相关文章

php实现增删改查

php实现增删改查

以下是在PHP中实现增删改查(CRUD)操作的详细方法,以MySQL数据库为例: 数据库连接配置 创建config.php文件存储数据库连接信息: <?php $host = 'localh…

php验证码的实现

php验证码的实现

PHP 验证码实现方法 使用 GD 库生成基础验证码 创建画布并生成随机字符串作为验证码内容: session_start(); $width = 120; $height = 40; $image…

php实现博客

php实现博客

使用PHP实现博客系统 数据库设计 创建数据库表存储博客文章和用户信息。常见的表包括posts(文章)和users(用户)。 CREATE TABLE users ( id INT AUTO…

php 实现队列

php 实现队列

PHP 实现队列的方法 PHP 可以通过多种方式实现队列功能,以下是几种常见的实现方法: 使用数组实现队列 PHP 数组可以通过 array_push 和 array_shift 函数模拟队列的先进…

php实现定时

php实现定时

PHP 实现定时任务的方法 PHP 本身是脚本语言,通常需要借助外部工具或框架实现定时任务。以下是几种常见方法: 使用 Cron 任务 Linux 系统自带的 Cron 是常用的定时任务工具。通过编…

php实现注册登录

php实现注册登录

PHP 注册功能实现 创建数据库表(以 MySQL 为例) CREATE TABLE users ( id INT AUTO_INCREMENT PRIMARY KEY, usern…