workerman跨服务器通信必须通过gatewayworker框架或redis pub/sub实现,禁用直接连接共享、http调用和mysql轮询等错误方式。

Workerman跨服务器通信必须解决连接实例隔离问题,因为单机Worker的$connections只存本进程连接,A服务器根本拿不到B服务器上用户的$connection对象,直接foreach发消息会报Call to a member function send() on null或静默失败。
用GatewayWorker框架实现跨服务器广播
这是最稳妥、开箱即用的方案,天然支持集群部署,无需自行维护连接映射和心跳状态。
第一步:安装GatewayWorker依赖
在项目根目录执行:composer require workerman/gateway-worker
第二步:启动Register服务(注册中心)
新建start_register.php,内容如下:$register = new \GatewayWorker\Register('text://0.0.0.0:1236');
运行php start_register.php start,该服务必须始终在线且所有Gateway实例都指向它。
第三步:配置Gateway实例并指定lanIp
在start_gateway.php中设置:$gateway->lanIp = '172.21.0.1';
【lanIp必须设成本机内网IP,不能写127.0.0.1或0.0.0.0,否则Register无法识别路由】
同时设置$gateway->registerAddress = '172.21.0.1:1236';指向Register服务地址。
第四步:启动BusinessWorker并调用跨服务器广播
在业务逻辑里使用GatewayClient::sendToAll()发送消息,请求会经Register转发至所有已注册的Gateway进程,再由各Gateway推送给本地连接。
用Redis Pub/Sub实现轻量级跨服务器通信
适合已有Redis、不想引入新框架的场景,但需自行处理连接归属、心跳续期与离线清理。
方法一:发布/订阅基础通信
在onMessage中检测到需广播的消息时:redis()->publish('broadcast_channel', json_encode($msg));
每个Workerman实例启动一个独立的Redis订阅协程,监听broadcast_channel,收到后遍历本地$connections逐一send。
方法二:带连接路由的精准推送
客户端首次连接时,将其$connection->id与所在服务器标识(如hostname)一起存入Redis哈希表:redis()->hSet('conn_server_map', $connection->id, gethostname());
广播前先查目标用户在哪台机器,再只向对应服务器的订阅端口发指令,避免全量遍历。
注意:Redis连接必须使用pconnect保持长连接,否则频繁重连会导致订阅中断;订阅协程需单独启一个Worker进程,不能混在HTTP或Gateway Worker里。
禁止使用的错误方式
直接在多台服务器上启动相同Worker监听同一端口——操作系统会拒绝绑定,或仅有一台能成功监听。
用file_get_contents("http://other-server:2345/api/broadcast")触发远程广播——HTTP请求无上下文,无法获取目标服务器上的$connection实例,返回空响应或500错误。
试图通过共享MySQL记录连接ID再轮询查询——高并发下数据库成瓶颈,且无法实时感知连接断开,导致消息堆积或投递失败。











