当前位置：首页 > 文章列表 > 文章 > php教程 > PHP实现WebSocket实时通信教程

PHP实现WebSocket实时通信教程

2025-07-20 16:15:22 0浏览收藏

想要用PHP搭建WebSocket实时通信服务吗？本文为你提供一份详尽的教程，带你从零开始，掌握PHP实现WebSocket的技巧。文章首先介绍了WebSocket的基础知识和环境要求，强调了使用CLI模式和Sockets扩展的重要性。接着，详细讲解了如何通过原生PHP的`socket_create`等函数，实现WebSocket服务端的创建、握手和数据帧解析。为了简化开发，文章还推荐使用Ratchet框架，并通过Composer安装和创建监听类、启动脚本，让你快速搭建一个完整的WebSocket服务。此外，本文还强调了在生产环境中，需要注意避免在Apache/FPM下运行，确保端口开放并设计心跳机制，以及结合Workerman、Swoole等提升性能的方案。无论你是PHP新手还是有一定经验的开发者，都能通过本文轻松掌握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？实时通信服务搭建指南

用 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 服务。以下是主要流程：

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

握手部分要特别注意，客户端发起 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();

然后运行：