Swoole WebSocket 并发架构与实战：从原理到部署

引言

使用 Swoole 开发 WebSocket 服务时，很多从传统 PHP-FPM 转过来的开发者会有一个疑问：每个 WebSocket 连接是否对应一个独立的进程或线程？ 答案是否定的。Swoole 采用“多进程 + 协程”的架构，能在一个极小的资源开销下支撑数十万乃至百万级并发连接。本文将深入解析 Swoole 的并发模型，并通过一个完整的多人聊天室示例，带你从零开始构建高性能 WebSocket 服务。最后，我们将探讨在生产环境中如何调整系统限制，以确保服务器能承载预期的连接数。

一、Swoole 的并发模型：进程、线程与协程

1.1 传统 PHP 的局限

在 PHP-FPM 模式下，每个请求都会启动一个进程，处理完即销毁。这种方式无法维持长连接，更不可能同时处理数万连接，因为进程创建和内存开销极大。

1.2 Swoole 的多进程 + 协程架构

Swoole 的 WebSocket 服务器在启动时会创建固定数量的 Worker 进程（例如 8 个），这些进程常驻内存，负责处理所有连接的业务逻辑。每个连接不是独占一个进程，而是通过协程（Coroutine）来实现并发。

核心组件：

Master 进程：负责监听端口、管理 Reactor 线程和 Worker 进程。
Reactor 线程池：负责网络 I/O 的读写，将数据分发给 Worker 进程。
Worker 进程池：固定的进程数，处理业务逻辑（解析消息、数据库操作、广播等）。
协程：在每个 Worker 进程内，每个连接对应一个协程。协程的切换开销远小于线程或进程，几 KB 的内存即可承载一个协程，从而让单个 Worker 进程可同时处理数千连接。

下面这张图清晰地展示了客户端连接如何在 Swoole 内部流转：

graph TD
    subgraph Client [客户端]
        C1[客户端 1]
        C2[客户端 2]
        C3[客户端 3]
        C4[客户端 ...]
    end

    subgraph SwooleServer [Swoole WebSocket 服务器]
        direction LR
        Master[主进程<br>Master Process<br>负责创建和管理子进程]
        
        subgraph Reactor [Reactor 线程池]
            R1[Reactor 线程]
            R2[Reactor 线程]
            R3[Reactor 线程]
        end
        
        subgraph Workers [Worker 进程池]
            direction TB
            W1[Worker 进程 1<br>协程1 协程2 ...]
            W2[Worker 进程 2<br>协程1 协程2 ...]
            W3[Worker 进程 N<br>协程1 协程2 ...]
        end
    end

    C1 ---> R1
    C2 ---> R2
    C3 ---> R3
    C4 ---> R1
    
    R1 --> W1
    R2 --> W2
    R3 --> W3

当某个连接需要等待 I/O（如数据库查询）时，Swoole 会自动挂起该协程，Worker 进程转而去处理其他协程的任务，待 I/O 完成后再恢复执行。这种机制使得 CPU 利用率极高，且无需开发者手动处理异步回调。

1.3 对比总结

特性	误解：每个连接一个线程/进程	实际：Swoole 架构
连接与进程关系	1 个连接 = 1 个进程/线程	多个连接共享固定数量 Worker 进程
并发实现方式	通过大量进程/线程	通过少量进程 + 大量协程
内存开销	极高（每个线程几 MB）	极低（每个协程几 KB）
最大连接数	受进程/线程数限制（通常几千）	可达数十万甚至百万
典型代表	PHP-FPM, Apache	Swoole, Nginx, Node.js

二、实战：用 Swoole 开发一个多人聊天室

下面我们构建一个简单的聊天室，所有连接的用户都能看到彼此发送的消息。

2.1 服务端代码 `chat_server.php`

<?php
use Swoole\WebSocket\Server;
use Swoole\Http\Request;
use Swoole\WebSocket\Frame;

// 创建 WebSocket 服务器，监听 0.0.0.0:9501
$server = new Server("0.0.0.0", 9501);

// 使用 Swoole\Table 存储所有客户端连接的文件描述符（fd），以便多进程共享
$connections = new Swoole\Table(1024);
$connections->column('fd', Swoole\Table::TYPE_INT);
$connections->create();

