PHP服务器实现简单、高效的Push消息推送功能 (php 服务器push)

PHP服务器通过实现Push消息推送功能，提供简单高效的实时通信机制，增强用户体验。

在Web开发中，实现服务器向客户端推送消息的功能是一个常见的需求，传统的方法通常是使用轮询（Polling）或长轮询（Long Polling），但这些方法效率不高，会造成资源浪费，随着HTML5的发展，Server-Sent Events (SSE) 和 WebSockets 提供了实现服务器Push的更好方式，PHP作为一种广泛使用的服务端脚本语言，也支持这些技术。

Server-Sent Events (SSE)

Server-Sent Events 是 HTML5 提供的一种 API，允许服务器不断地发送实时更新到客户端，与 AJAX 不同，SSE 是单向的，只从服务器发送到客户端。

要在 PHP 服务器上实现 SSE，你可以设置一个特殊的 Content-Type 为 text/event-stream，并通过 ob_flush() 和 flush() 函数来确保数据被即时发送出去。

<?php
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
// 连接数据库或其他数据源
// ...
while (true) {
    // 获取新的消息
    $message = getLatestMessage();
    if ($message) {
        echo "data: {$message}
";
        ob_flush();
        flush();
        sleep(1); // 避免太过频繁的数据发送
    } else {
        sleep(2); // 没有新消息时稍微等待一会儿
    }
}
?>

在客户端，你可以使用 JavaScript 的 EventSource 对象来接收这些事件。

var source = new EventSource('/path/to/sse/script.php');
source.onmessage = function(event) {
    console.log(event.data);
};

WebSockets

WebSockets 是一种全双工通信协议，允许服务器与客户端之间进行更灵活、低延迟的实时交互，PHP 通过扩展库如 Ratchet 来实现 WebSocket 服务。

Ratchet 是一个用于创建WebSocket应用的PHP库，它需要ReactPHP作为基础，安装Ratchet和ReactPHP后，你可以创建一个WebSocket服务器来处理客户端连接和消息。

require 'vendor/autoload.php';
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
use MyAppChat;
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new Chat()
            )
        ),
        8080
    );
    $server->run();

在这里，MyAppChat 是你自定义的类，用来处理WebSocket连接和消息，你需要在这个类中定义 onOpen、onMessage、onClose 等方法。

namespace MyApp;
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
class Chat implements MessageComponentInterface {
    protected $clients;
    public function __construct() {
        $this->clients = new SplObjectStorage;
    }
    public function onOpen(ConnectionInterface $conn) {
        // 新的连接加入时的逻辑
        $this->clients->attach($conn);
    }
    public function onMessage(ConnectionInterface $from, $msg) {
        // 收到消息时的逻辑
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }
    public function onClose(ConnectionInterface $conn) {
        // 连接关闭时的逻辑
        $this->clients->detach($conn);
    }
    public function onError(ConnectionInterface $conn, Exception $e) {
        // 错误处理逻辑
    }
}

在客户端，你可以使用浏览器提供的 WebSocket API 或者第三方库来连接WebSocket服务器并发送接收消息。


var socket = new WebSocket('ws://localhost:8080');
socket.onopen = function(e) {
    console.log("[open] Connection established");
    socket.send("Hello Server!");
};
socket.onmessage = function(event) {
    console.log([message] Data received from server: ${event.data});
};
socket.onclose = function(event) {
    if (event.wasClean) {
        console.log([close] Connection closed cleanly, code=${event.code} reason=${event.reason});
    } else {
        console.log('[close] Connection died');
    }
};
socket.onerror = function(error) {
    console.log([error] ${error.message});
};