Swoole 深度研究报告

1. 项目概述

1.1 基本信息

1.2 核心定位

Swoole 是 PHP 的异步、并行、高性能网络通信引擎

它打破了 PHP 传统 Web 领域的限制，使 PHP 能够用于：

• 高性能 Web 服务器
• WebSocket 实时通信
• TCP/UDP 服务
• 物联网 (IoT)
• 微服务架构
• 游戏服务器

---

2. 架构设计

2.1 整体架构

┌─────────────────────────────────────────────────────────────────┐
│                        Application Layer                        │
│              (PHP 代码 - 同步写法，异步执行)                      │
├─────────────────────────────────────────────────────────────────┤
│                      Coroutine Layer                            │
│         (协程调度器 - C 实现，类似 Go goroutine)                  │
├─────────────────────────────────────────────────────────────────┤
│                       Event Loop                                │
│            (epoll/kqueue - Linux/macOS 原生)                    │
├─────────────────────────────────────────────────────────────────┤
│                      Network Layer                              │
│         (TCP/UDP/HTTP/WebSocket/HTTP2 Server)                   │
└─────────────────────────────────────────────────────────────────┘

2.2 核心组件

---

3. 协程 (Coroutine) 详解

3.1 与 Go Goroutine 的对比

3.2 协程调度原理

<?php
use function Swoole\Coroutine
un;
use function Swoole\Coroutine\go;

run(function () {
    // 启动 100 个协程
    for ($i = 0; $i < 100; $i++) {
        go(function () {
            // 同步写法
            $mysql = new Swoole\Coroutine\MySQL();
            $mysql->connect($config);
            
            // 此处发生 I/O 时，协程挂起
            $result = $mysql->query('SELECT * FROM users');
            
            // I/O 完成后，协程恢复
            echo count($result);
        });
    }
});
// 100 个查询并发执行，总耗时 = 最慢的那个

3.3 性能数据

// 10K MySQL 并发查询
$s = microtime(true);
Co
un(function() {
    for ($c = 100; $c--; ) {
        go(function () {
            $mysql = new Swoole\Coroutine\MySQL;
            $mysql->connect([...]);
            $statement = $mysql->prepare('SELECT * FROM `user`');
            for ($n = 100; $n--; ) {
                $result = $statement->execute();
            }
        });
    }
});
echo 'use ' . (microtime(true) - $s) . ' s';
// 输出: use 0.2 s (10K 查询仅需 0.2 秒!)

---

4. 服务器类型

4.1 HTTP Server

<?php
$server = new Swoole\HTTP\Server("0.0.0.0", 9501);

$server->on("request", function ($request, $response) {
    // 协程环境，可以使用协程客户端
    $mysql = new Swoole\Coroutine\MySQL();
    $mysql->connect([...]);
    $result = $mysql->query('SELECT * FROM users WHERE id = ' . $request->get['id']);
    $response->end(json_encode($result));
});

$server->start();

4.2 WebSocket Server

<?php
$server = new Swoole\WebSocket\Server("0.0.0.0", 9502);

$server->on('open', function ($server, $req) {
    echo "连接打开: {$req->fd}
";
});

