workerman onmessage回调中必须用json_decode($data, true)解析json字符串,否则会因类型错误报错;前端需用json.stringify()发送,后端send前须json_encode(),且注意utf-8编码统一。

Workerman onMessage 回调里必须用 json_decode($data, true)
Workerman 的 onMessage 回调收到的 $data 是原始字符串(不是自动解析的对象),直接当数组取字段会报 Warning: Illegal string offset 或 Undefined index。很多 PHP 开发者卡在这一步,以为框架“应该”自动解析。
正确做法是立刻调用 json_decode(),且第二个参数必须传 true:
- 不传
true(即默认false)→ 返回stdClass对象,$data['type']会出错,只能用$data->type - 传
true→ 返回关联数组,才能用下标语法,也更符合 PHP 后端常规处理习惯 - 务必检查返回值是否为
null:若前端没JSON.stringify(),$data可能是"[object Object]",json_decode()会失败并静默返回null
示例:
$ws_worker->onMessage = function ($connection, $data) {
$parsed = json_decode($data, true);
if (!is_array($parsed)) {
$connection->close('invalid JSON');
return;
}
// ✅ 此时可安全访问 $parsed['type'], $parsed['content']
};
前端发 JSON 前漏掉 JSON.stringify(),Workerman 收到的就是 "[object Object]"
这是最常被忽略的跨端配合点:WebSocket 协议本身不认 JSON,只管字节流。前端用原生 WebSocket.send({type: "msg"}) 看似正常,实际发的是 String({}) === "[object Object]",后端 json_decode() 必然失败。
你得在前端主动序列化:
Miller (mlr) 是一个命令行工具,用于查询、整形和重新格式化名称索引数据,如 CSV、TSV、JSON 和 JSON Lines。它将 awk、sed、cut、join 和 sort 的功能整合到一个专为结构化数据处理而构建的单一工具中。
- 发送前必须包裹
try { socket.send(JSON.stringify(payload)); } catch(e) { ... },防undefined、Date、循环引用等导致JSON.stringify()报错 - 推荐统一时间字段用
Date.now()或toISOString(),避免后端strtotime()解析失败 - 金额、ID 类字段建议转字符串(如
{"id": "1234567890123456789"}),PHP int 会丢失精度
Workerman 广播或单推时,$connection->send() 只接受字符串,别直接传数组
Workerman 的 $connection->send() 和浏览器 send() 一样,只接受 string、array(会被自动 json_encode?错!)、resource 等——但 PHP 数组不会自动转 JSON,而是触发类型警告甚至崩溃。
所以后端往外推数据时,也要手动序列化:
- ❌ 错误:
$connection->send(['code' => 0, 'msg' => 'ok']); - ✅ 正确:
$connection->send(json_encode(['code' => 0, 'msg' => 'ok'], JSON_UNESCAPED_UNICODE)); -
JSON_UNESCAPED_UNICODE很关键:避免中文变成\u4f60\u597d,前端JSON.parse()虽能解,但日志难读、调试痛苦 - 如果广播给多人,记得对每个
$connection单独send(),不要拼大字符串再发——连接可能已断,send()失败会抛异常,需try/catch
Workerman 内部通信(如 text worker 推送)也要走 json_decode + json_encode
很多 Workerman 部署会配一个内部 text:// 端口接收业务系统推送(比如数据库变更通知),这个端口收的数据仍是裸字符串,不是 JSON 对象。
例如监听 5678 端口的 text worker:
- 业务系统
file_get_contents("http://127.0.0.1:5678")或socket_write()发的是纯文本,哪怕内容是{"uid":"1001","event":"order_created"},它也只是字符串 - 你必须在
$inner_text_worker->onMessage里显式json_decode($buffer, true),否则直接$buffer['uid']会报错 - 转发给 WebSocket 连接时,同样要
json_encode()再send(),不能把原始$buffer直接塞过去——因为前端期望的是合法 JSON 字符串,不是带换行符的 text 协议包
容易被忽略的一点:内部通信没做 UTF-8 校验,若业务系统发来 GBK 编码的 JSON,json_decode() 会静默失败。上线前务必确认所有环节统一 UTF-8。










