当前位置：首页 > PHP

php实现推送功能实现原理

2026-02-15 03:21:06PHP

PHP 推送功能实现原理

PHP 推送功能通常涉及服务器向客户端实时或准实时传递数据，常见于聊天应用、通知系统等场景。以下是几种常见的实现方式：

短轮询（Short Polling）

客户端定期向服务器发送请求，服务器立即返回响应。如果服务器有新数据，返回数据；否则返回空响应。

// 服务器端示例
$hasNewData = checkForNewData(); // 检查是否有新数据
if ($hasNewData) {
    echo json_encode(['data' => $newData]);
} else {
    echo json_encode(['data' => null]);
}

短轮询实现简单，但频繁请求会增加服务器负担。

长轮询（Long Polling）

客户端发送请求后，服务器保持连接打开直到有新数据或超时。减少不必要的请求，但服务器需要维护更多连接。

// 服务器端示例
$timeout = 30; // 超时时间（秒）
$startTime = time();
while (time() - $startTime < $timeout) {
    $hasNewData = checkForNewData();
    if ($hasNewData) {
        echo json_encode(['data' => $newData]);
        break;
    }
    usleep(100000); // 避免CPU占用过高
}

WebSocket

WebSocket 提供全双工通信，适合高实时性场景。PHP 可通过 Ratchet 等库实现 WebSocket 服务器。

// Ratchet 示例
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class MyChat implements MessageComponentInterface {
    public function onOpen(ConnectionInterface $conn) {
        // 新连接逻辑
    }
    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理消息
    }
    public function onClose(ConnectionInterface $conn) {
        // 连接关闭逻辑
    }
    public function onError(ConnectionInterface $conn, \Exception $e) {
        // 错误处理
    }
}

$server = \Ratchet\Server\IoServer::factory(
    new \Ratchet\Http\HttpServer(
        new \Ratchet\WebSocket\WsServer(
            new MyChat()
        )
    ),
    8080
);
$server->run();

Server-Sent Events (SSE)

SSE 允许服务器通过 HTTP 连接向客户端推送数据。客户端通过 EventSource API 接收数据。

// 服务器端示例
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');

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

第三方推送服务

使用 Firebase Cloud Messaging (FCM) 或 Pusher 等第三方服务简化推送实现。

php实现推送功能实现原理

// FCM 示例
$url = 'https://fcm.googleapis.com/fcm/send';
$headers = [
    'Authorization: key=YOUR_SERVER_KEY',
    'Content-Type: application/json'
];
$data = [
    'to' => 'DEVICE_TOKEN',
    'notification' => [
        'title' => 'Title',
        'body' => 'Message body'
    ]
];

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
$result = curl_exec($ch);
curl_close($ch);