PHP实现WebSocket消息推送 Workerman接收与传输数据实例【源码】-js教程-PHP中文网

onmessage不触发，首要确认websocket握手是否成功及连接是否被代理中断；需检查端口监听状态、浏览器控制台101响应、nginx upgrade头配置，并确保客户端发送格式合法、服务端未被防火墙拦截。

php实现websocket消息推送 workerman接收与传输数据实例【源码】

Workerman 的 onMessage 回调能直接拿到客户端发来的原始数据，但前提是 WebSocket 握手必须成功、连接未被中间件或代理中断。很多“收不到数据”的问题，根本不是代码写错，而是环境没配对。

为什么 `onMessage` 从不触发？

最常见的原因是客户端连的是 ws://，而服务端启动时监听了 websocket://127.0.0.1:8000，但实际运行环境（比如 Docker 或 Nginx 反代）没把请求透传到 Workerman 进程，或者防火墙/SELinux 拦截了端口。

用 netstat -tuln | grep :8000 确认端口确实在监听，且是 LISTEN 状态
浏览器控制台检查 WebSocket 连接是否返回 101 Switching Protocols，不是就说明握手失败
如果用了 Nginx，必须显式配置 upgrade 和 connection 头，否则协议降级为 HTTP，onMessage 永远不会执行
onConnect 被触发但 onMessage 不触发，大概率是客户端发送的数据格式非法（比如发了非 UTF-8 字符串、二进制帧没设 binaryType）

`onMessage` 收到的 `$data` 是什么类型？

Workerman 默认把文本帧转成 PHP string，二进制帧转成 string（内容是原始字节），不是 resource 或对象。别试图用 fgets() 或 stream_get_contents() 去读它——它已经是个完整值了。

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

前端用 socket.send('hello') → $data 是 string(5) "hello"
前端用 socket.binaryType = 'arraybuffer'; socket.send(new ArrayBuffer(4)) → $data 是长度为 4 的 string，需用 unpack('L', $data) 等解析
不要在 onMessage 里做耗时操作（如数据库写入、远程 API 调用），会阻塞整个进程；用 Worker::sendToAll() 或异步任务分发

如何安全地把消息推送给指定客户端？

Workerman 不自动维护用户身份，$connection 对象本身没有 user_id 属性。你得自己绑定标识，常见做法是握手阶段解析 URL 参数或 Cookie。

启动 Worker 时加参数： $ws_worker = new Worker("websocket://0.0.0.0:2000?uid=123"); 不生效——URL 参数在握手请求头里，得在 onConnect 中解析 $connection->getRemoteIp() 和 $connection->context->host 等字段
更可靠的方式：客户端连接时发一个认证帧（如 {"type":"auth","token":"xxx"}），在 onMessage 中识别并存到 $connection->uid = $uid;，后续用 foreach($ws_worker->connections as $conn) { if ($conn->uid === $target_uid) $conn->send($msg); }
注意：$ws_worker->connections 是当前进程内的连接列表，多进程下需用 Redis 或 GatewayWorker 做跨进程广播

本地测试时 `php wsserver.php start` 没反应？

Workerman 只能在 CLI 模式运行，不能通过 Web 服务器（如 Apache/Nginx + PHP-FPM）启动。报错 PHP Warning: pcntl_fork() has been disabled 表示 PHP 禁用了 pcntl 扩展——这是 Workerman 的硬依赖，必须开启。