// 监听 WebSocket 连接打开事件
$server->on('open', function (Server $server, Request $request) use ($connections) {
    $fd = $request->fd;
    $connections->set((string)$fd, ['fd' => $fd]);
    echo "新连接: fd={$fd}\n";

    // 欢迎消息
    $server->push($fd, "欢迎加入聊天室！");
    // 通知其他人
    foreach ($connections as $conn) {
        if ($conn['fd'] != $fd) {
            $server->push($conn['fd'], "用户 {$fd} 进入房间");
        }
    }
});

// 监听 WebSocket 消息事件
$server->on('message', function (Server $server, Frame $frame) use ($connections) {
    $fd = $frame->fd;
    $data = $frame->data;
    echo "收到消息: fd={$fd}, data={$data}\n";

    // 广播给所有客户端
    foreach ($connections as $conn) {
        $server->push($conn['fd'], "用户 {$fd} 说: {$data}");
    }
});

// 监听 WebSocket 连接关闭事件
$server->on('close', function (Server $server, int $fd) use ($connections) {
    $connections->del((string)$fd);
    echo "连接关闭: fd={$fd}\n";

    // 广播离开消息
    foreach ($connections as $conn) {
        $server->push($conn['fd'], "用户 {$fd} 离开了聊天室");
    }
});

// 启动服务器
$server->start();

关键点：
使用 Swoole\Table 存储连接的 fd，这是共享内存结构，可在多个 Worker 进程间共享。
广播时遍历所有连接，向每个客户端推送消息。如果连接已断开，push 可能会失败，可根据实际情况忽略错误。

2.2 客户端代码 `index.html`

<!DOCTYPE html>
<html lang="zh">
<head>
    <meta charset="UTF-8">
    <title>Swoole 多人聊天室</title>
    <style>
        body { font-family: Arial, sans-serif; margin: 20px; }
        #messages { list-style: none; padding: 0; height: 300px; overflow-y: auto; border: 1px solid #ccc; margin-bottom: 10px; }
        #messages li { padding: 5px; border-bottom: 1px solid #eee; }
        #form { display: flex; }
        #input { flex: 1; padding: 8px; }
        button { padding: 8px 15px; }
    </style>
</head>
<body>
    <h2>Swoole 多人聊天室</h2>
    <ul id="messages"></ul>
    <form id="form" action="">
        <input id="input" autocomplete="off" />
        <button>发送</button>
    </form>

    <script>
        const ws = new WebSocket("ws://你的服务器IP:9501");
        const messages = document.getElementById('messages');
        const input = document.getElementById('input');
        const form = document.getElementById('form');

        ws.onmessage = function(event) {
            const li = document.createElement('li');
            li.textContent = event.data;
            messages.appendChild(li);
            messages.scrollTop = messages.scrollHeight;
        };

        form.addEventListener('submit', function(e) {
            e.preventDefault();
            if (input.value) {
                ws.send(input.value);
                input.value = '';
            }
        });
    </script>
</body>
</html>

注意：将 ws://你的服务器IP:9501 替换为实际服务器的 IP 和端口。

2.3 运行测试

启动服务端：php chat_server.php
启动一个简易 HTTP 服务器（用于托管 index.html）：php -S 0.0.0.0:8080
用多个浏览器标签页或不同设备访问 http://服务器IP:8080，即可模拟多人聊天。

三、系统限制：文件描述符与 ulimit

当连接数增长时，我们需要确保操作系统允许打开足够多的文件描述符（每个网络连接占用一个）。默认的 ulimit -n 通常为 1024，对于高并发服务远远不够。

3.1 查看当前使用情况

系统整体已分配的文件描述符数：
```
cat /proc/sys/fs/file-nr
```
输出示例：3120 0 9223372036854775807
- 第一个数字 = 当前已分配数量
- 第二个 = 未使用但已分配的数量（通常为 0）
- 第三个 = 系统最大限制（fs.file-max）

查看某个进程（如 Swoole 服务）的文件描述符使用数：

ps aux | grep swoole          # 获取进程 PID
ls /proc/<PID>/fd | wc -l     # 统计 fd 目录下的文件数

统计当前 TCP 连接数（ESTABLISHED）：
```
ss -tan | grep ESTAB | wc -l
```

3.2 临时修改（重启后失效）

ulimit -n 1000000

该命令只影响当前 shell 会话，关闭终端即恢复。

3.3 永久修改

3.3.1 修改 `/etc/security/limits.conf`

