Fibers（纤程）是一种轻量级的并发原语，可以在用户态实现协作式多任务。PHP 8.1引入了Fibers，为PHP的并发编程带来了新的可能。本文从架构设计的角度，讲解如何基于Fibers构建高可用高并发的系统，包括整体架构、调度器设计、IO多路复用、错误处理、限流熔断、监控告警等。如果你在做高并发系统，或者对Fibers感兴趣，希望这篇文章能给你一些参考。

一、为什么选择Fibers

先说说为什么要在架构中使用Fibers。

传统的PHP并发方案主要有多进程和多线程两种。多进程模式（比如PHP-FPM）每个请求一个进程，优点是稳定、隔离性好，缺点是进程开销大，并发数受限于进程数，而且进程间通信复杂。

多线程模式开销比进程小，但是PHP的线程安全版本性能不好，而且很多扩展不支持多线程，实际使用中问题很多。

Fibers提供了第三种选择：用户态的协作式多任务。一个进程内可以运行成千上万个Fiber，每个Fiber的开销很小（只有几KB的栈空间），切换成本也很低。这使得PHP可以处理大量并发连接，而不需要大量的进程或线程。

Fibers的核心优势：

  • 轻量级：一个进程可以创建上万个Fiber
  • 低开销：创建和切换的成本很低
  • 协作式：不需要锁，因为Fiber主动让出控制权
  • 同步编程风格：用同步的写法实现异步的效果

当然，Fibers也有局限性。它是协作式的，如果一个Fiber不主动让出控制权，就会阻塞整个进程。所以Fibers适合IO密集型的场景，不适合CPU密集型的场景。

二、整体架构设计

基于Fibers的高并发系统，整体架构分为几个层次。

接入层

接入层负责接收客户端连接，包括TCP/UDP服务器、HTTP服务器等。接入层用非阻塞IO，把连接事件交给事件循环处理。

接入层的核心是事件循环（Event Loop），用stream_select或者libevent扩展实现。事件循环监听所有的socket，当有可读或可写事件时，唤醒对应的Fiber来处理。

调度层

调度层负责Fiber的创建、调度和销毁。调度器维护一个就绪队列和一个等待队列，当Fiber需要等待IO时，把它放到等待队列；当IO就绪时，把它移回就绪队列。

调度器是整个系统的核心，它决定了哪个Fiber在什么时候运行。好的调度器应该公平、高效、可预测。

业务层

业务层是具体的业务逻辑，每个请求在一个独立的Fiber中运行。业务代码用同步的风格编写，遇到IO操作时，通过Fiber::suspend()让出控制权，等IO完成后再恢复执行。

业务层不需要关心底层的并发细节，就像写普通的同步代码一样，但是实际上是异步非阻塞的。

基础设施层

基础设施层提供各种公共服务，包括数据库连接池、缓存连接池、消息队列客户端、日志、监控等。这些基础设施都要支持非阻塞IO，才能和Fibers配合使用。

三、调度器设计

调度器是Fibers架构的核心，详细说说设计思路。

调度器的职责

调度器的主要职责：

  1. 管理Fiber的生命周期（创建、运行、暂停、恢复、销毁）
  2. 维护就绪队列和等待队列
  3. 处理IO事件，唤醒等待的Fiber
  4. 处理定时器（延时任务、超时控制）
  5. 处理异常和错误

就绪队列

就绪队列存放所有可以运行的Fiber。调度器从队列头部取出Fiber运行，Fiber运行到suspend点或者结束后，再处理下一个。

就绪队列可以用普通的队列实现（FIFO），也可以用优先队列实现（按优先级调度）。对于一般的Web服务，FIFO就够了。

等待队列

等待队列存放正在等待IO或者定时器的Fiber。每个等待的Fiber关联一个或多个事件（socket可读、socket可写、定时器到期等）。当事件发生时，调度器把对应的Fiber从等待队列移到就绪队列。

等待队列的实现要高效，因为事件发生时需要快速找到对应的Fiber。可以用socket资源或者定时器ID作为key，用哈希表来存储。

事件循环

事件循环是调度器的引擎。它用stream_select或者epoll来监听所有的socket和定时器，当有事件发生时，调用对应的回调函数。

在PHP中，可以用stream_select来实现事件循环，虽然效率不如epoll，但是跨平台、不需要扩展。如果追求更高的性能，可以用ev扩展或者libevent扩展。

