PHP实现WebSocket实时通信方法

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《PHP实现WebSocket实时通信教程》，这篇文章主要讲到等等知识，如果你对文章相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

用 PHP 实现 WebSocket 需要借助 CLI 模式和 Sockets 扩展或框架如 Ratchet；1. 安装 PHP CLI 并启用 Sockets 扩展；2. 使用 socket_create 等函数实现原生 WebSocket 服务，完成握手和数据帧解析；3. 推荐使用 Ratchet 框架简化开发，通过 Composer 安装并创建监听类和启动脚本；4. 注意避免在 Apache/FPM 下运行，确保端口开放并设计心跳机制；5. 生产环境可结合 Workerman、Swoole 提升性能。

用 PHP 实现 WebSocket 其实并不复杂，但也不是像写个 HTML 页面那样直接。因为 PHP 本身是面向 HTTP 请求的脚本语言，而 WebSocket 是一种长连接、双向通信的协议，需要额外借助一些工具或扩展来实现。

不过只要掌握了基本原理和流程，你就能在自己的项目中搭建起一个简单的实时通信服务了。下面我们就一步步来看怎么做。

准备工作：了解基础和环境要求

WebSocket 是基于 TCP 的协议，客户端和服务端建立连接后，可以互相发送消息。PHP 要实现 WebSocket 服务端，不能依赖传统的 Apache + mod_php 模式，而是需要用 CLI（命令行）方式运行一个常驻进程。

你需要：

• 安装 PHP CLI 环境
• 推荐使用 Sockets 扩展（默认一般都启用）
• 可选：安装 Ratchet 这类框架简化开发

如果你是在本地测试，XAMPP 或 WAMP 都支持 CLI；如果是服务器环境，确保可以通过命令行执行 PHP 脚本。

原生 PHP 实现 WebSocket 的核心步骤

如果你不想引入额外框架，可以直接使用 socket_create 和相关函数来实现一个最简版的 WebSocket 服务。以下是主要流程：

1. 创建 socket 并绑定地址和端口
2. 监听连接请求
3. 接受客户端连接并处理握手
4. 解析和响应 WebSocket 数据帧
5. 循环读取和发送消息

握手部分要特别注意，客户端发起 WebSocket 请求时会带 Sec-WebSocket-Key 头，服务端需要计算对应的响应值，否则连接会被拒绝。

示例代码片段如下：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($socket, '0.0.0.0', 8080);
socket_listen($socket);

$client = socket_accept($socket);
$request = socket_read($client, 2048);

// 解析 Sec-WebSocket-Key
preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $request, $matches);
$key = base64_encode(pack('H*', sha1($matches[1] . '258EAFA5-E914-47DA-95CA-C5AB6DC6DEAD')));

$headers = "HTTP/1.1 101 Switching Protocols\r\n";
$headers .= "Upgrade: websocket\r\n";
$headers .= "Connection: Upgrade\r\n";
$headers .= "Sec-WebSocket-Accept: $key\r\n\r\n";
socket_write($client, $headers, strlen($headers));

// 开始收发数据
while (true) {
    $data = socket_read($client, 1024);
    // 解析数据帧...
}

这只是一个简化版本，实际使用中还要处理断开连接、多客户端管理等问题。

使用 Ratchet 框架更省事

如果你想更快上手，推荐使用 Ratchet，这是一个专为 PHP 设计的 WebSocket 框架，封装好了握手、消息解析等底层逻辑。

安装方式很简单，用 Composer 即可：

composer require cboden/ratchet

然后创建一个监听类，比如 Chat.php：

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    public function onOpen(ConnectionInterface $conn) {
        echo "New connection!\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $from->send("You said: $msg");
    }

    public function onClose(ConnectionInterface $conn) {
        echo "Connection closed\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "Error: {$e->getMessage()}\n";
    }
}

再写一个启动脚本 server.php：

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

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

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

$server->run();

然后运行：

php server.php

这样就起了一个完整的 WebSocket 服务，支持多个客户端连接和消息转发。

注意事项和常见问题

• 不要在 Apache/FPM 下运行 WebSocket：这些环境不适合长连接，只能用 CLI 方式启动。
• 防火墙和端口开放：确保服务器的对应端口（如 8080）对客户端开放。
• 心跳机制：长时间不通讯可能被中间设备断开，建议定期发送 ping/pong 消息保持连接。
• 生产环境部署：Ratchet 适合小规模使用，如果并发量大，建议结合 Workerman、Swoole 等高性能方案。

基本上就这些。虽然 PHP 不是天生适合做 WebSocket 的语言，但通过合适的工具和结构设计，还是能很好地完成实时通信的任务。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~