* soft nofile 1000000
* hard nofile 1000000
root soft nofile 1000000
root hard nofile 1000000

修改后需重新登录才能生效。

3.3.2 针对 systemd 管理的服务（如 PHP-FPM、Swoole 守护进程）

在服务单元文件（如 /etc/systemd/system/swoole.service）中添加：

[Service]
LimitNOFILE=1000000

然后执行 systemctl daemon-reload 并重启服务。

3.3.3 WSL（Windows Subsystem for Linux）特殊配置

WSL 中 /etc/security/limits.conf 可能不生效，推荐使用以下方法：

创建或编辑 /etc/wsl.conf：
```
[boot]
command="ulimit -n 1000000"
```
或者修改 Windows 宿主目录下的 .wslconfig 文件（位于用户目录），增加：
```
[wsl2]
kernelCommandLine = "sysctl fs.file-max=1000000"
```
修改后需完全重启 WSL：wsl --shutdown，再重新启动。

3.4 系统上限 `fs.file-max`

fs.file-max 是系统级的总文件描述符上限。可通过以下命令查看：

cat /proc/sys/fs/file-max

临时修改：

sysctl -w fs.file-max=1000000

永久修改：在 /etc/sysctl.conf 中添加 fs.file-max=1000000，然后执行 sysctl -p。

注意：即使将 ulimit -n 和 fs.file-max 设置得非常大，实际能支撑的连接数仍受服务器内存限制（每个连接约几 KB 内存开销）。

四、总结

Swoole 通过 多进程 + 协程 的架构，打破了传统 PHP 的并发瓶颈。它利用少量常驻进程和轻量级协程，高效处理海量网络连接，是构建 WebSocket 服务、即时通讯、游戏服务器的理想选择。开发时，我们只需按事件驱动的模式编写业务逻辑，无需关心底层并发细节。部署时，合理调整系统文件描述符限制，就能让服务平滑支撑数万甚至数十万并发连接。

希望本文能帮助你从原理到实践全面掌握 Swoole WebSocket 的开发与运维。如果你想进一步探索房间管理、用户认证、消息持久化等高级功能，可以在现有代码基础上轻松扩展。

版权属于：Joyber
本文链接：https://blog.qqvbc.com/default/1443.html
转载时须注明出处及本声明

Swoole WebSocket 的基础开发思想与运维

Swoole WebSocket 并发架构与实战：从原理到部署

引言

一、Swoole 的并发模型：进程、线程与协程

1.1 传统 PHP 的局限

1.2 Swoole 的多进程 + 协程架构

1.3 对比总结

二、实战：用 Swoole 开发一个多人聊天室

2.1 服务端代码 `chat_server.php`

2.2 客户端代码 `index.html`

2.3 运行测试

三、系统限制：文件描述符与 ulimit

3.1 查看当前使用情况

3.2 临时修改（重启后失效）

3.3 永久修改

3.3.1 修改 `/etc/security/limits.conf`

3.3.2 针对 systemd 管理的服务（如 PHP-FPM、Swoole 守护进程）

3.3.3 WSL（Windows Subsystem for Linux）特殊配置

3.4 系统上限 `fs.file-max`

四、总结

添加新评论

友情链接

最新文章

最近回复

分类

标签

热门文章

其它

Swoole WebSocket 的基础开发思想与运维

Swoole WebSocket 并发架构与实战：从原理到部署

引言

一、Swoole 的并发模型：进程、线程与协程

1.1 传统 PHP 的局限

1.2 Swoole 的多进程 + 协程架构

1.3 对比总结

二、实战：用 Swoole 开发一个多人聊天室

2.1 服务端代码 chat_server.php

2.2 客户端代码 index.html

2.3 运行测试

三、系统限制：文件描述符与 ulimit

3.1 查看当前使用情况

3.2 临时修改（重启后失效）

3.3 永久修改

3.3.1 修改 /etc/security/limits.conf

3.3.2 针对 systemd 管理的服务（如 PHP-FPM、Swoole 守护进程）

3.3.3 WSL（Windows Subsystem for Linux）特殊配置

3.4 系统上限 fs.file-max

四、总结

添加新评论

友情链接

最新文章

最近回复

分类

标签

热门文章

其它

2.1 服务端代码 `chat_server.php`

2.2 客户端代码 `index.html`

3.3.1 修改 `/etc/security/limits.conf`

3.4 系统上限 `fs.file-max`