$server->on('message', function ($server, $frame) {
    // 广播给所有客户端
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

$server->on('close', function ($server, $fd) {
    echo "连接关闭: {$fd}
";
});

$server->start();

4.3 TCP/UDP Server

<?php
// TCP 服务器
$server = new Swoole\Server('0.0.0.0', 9503, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

$server->on('receive', function ($server, $fd, $reactor_id, $data) {
    $server->send($fd, "Server: " . $data);
});

$server->start();

---

5. Runtime Hook 黑科技

5.1 原理

Swoole 4.1+ 引入了 Runtime::enableCoroutine()，可以一键将同步 PHP 代码转为异步协程：

<?php
Swoole\Runtime::enableCoroutine();

$s = microtime(true);
Co
un(function() {
    for ($c = 100; $c--; ) {
        go(function () {
            // 原生 Redis 扩展，自动变成协程！
            ($redis = new Redis)->connect('127.0.0.1', 6379);
            for ($n = 100; $n--; ) {
                $redis->get('key');
            }
        });
    }
});
// 10K 请求仅需 0.1 秒

5.2 支持的 Hook

---

6. 生态框架

6.1 Hyperf 示例

<?php
namespace App\Controller;

use Hyperf\HttpServer\Annotation\AutoController;

#[AutoController]
class UserController
{
    public function index()
    {
        // 自动协程环境
        $users = User::query()->where('status', 1)->get();
        return $users;
    }
    
    public function async()
    {
        // 并行请求多个服务
        $results = parallel([
            fn() => $this->serviceA->get(),
            fn() => $this->serviceB->get(),
            fn() => $this->serviceC->get(),
        ]);
        return $results;
    }
}

---

7. 与其他方案对比

7.1 PHP 服务器对比

7.2 跨语言对比

---

8. 使用场景

✅ 适合使用

1. 高并发 API 服务

- 10K+ 并发连接 - I/O 密集型操作

1. 实时通信

- WebSocket 聊天室 - 实时推送系统 - 在线游戏

1. 微服务架构

- gRPC 服务 - 服务注册发现 - 熔断降级

1. IoT 网关

- TCP/UDP 设备接入 - 百万级设备并发

❌ 不适合使用

1. CPU 密集型计算

- 协程不适合纯计算 - 应使用多进程/多线程

1. 传统 CRUD 项目

- PHP-FPM 更简单 - Swoole 有学习成本

1. 需要动态扩容的场景

- Swoole 文件大小固定 - 不支持文件热更新

---

9. 性能对比数据

9.1 与 PHP-FPM 对比

9.2 与 Go 对比

---

10. 安装与部署

10.1 安装

# PECL 安装
pecl install swoole

# 或 Docker
docker run --rm phpswoole/swoole "php --ri swoole"

# 编译安装
git clone https://github.com/swoole/swoole-src.git
cd swoole-src
phpize && ./configure && make && sudo make install

10.2 配置 php.ini

extension=swoole.so

; 可选配置
swoole.enable_coroutine=On
swoole.enable_preemptive_scheduler=On

---

11. 最佳实践

11.1 连接池

<?php
use Swoole\Database\PDOPool;

$pool = new PDOPool($config, 64); // 64 个连接

$server->on('request', function ($request, $response) use ($pool) {
    $pdo = $pool->get();      // 获取连接
    // ... 使用 ...
    $pool->put($pdo);         // 归还连接
});

11.2 热更新

<?php
$server->on('WorkerStart', function ($server, $workerId) {
    // 监控文件变化
    Timer::tick(3000, function () {
        if (fileChanged()) {
            $server->reload();  // 平滑重启 Worker
        }
    });
});

11.3 进程间通信

<?php
use Swoole\Table;

// 共享内存表
$table = new Table(1024);
$table->column('name', Table::TYPE_STRING, 64);
$table->column('count', Table::TYPE_INT);
$table->create();

$server->table = $table;

---

12. 总结

核心优势

1. PHP 生态 + 高性能: 不改语言，获得接近 Go 的 I/O 性能
2. 同步代码，异步执行: 无回调地狱，开发体验好
3. 协程无锁: 单线程调度，无需担心数据竞争
4. 功能全面: Server、WebSocket、定时器、任务队列一应俱全

适用团队

• PHP 团队需要高性能服务
• 不想切换到 Go/Node.js
• 需要快速开发实时应用

注意事项

• 学习成本较高 (异步思维)
• 调试相对复杂
• 部分 PHP 扩展不兼容

---

研究时间: 2026-03-07
标签: #Swoole #PHP #协程 #高性能 #异步编程 #WebSocket #微服务