事件循环的基本流程：

  1. 计算最近的定时器到期时间
  2. 调用stream_select等待IO事件，超时时间设为最近的定时器时间
  3. 处理就绪的IO事件，唤醒对应的Fiber
  4. 处理到期的定时器，唤醒对应的Fiber
  5. 运行就绪队列中的Fiber
  6. 重复以上步骤

四、IO多路复用

Fibers的高性能离不开IO多路复用。

非阻塞IO

所有的socket都要设置为非阻塞模式。这样在读写的时候，如果数据还没准备好，函数会立即返回而不是阻塞。然后Fiber调用suspend()让出控制权，等数据准备好之后再恢复。

比如读取数据的流程：

  1. Fiber调用fread读取数据
  2. 如果数据已经在缓冲区，直接返回
  3. 如果数据还没到，fread返回EAGAIN
  4. Fiber把自己注册到事件循环的可读事件中，然后suspend()
  5. 当socket可读时，事件循环唤醒Fiber
  6. Fiber再次调用fread，这时候数据已经准备好了

连接池

数据库和缓存的连接是有限的资源，需要用连接池来管理。连接池维护一定数量的长连接，Fiber需要连接时从池中获取，用完后归还。

连接池的设计要点：

  • 池的大小要合理，太小会导致等待，太大会浪费资源
  • 获取连接时如果池为空，Fiber要suspend等待，等有连接归还时再唤醒
  • 连接要做健康检查，坏的连接要销毁并重建
  • 要有超时机制，防止Fiber无限等待连接

异步客户端

数据库客户端、Redis客户端等都要支持非阻塞IO。PHP的很多扩展不支持非阻塞，所以需要自己实现或者用第三方的异步客户端库。

比如MySQL，可以用mysqli的poll方法来实现非阻塞查询。Redis可以用phpredis的异步模式，或者自己实现Redis协议的异步客户端。

五、错误处理和容错

高可用系统必须有完善的错误处理和容错机制。

Fiber异常捕获

每个Fiber运行时都要用try-catch包裹，捕获所有异常。如果异常没有被捕获，会导致整个进程崩溃。

异常处理的策略：

  • 业务异常：返回错误响应给客户端
  • 系统异常：记录日志，尝试恢复或者优雅退出
  • 致命错误：记录日志，通知运维，进程退出后由守护进程重启

超时控制

每个请求都要有超时控制，防止某个Fiber卡住不退出，占用资源。

超时控制的实现：

  • 请求开始时设置一个定时器
  • 如果请求在超时时间内完成，取消定时器
  • 如果超时了，定时器唤醒Fiber，Fiber抛出超时异常
  • Fiber捕获异常后清理资源，返回超时响应

限流和熔断

高并发系统必须有限流和熔断机制，防止系统被打垮。

限流：限制单位时间内的请求数，超过限制的请求直接拒绝或者排队。可以用令牌桶算法实现，每个请求消耗一个令牌，没有令牌就拒绝。

熔断：当某个依赖的服务（比如数据库）出现故障时，快速失败，不再调用故障服务，等一段时间后再尝试恢复。熔断可以防止故障蔓延，保护系统的稳定性。

优雅退出

系统需要支持优雅退出，收到退出信号后，停止接收新请求，等待正在处理的请求完成，然后退出进程。

优雅退出的流程：

  1. 收到SIGTERM信号
  2. 停止监听新连接
  3. 等待所有Fiber处理完成（或者超时后强制退出）
  4. 关闭连接池，释放资源
  5. 进程退出

六、资源管理

高并发系统的资源管理很重要，资源泄漏会导致系统逐渐崩溃。

内存管理

每个Fiber都有自己的栈空间，虽然单个Fiber的内存很小，但是上万个Fiber加起来也不少。要注意：

  • Fiber结束后要及时销毁，释放内存
  • 不要在Fiber中保存大的对象或者数据
  • 定期检查内存使用情况，发现泄漏及时修复

连接管理

数据库连接、Redis连接、HTTP连接等都是有限的资源，要确保：

  • 连接用完后及时归还到连接池
  • 异常情况下也要释放连接（用try-finally）
  • 定期检查连接的健康状态
  • 设置连接的最大空闲时间，超时自动关闭

文件描述符

每个socket连接都占用一个文件描述符，操作系统的文件描述符是有限的。要注意：

  • 调整系统的文件描述符限制（ulimit -n）
  • 连接关闭后要及时释放文件描述符
  • 监控文件描述符的使用情况

七、监控和告警

高可用系统必须有完善的监控和告警。

