【高级进阶】Swoole自定义协议分包面试解法-Swoole-PHP中文网

swoole_http_server不能处理自定义二进制协议，因其内置http解析器会在收包时立即按http格式解析，非http数据直接报错断连；真正可接管原始字节流的是swoole\server或swoole\coroutine\server。

【高级进阶】swoole自定义协议分包面试解法

为什么 `swoole_http_server` 不能直接处理自定义二进制协议

因为 swoole_http_server 内置了完整的 HTTP 解析器，它会在收到数据第一刻就尝试按 HTTP 格式解析——如果发的是纯二进制包（比如以 0x12 0x34 开头的包），它会立刻报 http parse error 或直接断连。这不是配置问题，是架构层面的拦截。

真正能接管原始字节流的，只有 swoole_server（即 Swoole\Server）或其子类 Swoole\Coroutine\Server。它们暴露 onReceive 回调，让你自己决定怎么读、怎么切、怎么识别包边界。

别在 swoole_http_server 上硬套 open_length_check —— 它只对 TCP 模式生效，HTTP 模式下该配置被忽略
swoole_websocket_server 同样不行：它内部已按 WebSocket 帧格式解帧，你收不到原始 TCP 流
若必须用 HTTP 端口承载自定义协议（例如兼容老网关），得退到 Swoole\Server + 手动识别协议头（如前 2 字节为 0xFE 0xFF 则走自定义逻辑）

`open_length_check` 的真实行为和三个关键陷阱

这个选项不是“自动分包”，而是“按长度字段截出一整包”。它依赖你在协议头里预留固定位置存包体长度，Swoole 只负责读够字节数后触发 onReceive。但它不校验、不解析、不重试——包粘连或错位时它照常吐数据。

典型配置：

$server->set([
    'open_length_check' => true,
    'package_length_type' => 'N', // 无符号 32 位大端
    'package_length_offset' => 0, // 长度字段从包首偏移 0 字节
    'package_body_offset' => 4,    // 包体从第 4 字节开始
    'package_max_length' => 2 * 1024 * 1024,
]);

package_length_type 必须和你的序列化一致：PHP pack('N') 对应 'N'，pack('V') 对应 'V'；用错会导致长度读成 0 或超大值
package_length_offset 和 package_body_offset 不是“头部长度”，而是绝对偏移量；如果你协议是「2 字节魔数 + 4 字节长度 + N 字节内容」，那 length_offset 应是 2，body_offset 是 6
当客户端发包慢于 Swoole 读取节奏（如网络抖动），可能出现 onReceive 收到半包——此时 strlen($data) 会小于你解析出的长度，必须手动缓存并等待下一次数据

手写分包逻辑时，`onReceive` 中必须检查的三件事

启用 open_length_check 只解决“长度提取”，不解决“粘包合并”和“跨包截断”。只要协议有魔数、版本、校验等字段，就得在 onReceive 里自己处理。

Swoole 6.1.1

Swoole 6.1.1 是一个专为 PHP 设计的高性能事件驱动并发网络引擎。作为稳定版，它修复了编译时对 zlib 依赖的缺失及 curl 模块的内存安全风险。该版本支持协程、多线程与多进程架构，内置 TCP/HTTP/WebSocket 服务器，能够显著提升 PHP 在微服务、实时通信等场景下的执行效率与并发能力。

下载

先检查 strlen($data) ：如果连协议头都没收全，直接 <code>return 并把数据暂存到连接上下文（$server->connection_info($fd) 不可靠，建议用 [$fd => ''] 数组维护）
再解析长度字段，确认 $bodyLen = unpack('N', substr($data, $offset, 4))[1] 是否合法（比如是否 > 0 且 ≤ package_max_length）
最后判断 strlen($data) >= $headerLen + $bodyLen：不够就缓存；够了就切出完整包，剩余字节（可能含下一个包头）要追加进缓存，不能丢

示例片段（非完整）：

// $this->recvBuffer[$fd] 是字符串缓存
$this->recvBuffer[$fd] .= $data;
$raw = $this->recvBuffer[$fd];
while (strlen($raw) >= 6) { // 至少够读魔数(2)+长度(4)
    if (substr($raw, 0, 2) !== "\xAA\xBB") break;
    $len = unpack('N', substr($raw, 2, 4))[1];
    if ($len  2097152) break;
    if (strlen($raw) handlePacket($packet);
}
$this->recvBuffer[$fd] = $raw;