0

0

Workerman怎么广播消息_循环connections发送数据方法【方法】

看不見的法師

看不見的法師

发布时间:2026-03-12 21:36:58

|

877人浏览过

|

来源于php中文网

原创

Workerman广播最直接做法是遍历$worker->connections并调用每个连接的send()方法;需检查$connection&& !$connection->isClosed() && $connection->isWebSocket()确保安全发送,多进程须用Channel或Redis同步连接状态。

workerman怎么广播消息_循环connections发送数据方法【方法】

Workerman广播消息最直接的做法就是遍历$worker->connections

Workerman本身不内置“广播”方法,但每个Worker实例都维护着一个$connections数组,里面存着当前进程所有活跃的TcpConnection对象。只要遍历它、对每个连接调用send(),就完成了广播。

常见错误现象:$worker->connections是只读属性,不能直接修改;如果在onMessage里误删了某个连接又没及时清理引用,可能导致send()调用失败或静默丢包。

  • 必须确保连接未关闭(可用$connection->isClosed()判断)再调用send()
  • 单进程下可直接用$worker->connections;多进程必须配合Channel组件同步连接状态,否则只能广播到本进程内的连接
  • 广播前建议加if ($connection->isWebSocket())过滤非 WebSocket 连接(如你只跑 WebSocket 服务)

为什么不能直接用foreach($worker->connections as $conn)无脑发?

因为$worker->connections包含所有连接——包括正在握手、尚未完成协议升级的 TCP 连接,也包括已触发onClose但尚未被 Worker 内部清理的“僵尸连接”。直接发会导致Call to a member function send() on nullConnection is closed警告。

实操建议:广播函数里加上安全包裹:

天工大模型
天工大模型

中国首个对标ChatGPT的双千亿级大语言模型

下载
function broadcast($worker, $data) {
    foreach ($worker->connections as $connection) {
        if ($connection && !$connection->isClosed() && $connection->isWebSocket()) {
            $connection->send($data);
        }
    }
}
  • $connection->isWebSocket()能排除掉 raw TCP 或 HTTP 升级前的中间态连接
  • 不检查isClosed()的话,在高并发断连场景下容易触发 warning 甚至 crash
  • 该循环本身是同步阻塞的,10 万连接时单次广播可能耗时数百毫秒,业务敏感场景需考虑分批或异步队列

想按用户 ID 推送?别只靠$connection->uid,得自己建映射表

Workerman 不自动管理用户身份,$connection->uid只是个可写属性,赋值后不会自动去重、不会跨进程共享、也不会在断连时自动清理。很多人以为设了$connection->uid = 123就能靠它精准推送,结果发现重复登录、ID 冲突、推送丢失全来了。

正确做法是:在onMessage首次验证后,把$connection->uid作为键,存进$worker->uidConnections这个自定义数组,并在onClose里主动unset

  • 必须把$worker->count = 1,否则多进程下$worker->uidConnections各自为政,推送会漏人
  • 真实项目要支持横向扩展,就得用 Redis 或 Channel 做 uid → connection 的跨进程映射
  • 别在onClose回调里做耗时操作(比如查 DB),否则会拖慢整个进程的连接回收

广播性能卡在哪?不是send()慢,是缓冲区压爆了

真正让广播变慢甚至失败的,往往不是循环本身,而是某几个连接的发送缓冲区(_sendBuffer)持续积压。一旦某个连接网络卡顿或客户端不收数据,它的_sendBuffer就会涨到$connection->maxSendBufferSize(默认 1MB),触发onBufferFull,后续send()直接返回false,但多数人没监听这个回调,就以为“发出去了”。

  • 务必设置$connection->onBufferFull并记录日志,否则广播失败无声无息
  • 可动态调小$connection->maxSendBufferSize(比如设为 64KB)来更快暴露问题
  • 广播量大时,建议加节流:每轮最多发 50 个连接,usleep(1000)再继续,避免单次循环吃光 CPU
广播这事看着简单,但一上生产环境,连接状态管理、跨进程一致性、缓冲区水位控制,三处最容易被忽略。尤其当连接数破万后,一个没清掉的uidConnections残留,就可能让定时任务反复往已断开的连接发数据,悄无声息地拖垮整个服务。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

254

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

1089

2024.03.01

if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

847

2023.08.22

counta和count的区别
counta和count的区别

Count函数用于计算指定范围内数字的个数,而CountA函数用于计算指定范围内非空单元格的个数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

203

2023.11.20

php中foreach用法
php中foreach用法

本专题整合了php中foreach用法的相关介绍,阅读专题下面的文章了解更多详细教程。

267

2025.12.04

Golang channel原理
Golang channel原理

本专题整合了Golang channel通信相关介绍,阅读专题下面的文章了解更多详细内容。

261

2025.11.14

golang channel相关教程
golang channel相关教程

本专题整合了golang处理channel相关教程,阅读专题下面的文章了解更多详细内容。

351

2025.11.17

function是什么
function是什么

function是函数的意思,是一段具有特定功能的可重复使用的代码块,是程序的基本组成单元之一,可以接受输入参数,执行特定的操作,并返回结果。本专题为大家提供function是什么的相关的文章、下载、课程内容,供大家免费下载体验。

499

2023.08.04

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

76

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号