workerman通过事件循环机制实现事件驱动，利用i/o多路复用技术监听socket事件，触发预设回调函数处理连接、消息等，采用非阻塞模式使单进程能高效管理大量并发连接，相比传统php的阻塞式请求响应模型，显著提升性能与资源利用率。
Workerman实现事件驱动的核心在于其内置的事件循环（Event Loop）机制。说白了，它就像一个永不停歇的“监听器”，不断地盯着网络连接有没有新动静——比如有新用户连进来了，或者某个连接上有数据可以读写了。一旦有这些事件发生，它就会迅速把对应的任务分发给预先注册好的回调函数去处理，而不是傻傻地等待。这种非阻塞的处理方式，正是Workerman能够实现高并发、高性能的关键。
解决方案
Workerman的事件驱动模型，在我看来，是一种非常优雅的设计。它将传统的阻塞式I/O操作转化为非阻塞模式，让PHP应用能够像Node.js或Go那样，在一个进程中同时处理成千上万个并发连接。
具体来说，当Workerman启动时，会创建一个或多个Worker进程。每个Worker进程内部都运行着一个独立的事件循环。这个事件循环会持续地做几件事：
-
监听I/O事件： 它会利用底层的I/O多路复用技术（如
select
,poll
,epoll
,kqueue
等，Workerman会根据系统环境和扩展安装情况自动选择最优的方案）来监听所有已注册的socket文件描述符（FD）上的读写事件。 - 事件触发与收集： 一旦某个FD上有事件就绪（比如客户端发送了数据，或者连接断开了），事件循环会检测到这个变化。
-
回调函数分发： Workerman预先为不同的事件类型（如
onConnect
、onMessage
、onClose
、onError
等）注册了回调函数。当事件发生时，事件循环会调用对应的回调函数，并将相关的连接信息和数据传递进去。 - 非阻塞执行： 回调函数执行时，通常不会进行阻塞式操作。如果需要进行耗时的操作（如数据库查询、文件I/O），则需要采用异步的方式，或者将其交给其他进程/服务处理，以避免阻塞事件循环，影响其他连接的处理。
这种机制使得单个Worker进程能够以极低的资源消耗，高效地处理大量并发连接。它不像传统PHP那样，每个请求都得重新初始化环境，而是常驻内存，大大提升了性能和响应速度。
Workerman的事件循环与传统PHP运行模式有何本质区别？
这几乎是Workerman最核心的价值所在。传统PHP，尤其是我们最熟悉的FPM模式，本质上是一种“请求-响应”模型。每次HTTP请求进来，FPM都会启动一个PHP-CGI进程（或者复用一个已有的进程），加载PHP脚本，执行，然后输出结果，最后进程通常就释放了。这个过程是短生命周期的，而且是同步阻塞的：一个请求进来，PHP脚本会从头跑到尾，如果中间有数据库查询或者文件读写，整个脚本都会等待，直到操作完成。这意味着，如果你的应用有1000个并发请求，FPM可能就需要启动1000个PHP进程来处理，资源消耗巨大。
Workerman则完全不同。它是一个长生命周期的PHP进程，一旦启动就常驻内存。每个Worker进程内部维护一个事件循环，这个循环是非阻塞的。打个比方，传统PHP像一个饭店，每来一个客人就得新请一个厨师从头开始做菜；Workerman则像一个高效的流水线，一个厨师（Worker进程）可以同时监控多个锅（连接），哪个锅里的菜熟了就去处理一下，然后立马回来监控其他锅。它不会因为一个锅里的菜还没熟就傻等着，而是会去看看其他锅有没有需要处理的。这种模式使得单个Workerman进程能够以非常低的内存占用，同时管理成千上万个并发连接，大大提升了系统的吞吐量和并发能力。这是PHP从一个脚本语言向高性能网络服务框架迈进的关键一步。
Workerman如何选择并利用底层I/O多路复用技术？
Workerman在底层I/O多路复用技术的选择上，是相当智能且灵活的。它会根据当前运行环境和PHP扩展的安装情况，自动选择一个最优的事件驱动库。这个选择顺序通常是这样的：
-
Event
扩展 (libevent/libev/libuv)：如果安装了PHP的Event
扩展，Workerman会优先使用它。Event
扩展是基于libevent
、libev
或libuv
这些高性能C语言库的封装，能够提供非常高效的I/O多路复用能力，尤其在处理大量并发连接时表现出色。 -
libevent
扩展：如果Event
扩展不可用，但安装了旧版libevent
扩展，Workerman会退而求其次使用它。虽然不如Event
扩展功能全面，但在I/O多路复用方面依然比纯PHP实现要高效得多。 -
纯PHP
select
轮询：如果以上两个扩展都没有安装，Workerman就会退化到使用纯PHP实现的select
系统调用。select
是POSIX标准的一部分，兼容性最好，几乎所有类Unix系统都支持。但它的缺点也很明显：文件描述符数量有限制（通常是1024），并且在文件描述符数量增多时，其性能会随着FD数量线性下降（O(N)复杂度）。
对于我们开发者来说，通常无需关心这些底层细节，Workerman会自动搞定。但如果你的应用需要处理极高的并发量，比如数万甚至数十万的连接，那么确保安装
Event扩展（特别是底层使用
epoll或
kqueue的实现）就显得尤为重要。因为
epoll（Linux）和
kqueue（FreeBSD/macOS）这类技术，在处理大量文件描述符时，性能是O(1)的，远超
select和
poll的O(N)。
你可以通过
Workerman\Worker::getEventLoopClass()这样的方式来查看当前Workerman正在使用哪个事件循环类，这在调试或优化时很有用。
在Workerman中，如何注册和管理事件回调函数以实现业务逻辑？
在Workerman中，注册和管理事件回调函数是实现业务逻辑的核心。每个
Worker实例都有一系列属性，你可以将PHP函数或匿名函数赋值给这些属性，作为特定事件发生时的处理器。
这里有一些最常用的回调函数：
-
$worker->onWorkerStart = function($worker)
: 当Worker进程启动时触发。这个回调非常适合做一些进程级别的初始化工作，比如连接数据库、加载配置文件、设置定时器等。 -
$worker->onConnect = function($connection)
: 当有新的客户端连接到Worker时触发。你可以在这里进行一些连接建立后的初始化，比如记录连接信息、发送欢迎消息。 -
$worker->onMessage = function($connection, $data)
: 当客户端发送数据过来时触发。这是处理大部分业务逻辑的地方。$data
就是客户端发送过来的实际数据。 -
$worker->onClose = function($connection)
: 当客户端连接断开时触发。通常用于清理资源，比如从在线用户列表中移除该连接。 -
$worker->onError = function($connection, $code, $msg)
: 当连接发生错误时触发。可以用于错误日志记录。 -
$worker->onBufferFull = function($connection)
: 当发送缓冲区满时触发。这通常意味着客户端接收数据太慢，或者网络拥堵。 -
$worker->onBufferDrain = function($connection)
: 当发送缓冲区数据发送完毕，变为空闲时触发。
举个简单的例子：
<?php
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';
// 创建一个Worker，监听9000端口
$text_worker = new Worker("text://0.0.0.0:9000");
// 设置Worker进程数量
$text_worker->count = 4;
// Worker进程启动时
$text_worker->onWorkerStart = function($worker) {
echo "Worker进程 {$worker->id} 启动了，准备处理连接。\n";
// 假设这里可以初始化一个数据库连接池，但要确保是非阻塞的
// 或者只做一些简单的全局配置加载
};
// 客户端连接时
$text_worker->onConnect = function($connection) {
echo "有新客户端连接进来了，ID: {$connection->id}\n";
$connection->send("你好，欢迎连接到Workerman服务！\n");
};
// 客户端发来消息时
$text_worker->onMessage = function($connection, $data) {
echo "收到来自客户端 {$connection->id} 的消息: {$data}\n";
// 业务逻辑处理：这里可以解析消息，进行数据库操作，或者与其他服务交互
// 注意：如果这里有阻塞操作，会影响当前Worker进程处理其他连接！
// 假设我们只是简单地回复
$connection->send("你发来的是: " . $data);
};
// 客户端断开连接时
$text_worker->onClose = function($connection) {
echo "客户端 {$connection->id} 断开了连接。\n";
};
// 运行所有Worker
Worker::runAll();管理和注意事项：
最重要的一点是，永远不要在这些回调函数中执行阻塞操作。一个
sleep(5)或者一个长时间的同步数据库查询，都会导致整个Worker进程在这段时间内无法处理其他任何连接和事件，直接让你的高并发服务变成单线程阻塞。
如果确实需要执行耗时操作，你有几种选择：
-
异步库： 使用Workerman提供的异步客户端，例如
AsyncTcpConnection
、AsyncMysql
等，它们本身就是非阻塞的。 -
多进程/多服务： 将耗时任务投递到另一个专门处理任务的进程（比如通过
Channel
组件或消息队列如Redis、RabbitMQ），或者一个独立的微服务去处理，然后通过异步回调或轮询获取结果。 -
定时器： 对于一些周期性任务，可以使用
Timer
类来注册定时器，它也是非阻塞的。
理解这些回调的生命周期和执行环境，是编写高效、稳定的Workerman应用的关键。它让我们可以细粒度地控制网络应用的每一个环节，从而构建出响应迅速、资源友好的服务。