监控指标

需要监控的指标包括：

  • 系统指标：CPU、内存、文件描述符使用量
  • 业务指标：QPS、响应时间、错误率
  • Fiber指标：活跃Fiber数、等待Fiber数、Fiber创建和销毁速率
  • 连接池指标：连接池使用率、等待连接数、获取连接耗时
  • 事件循环指标：事件循环延迟、IO事件处理时间

告警

设置告警阈值，当指标异常时及时通知运维人员。比如：

  • 错误率超过1%告警
  • 响应时间超过1秒告警
  • 内存使用率超过80%告警
  • 连接池使用率超过90%告警
  • 事件循环延迟超过100ms告警

日志

完善的日志系统是排查问题的关键。要记录：

  • 请求日志：每个请求的参数、响应、耗时
  • 错误日志：异常和错误的详细信息
  • 慢查询日志：耗时超过阈值的请求
  • 系统日志：进程启动、退出、重启等事件

八、性能优化

基于Fibers的系统，还有一些性能优化的点。

减少Fiber切换

Fiber切换虽然轻量，但是也有开销。要尽量减少不必要的切换，比如：

  • 批量处理IO操作，减少suspend的次数
  • 数据已经在缓冲区时直接读取，不suspend
  • 合并多个小请求为一个大请求

优化事件循环

事件循环是性能的关键。要：

  • 用高效的事件循环（epoll比select快）
  • 减少事件循环的迭代次数
  • 批量处理就绪事件

连接池调优

连接池的大小要根据实际情况调优。太小会导致Fiber等待连接，太大会浪费资源而且可能压垮数据库。可以通过监控连接池的等待时间来调整大小。

缓存优化

合理使用缓存可以大大减少数据库的压力。用Redis做缓存，热点数据直接从缓存读取，不需要查数据库。缓存要设置合理的过期时间，还要有缓存穿透和缓存雪崩的防护。

九、和其他方案的对比

Fibers不是唯一的高并发方案，简单对比一下。

vs 多进程（PHP-FPM）

多进程的优点是稳定、隔离性好、调试简单。缺点是并发数有限、内存占用大、进程间通信复杂。

Fibers的优点是并发数高、内存占用小、单机可以处理更多连接。缺点是一个Fiber崩溃可能影响整个进程、调试更复杂、需要非阻塞的基础设施。

vs Swoole

Swoole是PHP的异步扩展，提供了协程、异步IO、连接池等功能。Swoole的性能很好，生态也比较成熟。

Fibers是PHP官方的特性，不需要安装扩展，兼容性更好。但是Fibers只提供了基础的纤程原语，调度器、连接池等都需要自己实现。Swoole则提供了一整套的解决方案。

如果项目已经在用Swoole，继续用Swoole就好。如果不想装扩展，或者想要更底层的控制，可以考虑Fibers。

vs Go协程

Go的协程（goroutine）是语言级别的支持，调度器由runtime管理，用户不需要关心。Go的协程性能很好，而且有丰富的标准库。

Fibers需要自己实现调度器和基础设施，工作量比Go大很多。但是如果团队主要用PHP，Fibers是一个不错的选择。

十、适用场景和不适用场景

适用场景

Fibers适合以下场景：

  1. IO密集型的Web服务，比如API网关、代理服务器
  2. 高并发的聊天服务器、推送服务器
  3. 爬虫和数据采集系统
  4. 微服务之间的通信
  5. 需要大量并发连接的场景

不适用场景

Fibers不适合以下场景：

  1. CPU密集型任务，因为协作式调度会被长时间计算阻塞
  2. 需要强隔离的场景，因为一个Fiber崩溃可能影响整个进程
  3. 团队没有异步编程经验，学习成本较高
  4. 依赖大量阻塞扩展的项目，改造工作量大

十一、写在最后

Fibers为PHP的并发编程带来了新的可能。基于Fibers可以构建高可用高并发的系统，但是需要在调度器、IO多路复用、错误处理、资源管理、监控等方面做很多工作。

本文介绍的架构设计和经验，是我在实际项目中总结出来的。当然，每个项目的情况不一样，具体的架构还要根据业务需求来调整。

如果你在做高并发的PHP系统，可以考虑尝试一下Fibers。它可能不会让你的系统立刻变得多快，但是会让你对并发编程有更深的理解。

最后用一句话结束本文："并发编程没有银弹，只有根据业务场景选择合适的方案，并且在实践中不断优化。"愿每一个系统都能稳定高效地运行。