Swoole4 自定义协议，swoole 接收数据自定义协议解析分包写法-php教程-PHP中文网

swoole 4 处理 tcp 自定义协议需解决粘包和半包问题，内置 eof 标记协议（如\r\n结尾）和固定包头+包体协议（如32位大端长度字段）两种分包机制，配置后 onreceive 即收完整包。

swoole4 自定义协议，swoole 接收数据自定义协议解析分包写法

Swoole 4 中处理 TCP 自定义协议，核心是解决 TCP 流式传输带来的“粘包”和“半包”问题。Swoole 底层已内置两种主流分包机制：EOF 标记协议和固定包头+包体协议。你不需要手动缓存、拼接、切分原始字节流，只需正确配置并按规范发送数据，onReceive 回调中收到的就是一个完整、独立的业务数据包。

EOF 标记协议（适合文本类、分隔明确的场景）

适用于消息以固定字符串结尾（如 \r\n、###、|END|），且该标记不会出现在正常业务数据中。

服务端配置需启用 open_eof_check 并指定 package_eof
客户端每次发送的数据末尾必须严格带上这个 EOF 字符串
Swoole 只检查每次接收缓冲区的末尾是否匹配 EOF，不扫描中间内容，性能高但要求数据干净

示例配置：

$server->set([
    'open_eof_check' => true,
    'package_eof'    => "\r\n",
    'package_max_length' => 1024 * 1024 // 防止超长恶意包
]);

客户端发送必须为："Hello world\r\n"，不能漏掉 \r\n，否则服务端一直等不到结束符，数据会滞留在缓存区直到超时或下一次带 EOF 的包到达。

固定包头 + 包体协议（推荐用于生产环境）

更通用、更健壮，不受业务数据内容限制。典型结构：前 N 字节为包总长度（或包体长度），后接实际数据。

Swoole 6.1.1

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

下载

启用 open_length_check
用 package_length_offset 指定长度字段在包头中的起始位置（字节偏移）
用 package_body_offset 指定包体从第几个字节开始（常与长度字段是否包含包头有关）
用 package_length_type 声明长度字段类型，如 N（32位大端无符号整数）、V（32位小端）等

常见 4 字节包头（仅含长度）配置：

$server->set([
    'open_length_check'     => true,
    'package_length_type'   => 'N', // 4 字节网络字节序 uint32
    'package_length_offset' => 0,   // 长度字段从第 0 字节开始
    'package_body_offset'   => 4,   // 包体从第 4 字节开始（即跳过包头）
    'package_max_length'    => 5 * 1024 * 1024
]);

客户端发送时，先打包长度，再发数据：

$data = json_encode(['cmd' => 'login', 'uid' => 1001]);
$len  = strlen($data);
$packet = pack('N', $len) . $data; // N 表示 4 字节大端
$client->send($packet);

自定义协议解析（当内置协议不满足需求时）

如果协议更复杂（例如含魔数、版本号、校验和、多级嵌套头），可关闭 Swoole 自动分包，自行实现解析逻辑。

设置 open_length_check => false 和 open_eof_check => false
在 onReceive 中接收原始 $data，追加到连接专属缓存（如 $server->connections[$fd]['buffer'] ??= ''）
循环检查缓存中是否有完整包：先读包头 → 解出长度 → 判断缓存是否足够 → 截取完整包 → 剩余部分留作下次解析
务必设好 package_max_length 和超时清理机制，防止内存泄漏或 DoS 攻击

关键点：每个连接需独立维护 buffer；解析过程要支持多次调用（因可能一次收不全）；避免使用 substr 或 unpack 错误偏移导致崩溃。