Workerman 4.0.0可快速搭建常驻内存、支持上万并发的TCP服务器:先用composer创建项目,再通过autoload加载、实例化Worker绑定tcp://端口、设count并调用runAll()启动;需手动实现client_id映射、异步安全send、进程级定时器等关键逻辑。

快速搭建一个能处理上万并发连接的TCP服务器,无需依赖Nginx或PHP-FPM,直接用PHP原生代码监听端口并实时响应客户端——Workerman 4.0.0让这件事变成几行代码就能落地的现实,而不是停留在理论或配置文件里的抽象概念。
初始化一个常驻内存的TCP服务
第一步:创建项目目录并安装Workerman 4.0.0
执行composer create-project workerman/workerman:4.0.0,这会拉取稳定版源码并自动构建vendor/autoload.php。
第二步:新建start.php,写入基础服务骨架
必须使用require_once __DIR__.'/vendor/autoload.php';加载自动加载器,否则Worker类无法识别——这是Workerman 4.0.0与旧版最明显的入口差异。
第三步:实例化Worker并绑定端口
【$worker = new Worker('tcp://0.0.0.0:1234');】这一行必须写在autoload之后、runAll之前,且协议前缀必须是tcp://、http://或websocket://之一,其他如tcp://localhost:1234会导致监听失败。
第四步:设置进程数并启动
$worker->count = 4; → Worker::runAll(); 这两行不能颠倒顺序,runAll()必须是最后调用,否则进程数设置无效。
让连接具备业务身份:绑定自定义client_id
Workerman默认分配的connection->id随断连重连变化,无法用于业务识别。要实现精准推送,必须让客户端主动上报唯一标识。
方法一:客户端首次发包携带JSON格式{“type”: “bind”, “client_id”: “U1001”}
服务端onMessage回调中解析该结构,成功后执行self::$client_map[$client_id] = $connection;建立映射。
方法二:利用HTTP升级WebSocket时从URL参数提取token
若使用websocket://0.0.0.0:8686,客户端连接地址为ws://your-domain.com?token=abc123,服务端可通过$connection->getRemoteIp()配合解析query string获取初始ID。
注意:映射数组【必须声明为static public】,否则跨Worker进程无法共享;非GatewayWorker架构下不支持全局client_map,需自行用Redis持久化。
异步发送消息而不阻塞主线程
第一步:确认连接状态
调用$connection->send()前先判断if ($connection->isConnected()),否则可能触发PHP Warning并中断当前回调。
第二步:批量推送时避免逐个send
对100个在线用户循环调用send()会串行阻塞,正确做法是把消息内容缓存进数组,再用foreach ($connections as $conn) { $conn->send($msg); }一次性发出——Workerman内部已做缓冲优化,无需额外sleep。
第三步:超大消息分片发送
单次send超过2MB可能触发底层socket缓冲区溢出,应主动拆分为≤512KB的chunk,每片间隔usleep(1000)(1毫秒),防止瞬时带宽打满。
定时任务精准触发的两种写法
方法一:全局定时器(适用于心跳检测等低频任务)
在onWorkerStart回调里写Timer::add(30, function() { echo "ping\n"; });,这个定时器由当前Worker进程独立维护,不跨进程同步。
方法二:单例模式控制唯一执行体
定义static $timer_id = null; → if (!$timer_id) { $timer_id = Timer::add(1, ...); },防止多进程重复创建相同定时器导致日志刷屏。
方法三:使用workerman/crontab组件(仅限Webman生态)
1、执行composer require workerman/crontab
2、在config/crontab.php中注册任务类路径
3、任务类的execute()方法内禁止调用exit/die,否则整个Worker进程崩溃。

















