PHP怎样处理WebSocket连接 PHP处理WebSocket连接指南-php教程-PHP中文网

PHP怎样处理WebSocket连接 PHP处理WebSocket连接指南

穿越時空

发布： 2025-06-24 19:16:01

原创

603人浏览过

要使用php处理websocket连接，需借助第三方库如ratchet或swoole；1.选择适合的库（如ratchet适合入门，swoole适合高并发）；2.通过composer安装ratchet；3.编写服务器代码实现连接、消息接收等事件处理；4.运行php脚本启动websocket服务器；5.编写javascript客户端代码连接服务器并收发消息；6.ratchet基于reactphp事件循环处理并发，swoole提供更高性能异步io支持；7.身份验证可在握手阶段传递token、使用http cookie或自定义认证协议；8.授权需在服务端维护权限表并检查用户权限；9.消息可靠传输依赖tcp协议，并可结合确认机制、序列号和心跳检测来增强可靠性。

PHP怎样处理WebSocket连接 PHP处理WebSocket连接指南

PHP处理WebSocket连接，说白了，就是让你的PHP服务器能跟客户端（比如浏览器）建立一种“长连接”，这样服务器就能主动推送消息给客户端，而不是像传统的HTTP请求那样，客户端问一句，服务器答一句。

实现这个功能，你需要借助一些现成的库，因为PHP本身并没有内置WebSocket支持。

解决方案

立即学习“PHP免费学习笔记（深入）”；

要用PHP处理WebSocket连接，主要分以下几个步骤：

选择一个WebSocket库：这是关键。有很多选择，比如Ratchet、Swoole等等。Ratchet比较成熟，文档也相对完善，适合新手入门。Swoole性能更好，但配置稍微复杂一些。这里我们以Ratchet为例。
安装Ratchet：使用Composer安装，这是PHP的依赖管理工具。
```
composer require cboden/ratchet
```
登录后复制

编写WebSocket服务器代码：你需要创建一个PHP脚本，这个脚本会监听一个特定的端口，等待客户端连接。这个脚本需要实现Ratchet提供的几个接口，用来处理连接、消息接收、断开连接等事件。

<?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use Ratchet\Http\HttpServer;

require __DIR__ . '/vendor/autoload.php';

class MyWebSocket implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        echo sprintf('Connection %d sending message "%s" to %d other connection(s)' . "\n"
            , $from->resourceId, $msg, count($this->clients) - 1);

        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";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new MyWebSocket()
        )
    ),
    8080 // 监听端口
);

$server->run();

登录后复制

运行WebSocket服务器：在命令行中运行你的PHP脚本。
```
php your_websocket_server.php
```
登录后复制

编写客户端代码：用JavaScript编写客户端代码，连接到你的WebSocket服务器，并发送和接收消息。

var conn = new WebSocket('ws://localhost:8080');
conn.onopen = function(e) {
    console.log("Connection established!");
};

conn.onmessage = function(e) {
    console.log(e.data);
};

conn.send('Hello World!');

登录后复制

测试：在浏览器中打开你的HTML页面，看看能否成功连接到服务器，并发送和接收消息。

PHP WebSocket服务器如何处理并发连接？

PHP本身是单线程的，但像Ratchet和Swoole这样的库，底层使用了异步非阻塞IO，这意味着它们可以同时处理多个连接，而不会阻塞主线程。Ratchet基于ReactPHP，利用事件循环机制来处理并发。Swoole则更进一步，它是一个PHP扩展，提供了更底层的异步IO支持，性能更高。选择哪个取决于你的具体需求，如果并发量不高，Ratchet足够用；如果需要处理大量的并发连接，Swoole可能是更好的选择。

如何在WebSocket中实现身份验证和授权？

身份验证和授权是WebSocket应用中非常重要的部分。你可以通过以下几种方式实现：

握手阶段传递Token：在客户端发起WebSocket连接时，可以在URL中包含一个Token，服务器在onOpen事件中验证这个Token，如果Token无效，则拒绝连接。

// 客户端
var conn = new WebSocket('ws://localhost:8080?token=your_secret_token');

// 服务器端 (onOpen方法中)
public function onOpen(ConnectionInterface $conn) {
    $uri = $conn->httpRequest->getUri();
    parse_str($uri->getQuery(), $parameters);
    $token = $parameters['token'] ?? null;

    if ($token !== 'your_secret_token') {
        $conn->close(); // 拒绝连接
        return;
    }

    $this->clients->attach($conn);
    echo "New connection! ({$conn->resourceId})\n";
}

登录后复制

HTTP Cookie：WebSocket握手请求也包含HTTP Cookie，你可以利用这个机制传递session ID，然后在服务器端验证session。
自定义认证协议：你也可以在WebSocket连接建立之后，自定义一个认证协议，客户端发送认证信息，服务器验证通过后才允许进行后续操作。

授权方面，可以根据用户的角色或权限，控制他们可以访问哪些资源或执行哪些操作。这需要在服务器端维护一个用户权限表，并在处理消息时进行权限检查。