当前位置：首页 > PHP

php 实现comet

2026-01-29 21:38:45PHP

PHP 实现 Comet 技术

Comet 是一种服务器推送技术，允许服务器实时向客户端推送数据，而不需要客户端频繁轮询。以下是几种 PHP 实现 Comet 的方法：

长轮询（Long Polling）

长轮询是 Comet 的一种常见实现方式。客户端发送请求后，服务器保持连接打开，直到有新数据或超时。

// 服务器端代码示例
while (true) {
    $data = getNewData(); // 检查是否有新数据
    if ($data) {
        echo json_encode($data);
        break;
    }
    sleep(1); // 避免 CPU 过载
    flush();  // 确保数据及时发送
}

客户端使用 JavaScript 发起长轮询请求：

function longPoll() {
    fetch('comet.php')
        .then(response => response.json())
        .then(data => {
            console.log(data);
            longPoll(); // 递归调用以保持长轮询
        });
}
longPoll();

使用 WebSocket

WebSocket 是更高效的实时通信协议，但需要服务器和客户端支持。PHP 可以通过库如 Ratchet 实现 WebSocket。

安装 Ratchet：

php 实现comet

composer require cboden/ratchet

服务器端代码：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);
$server->run();

客户端 JavaScript：

const socket = new WebSocket('ws://localhost:8080');
socket.onmessage = (event) => {
    console.log(event.data);
};

使用 Server-Sent Events (SSE)

SSE 是 HTML5 的一种技术，允许服务器单向推送数据到客户端。

php 实现comet

服务器端 PHP：

header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');

while (true) {
    $data = getNewData();
    if ($data) {
        echo "data: " . json_encode($data) . "\n\n";
        flush();
    }
    sleep(1);
}

客户端 JavaScript：

const eventSource = new EventSource('sse.php');
eventSource.onmessage = (event) => {
    console.log(event.data);
};

使用共享内存或文件锁

对于高并发场景，可以使用共享内存或文件锁来管理数据推送。

$shm_key = ftok(__FILE__, 't');
$shm_id = shmop_open($shm_key, "c", 0644, 100);

while (true) {
    $data = shmop_read($shm_id, 0, shmop_size($shm_id));
    if ($data) {
        echo $data;
        shmop_delete($shm_id);
        break;
    }
    sleep(1);
}
shmop_close($shm_id);