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

PHP实现WebSocket实时通信方法

2025-08-14 13:19:33 0浏览收藏

学习文章要努力，但是不要急！今天的这篇文章《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();

然后运行：