当前位置：首页 > PHP

php如何实现push

2026-03-13 12:45:02PHP

PHP 实现推送功能的方法

PHP 可以通过多种方式实现推送功能，具体取决于推送的目标和场景。以下是几种常见的实现方法：

使用 WebSocket 实现实时推送

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，适用于实时推送场景。PHP 可以与 WebSocket 服务器结合使用。

安装 Ratchet（一个 PHP WebSocket 库）：

composer require cboden/ratchet

创建 WebSocket 服务器：

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();

客户端连接：

var conn = new WebSocket('ws://localhost:8080');
conn.onmessage = function(e) {
    console.log('Received: ' + e.data);
};

使用 Server-Sent Events (SSE)

SSE 允许服务器向客户端推送事件，适用于单向实时通信。

php如何实现push

服务器端代码：

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

while (true) {
    echo "data: " . json_encode(['message' => 'New update']) . "\n\n";
    ob_flush();
    flush();
    sleep(1);
}

客户端代码：

var eventSource = new EventSource('sse.php');
eventSource.onmessage = function(e) {
    console.log(e.data);
};

使用第三方推送服务

对于移动应用推送，可以使用 Firebase Cloud Messaging (FCM) 或 Apple Push Notification Service (APNS)。

php如何实现push

FCM 示例：

$url = 'https://fcm.googleapis.com/fcm/send';
$serverKey = 'YOUR_SERVER_KEY';
$headers = [
    'Authorization: key=' . $serverKey,
    'Content-Type: application/json'
];

$data = [
    'to' => '/topics/all',
    'notification' => [
        'title' => 'New Message',
        'body' => 'You have a new message'
    ]
];

$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);

使用长轮询 (Long Polling)

长轮询是传统轮询的改进版，服务器在有数据时才响应。

服务器端：

$hasData = checkForNewData(); // 自定义函数检查新数据
if ($hasData) {
    echo json_encode($hasData);
    exit;
}

// 没有数据时等待
sleep(10);
echo json_encode([]);

客户端：

function fetchUpdates() {
    fetch('longpoll.php')
        .then(response => response.json())
        .then(data => {
            if (data.length) {
                console.log('New data:', data);
            }
            fetchUpdates();
        });
}
fetchUpdates();