如何用PHP项目实现WebSocket推送？

wen java案例 2026-07-24 2

如何用PHP项目实现WebSocket推送：从零搭建实时通信系统

文章导读

什么是WebSocket推送？为什么PHP需要它？
准备工作：环境与扩展安装
核心实现：基于Ratchet库的服务端开发
客户端连接：JavaScript与WebSocket的握手
消息广播与定向推送实战
常见问题与性能优化
Q&A：开发者最关心的5个问题

什么是WebSocket推送？为什么PHP需要它？

传统HTTP协议遵循“请求-响应”模式，服务器无法主动向客户端发送数据，在需要实时更新的场景（如聊天室、通知推送、股票行情）中，这种模式效率极低，往往需要客户端轮询或长轮询，不仅浪费带宽,还延迟高。

如何用PHP项目实现WebSocket推送？

WebSocket 解决了这个痛点：它允许服务器与客户端建立持久连接，实现全双工通信，PHP虽然长期被视为“弱实时”语言，但通过特定库（如Ratchet、Swoole）完全可以实现高性能WebSocket推送。

一个电商系统需要在用户下单后实时通知后台管理员，或者一个在线教育平台需要推送答题结果,WebSocket都能实现毫秒级响应。

准备工作：环境与扩展安装

基础环境要求

PHP 7.4及以上（推荐8.0+,性能更优）
Composer（PHP依赖管理工具）
命令行环境（Linux/Mac/WSL推荐）

安装Ratchet库

Ratchet是PHP最成熟的WebSocket库之一,基于ReactPHP事件循环：

composer require cboden/ratchet

关键依赖：该命令会自动安装 react/socket、react/event-loop 等底层组件。

检查PHP扩展

确保已安装以下扩展：

php-pcntl（进程控制,Linux环境下必须）
php-sockets（底层socket支持）
php-json（数据处理）

可以使用以下命令验证：

php -m | grep -E 'pcntl|sockets|json'

核心实现：基于Ratchet库的服务端开发

第一步：创建WebSocket服务器类

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
class ChatServer implements MessageComponentInterface {
    protected $clients;
    protected $userConnections; // 用于定向推送
    public function __construct() {
        $this->clients = new \SplObjectStorage;
        $this->userConnections = [];
    }
    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})\n";
    }
    public function onMessage(ConnectionInterface $from, $msg) {
        $data = json_decode($msg, true);
        // 处理认证或消息路由
        if (isset($data['type']) && $data['type'] === 'auth') {
            // 存储用户ID与连接ID的映射
            $userId = $data['user_id'];
            $this->userConnections[$userId] = $from->resourceId;
            $from->user_id = $userId;
        }
        // 广播给所有用户
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }
    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected\n";
        // 清理映射
        if (isset($conn->user_id)) {
            unset($this->userConnections[$conn->user_id]);
        }
    }
    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";
        $conn->close();
    }
}

第二步：启动服务器

创建一个入口文件 server.php：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
require 'vendor/autoload.php';
$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new ChatServer()
        )
    ),
    8080 // 端口号
);
echo "WebSocket server started on ws://0.0.0.0:8080\n";
$server->run();

在终端运行：

php server.php

此时服务器开始监听8080端口。

客户端连接：JavaScript与WebSocket的握手

前端HTML示例：

<!DOCTYPE html>
<html>
<body>
<script>
    let ws = new WebSocket("ws://your-server-ip:8080");
    ws.onopen = function() {
        console.log("Connected");
        // 发送认证信息
        ws.send(JSON.stringify({
            type: 'auth',
            user_id: 123
        }));
    };
    ws.onmessage = function(event) {
        let data = JSON.parse(event.data);
        console.log("Received:", data);
        // 处理推送内容，如更新页面UI
    };
    ws.onclose = function() {
        console.log("Disconnected");
        // 可添加重连逻辑
    };
    // 发送消息
    function sendMessage(msg) {
        ws.send(JSON.stringify({
            type: 'chat',
            content: msg
        }));
    }
</script>
</body>
</html>

注意：如果使用HTTPS页面，必须用 wss:// 协议,并在服务器端配置SSL证书。

消息广播与定向推送实战

场景1：向所有在线用户广播

在企业OA系统中，当发布一条全员通知时,可以直接广播：

protected function broadcast($message) {
    foreach ($this->clients as $client) {
        $client->send(json_encode($message));
    }
}

场景2：向特定用户定向推送

针对消息提醒场景（如：用户A收到一条私信）：

public function sendToUser($userId, $data) {
    if (isset($this->userConnections[$userId])) {
        $connId = $this->userConnections[$userId];
        // 通过resourceId找到连接对象
        foreach ($this->clients as $client) {
            if ($client->resourceId === $connId) {
                $client->send(json_encode($data));
                break;
            }
        }
    }
}

场景3：从PHP业务代码触发推送

需要推送的时机往往发生在普通HTTP请求中（如用户下单成功），这时可以借助内部消息队列（如Redis Pub/Sub）桥接：

// 在HTTP处理脚本中
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->publish('notifications', json_encode([
    'user_id' => $userId,
    'order_id' => $orderId,
    'message' => '您有新的订单通知'
]));
// 在WebSocket服务端添加Redis订阅监听
// 通过ReactPHP的EventLoop集成

常见问题与性能优化

问题1：连接数超过1000后卡顿

原因：PHP单进程事件循环处理能力有限。

解决方案：

使用 Swoole 替代Ratchet（底层使用多线程/协程）
部署多个Worker进程（如Supervisor管理）
配置Nginx反向代理做负载均衡

问题2：客户端频繁断连重连

原因：网络不稳定或WebSocket心跳超时。

解决方案：

在服务端添加心跳检测：

// 使用ReactPHP的定时器
$this->loop->addPeriodicTimer(30, function() {
    foreach ($this->clients as $client) {
        if ($client->lastPing < time() - 60) {
            $client->close();
        }
    }
});

问题3：消息丢失

原因：无确认机制。

解决方案：在业务逻辑中引入消息序号或ACK响应。

性能优化建议

使用Unix Socket代替TCP：减少网络开销
数据压缩：对JSON进行gzip压缩
连接池：复用MySQL/Redis连接

Q&A：开发者最关心的5个问题

Q1：PHP做WebSocket真的适合生产环境吗？

A：完全适合，很多千万级用户的应用（如腾讯云监控、部分游戏后端）使用PHP+WorkerMan或Swoole实现WebSocket，关键在于合理架构：PHP作为连接处理层，后端业务逻辑通过队列异步处理，推荐Swoole作为生产级方案,性能接近Go语言。

Q2：如何保证WebSocket连接安全性？

A：三步走：

使用wss://（WebSocket over TLS）
连接时发送Token进行身份验证（如上文auth消息）
服务端验证Token有效性后，绑定用户身份

Q3：部署时需要注意什么？

A：最重要是端口放行、守护进程（使用nohup或Supervisor），如果是云服务器，需在安全组开启8080端口,且建议使用Nginx反向代理：

location /ws/ {
    proxy_pass http://127.0.0.1:8080;
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection "upgrade";
}

Q4：WebSocket和SSE（Server-Sent Events）有什么区别？

A：SSE是单向通道（服务器→客户端），基于HTTP协议，只能推送文本数据，WebSocket是双向通道，支持二进制数据，实时性更高，如果只需要服务器推送通知（如新闻更新），SSE更简单；如果需要双向交互（如聊天）,WebSocket是唯一选择。

Q5：如何调试WebSocket连接？

A：推荐工具：