必须采用webman/gateway-worker三进程解耦架构,分离gateway(连接管理与心跳)、business(异步业务处理)和register(节点注册),并配nginx透传upgrade头、合理设置pinginterval与header分流,才能真正支撑万级websocket并发。

要让Workerman真正撑起万级并发的WebSocket服务,不能只靠几行代码启动一个Worker——单进程广播会卡死、连接数破千就丢消息、业务逻辑混在onMessage里一查数据库整个进程就阻塞。必须拆解架构、分离职责、配对心跳、透传协议头。
基础WebSocket服务启动(仅测试用)
这一步适合本地验证协议通路,【不可用于生产】:直接运行后所有连接挤在同一个进程,$connection->worker->connections只能遍历本进程连接,其他Worker里的客户端收不到广播。
创建 chat_server.php,写入以下代码:
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;
$ws_worker = new Worker('websocket://0.0.0.0:2346');
$ws_worker->count = 4;
$ws_worker->onConnect = function($connection) { echo "新连接\n"; };
$ws_worker->onMessage = function($connection, $data) use ($ws_worker) { foreach ($ws_worker->connections as $client) { $client->send($data); } };
Worker::runAll();
执行 php chat_server.php 启动服务。
必须启用GatewayWorker三进程解耦架构
真要扛住高并发、支持跨进程广播、实现header分流或协议透传,必须用 webman/gateway-worker 插件——它才是 Workerman 官方 GatewayWorker 架构的 Webman 封装,不是自己手写 onMessage 广播逻辑。
方法一:安装插件并配置三进程
composer require webman/gateway-worker
修改 config/plugin/webman/gateway-worker/process.php,这是关键配置文件,【只改 enable => true 而不配 process.php 等于没装】。
确保 gateway 进程配置 pingInterval 为 25~30 秒,且 pingData 是合法 JSON 字符串(例如 '{"type":"ping"}'),否则某些前端库解析失败导致心跳断连。
business 进程才是真正写业务逻辑的地方,通过 Events::onMessage() 接收 gateway 转发的消息,它不碰 TCP 连接,可放心异步调用 Redis 或发起协程 HTTP 请求。
register 进程必须唯一且常驻,地址格式必须是 text://127.0.0.1:1236,少一个 text:// 前缀就会连不上。
Nginx代理必须透传Upgrade头
线上环境绝不能让客户端直连 gateway-worker 端口(如 7272),必须过 Nginx 做 TLS 终结和负载均衡。
第一步:在 Nginx 配置中添加 WebSocket 支持段落
location /ws/ {
proxy_pass http://backend;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
}
第二步:定义 upstream backend,指向你的 gateway-worker 实例,例如:
upstream backend {
server 127.0.0.1:7272;
}
第三步:重载 Nginx 配置 nginx -s reload。
漏掉 proxy_set_header Upgrade $http_upgrade 这一行,客户端升级请求会被拒绝,返回 400 错误。
连接保活与消息路由分层实现
心跳检测必须由 gateway 进程独立完成,不能放在 business 里做——否则 onMessage 里一加 DB 查询就阻塞整个进程。
第一步:在 gateway 进程配置中启用自动心跳,设置 pingInterval 和 pingData
第二步:在 business 进程的 Events.php 中,只处理业务消息,例如解析 JSON 数据体、校验 token、读取 Redis 用户状态、调用 Laravel 接口
第三步:通过 GatewayClient 发送消息,指定 client_id 或 group,而不是遍历 $worker->connections
第四步:注册中心 register 必须始终在线,所有 gateway 和 business 进程都指向同一 register 地址,否则节点发现失败,新扩容的 business 进程收不到消息
第五步:前端连接时带上 X-Api-Version 或 Authorization 头,gateway 进程根据 header 值将连接路由到不同 business 分组,实现灰度发布或协议版本分流










