php怎么连接websocket

admin 2026年03月02日 20:47 105 0

PHP连接WebSocket需借助第三方库，如Ratchet、Swoole或Guzzle，以Ratchet为例，首先通过Composer安装ratchet/pawl，创建客户端实例并设置连接地址（如ws://localhost:8080），绑定事件回调：onOpen处理连接成功，onMessage接收服务端消息，onClose处理断开，通过$client->send()发送数据，循环监听消息，需注意WebSocket协议（ws/wss）及握手过程，确保服务端与客户端协议匹配，Swoole则提供更底层的协程支持，适合高性能场景，实际开发中需根据需求选择库，并处理异常与重连机制。

PHP实现WebSocket连接：从入门到实践

WebSocket是一种在单个TCP连接上进行全双工通信的协议,它允许服务器主动向客户端推送数据，彻底解决了HTTP协议只能客户端发起请求的局限性，在实时通信场景（如聊天室、在线游戏、实时数据监控等）中，WebSocket发挥着不可替代的作用，PHP作为一门广泛使用的服务器端语言，如何实现WebSocket连接呢？本文将详细介绍PHP连接WebSocket的多种方式，从基础库到高性能扩展，并附上完整代码示例，助你快速掌握WebSocket开发技能。

WebSocket与PHP的关系

首先需要明确：PHP本身并不原生支持WebSocket，这是因为PHP传统的运行模式（如Apache mod_php、PHP-FPM）是基于请求-响应模型的，每个请求结束后进程会释放，无法维持长连接，要实现WebSocket通信，需要借助以下方式：

基于PHP的长连接库（如Ratchet）：通过PHP脚本模拟WebSocket服务，适合中小型项目，开发门槛较低。
PHP扩展（如Swoole）：以扩展形式运行，提供高性能的异步网络通信能力，适合高并发场景，但需要额外安装。
第三方服务集成：如使用Socket.io与PHP配合，或通过中转服务（如Pusher）实现，适合已有基础设施的项目。

本文重点讲解前两种主流实现方案。

使用Ratchet库实现WebSocket（PHP原生方案）

Ratchet是一个基于PHP的WebSocket库,它遵循React事件循环模型，允许开发者用PHP构建功能完整的WebSocket服务，以下是具体实现步骤：

安装Ratchet

通过Composer安装Ratchet（确保已安装Composer）：

composer require cboden/ratchet

创建WebSocket服务端

创建一个WebSocketServer.php文件，定义一个简单的聊天室服务，实现连接管理、消息广播和错误处理：

<?php
require_once 'vendor/autoload.php';
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
class Chat implements MessageComponentInterface {
protected $clients; // 存储所有客户端连接
protected $usernames = []; // 存储用户名映射
public function __construct() {
    $this->clients = new \SplObjectStorage();
}
// 新客户端连接时触发
public function onOpen(ConnectionInterface $conn) {
    $this->clients->attach($conn);
    $this->usernames[$conn->resourceId] = '匿名用户';
    echo "新连接建立！当前连接数：{$this->clients->count()}\n";
    // 通知所有客户端
    $this->broadcast("欢迎新用户加入聊天室！");
}
// 收到客户端消息时触发
public function onMessage(ConnectionInterface $from, $msg) {
    $data = json_decode($msg, true);
    if (isset($data['type'])) {
        switch ($data['type']) {
            case 'username':
                // 设置用户名
                $this->usernames[$from->resourceId] = $data['name'];
                $this->broadcast("{$data['name']} 加入了聊天室");
                break;
            case 'message':
                // 广播消息
                $username = $this->usernames[$from->resourceId] ?? '匿名用户';
                $this->broadcast("{$username}: {$data['text']}");
                break;
        }
    }
}
// 客户端断开连接时触发
public function onClose(ConnectionInterface $conn) {
    $username = $this->usernames[$conn->resourceId] ?? '匿名用户';
    unset($this->usernames[$conn->resourceId]);
    $this->clients->detach($conn);
    echo "连接已关闭！当前连接数：{$this->clients->count()}\n";
    $this->broadcast("{$username} 离开了聊天室");
}
// 发生错误时触发
public function onError(ConnectionInterface $conn, \Exception $e) {
    echo "发生错误：{$e->getMessage()}\n";
    $conn->close();
}
// 向所有客户端广播消息
protected function broadcast($message) {
    foreach ($this->clients as $client) {
        $client->send(json_encode(['type' => 'system', 'text' => $message]));
    }
}
// 启动WebSocket服务
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
$server = IoServer::factory(
new HttpServer(
new WsServer(
new Chat()
)
),
8080 // 监听8080端口
);
echo "WebSocket服务已启动，监听端口：8080\n";
$server->run();

启动服务

在终端运行PHP脚本：

php WebSocketServer.php

服务启动后会监听8080端口,等待客户端连接，建议使用nohup或supervisor保持服务持续运行。

创建客户端测试

创建一个功能丰富的HTML客户端（client.html），实现用户名设置和消息发送：

<!DOCTYPE html>
<html>
<head>
    <title>PHP WebSocket聊天室</title>
    <style>
        body { font-family: Arial, sans-serif; margin: 20px; }
        #log { border: 1px solid #ccc; padding: 10px; height: 300px; overflow-y: scroll; margin-bottom: 10px; }
        #messageInput { width: 70%; padding: 5px; }
        button { padding: 5px 10px; }
        .system { color: #888; font-style: italic; }
        .username { color: #0066cc; font-weight: bold; }
    </style>
</head>
<body>
    <div id="log"></div>
    <div>
        <input type="text" id="usernameInput" placeholder="设置用户名">
        <button onclick="setUsername()">设置用户名</button>
    </div>
    <div>
        <input type="text" id="messageInput" placeholder="输入消息">
        <button onclick="sendMessage()">发送</button>
    </div>
&lt;script&gt;
    const ws = new WebSocket("ws://127.0.0.1:8080");
    const log = document.getElementById("log");
    const messageInput = document.getElementById("messageInput");
    const usernameInput = document.getElementById("usernameInput");
    // 连接建立时
    ws.onopen = function() {
        log.innerHTML += "&lt;p class='system'&gt;已连接到服务器&lt;/p&gt;";
    };
    // 收到消息时
    ws.onmessage = function
		    	
        	        		标签：        		    #PHP WebSocket