使用Swoole实现自定义TCP协议需解决粘包问题，可通过EOF分隔或固定包头+包体格式。1. EOF方式在消息末尾添加特殊字符如\n，配置open_eof_split和package_eof即可；2. 推荐使用带长度字段的二进制协议，设置open_length_check、package_length_type等参数，使Swoole自动解析；3. 对复杂协议可结合长度检测并手动提取命令码、版本、校验和等字段，在receive回调中完成校验与业务处理。核心是利用Swoole的协议解析能力正确切分消息边界。
要使用 Swoole 实现一个自定义的 TCP 协议，关键在于解决“粘包”问题。TCP 是流式协议，数据可能被拆分或合并传输，因此你需要在应用层定义一种规则来划分消息边界。Swoole 提供了多种方式支持自定义协议解析，最常用的是通过设置 EOF 或使用 固定包头 + 包体 格式。
1. 使用固定分隔符（EOF）实现简单协议
这种方式适合调试或简单场景。你可以在每条消息末尾添加一个特殊字符作为结束标记，比如换行符 \n 或自定义字符串 ###。
Swoole 服务器配置示例如下：
$server = new Swoole\Server("0.0.0.0", 9501);
$server->set([
'open_eof_split' => true, // 启用 EOF 分割
'package_eof' => "\n", // 定义结束符
]);
$server->on('connect', function ($server, $fd) {
echo "Client: {$fd} connected.\n";
});
$server->on('receive', function ($server, $fd, $reactorId, $data) {
// $data 已经是去掉 \n 的完整消息
echo "Received: {$data}\n";
$server->send($fd, "Server received: {$data}\n");
});
$server->on('close', function ($server, $fd) {
echo "Client: {$fd} closed.\n";
});
$server->start();
客户端发送消息时必须带上 \n 才能被正确解析。
2. 使用固定包头 + 包体协议（推荐）
更通用的方式是定义二进制协议，包含长度字段的包头。Swoole 支持自动解析这种格式，只需正确配置 package_length_type、package_body_offset 等参数。
假设你的协议格式如下：
- 前 4 字节：包体长度（int，大端）
- 后续数据：实际内容
服务端配置：
$server = new Swoole\Server("0.0.0.0", 9502);
$server->set([
'open_length_check' => true, // 开启长度检测
'package_length_type' => 'N', // unsigned int, 4 字节，大端
'package_length_offset' => 0, // 长度字段偏移量
'package_body_offset' => 4, // 包体起始位置
'package_max_length' => 8192, // 最大包长
]);
$server->on('receive', function ($server, $fd, $reactorId, $data) {
// $data 是完整的包体（不含包头）
echo "Received body: " . strlen($data) . " bytes\n";
$server->send($fd, "ok");
});
$server->start();
客户端发送时需先写入长度：
$client = new Swoole\Client(SWOOLE_SOCK_TCP);
$client->connect('127.0.0.1', 9502);
$message = "Hello Swoole Custom Protocol!";
$length = pack('N', strlen($message)); // 打包 4 字节长度
$client->send($length . $message);
3. 自定义复杂协议（如带命令码、校验和）
如果你的协议更复杂，比如：
- 4 字节长度
- 2 字节命令码
- 1 字节版本
- n 字节数据
- 4 字节 CRC 校验
你可以依然使用 open_length_check，但需要自己处理校验逻辑：
$server->set([
'open_length_check' => true,
'package_length_type' => 'N',
'package_length_offset' => 0,
'package_body_offset' => 7, // 跳过 len(4)+cmd(2)+ver(1)
'package_max_length' => 16384,
]);
然后在 receive 回调中手动提取字段并校验：
$server->on('receive', function ($server, $fd, $reactorId, $rawData) {
$len = unpack('N', substr($rawData, 0, 4))[1];
$cmd = unpack('n', substr($rawData, 4, 2))[1];
$ver = ord(substr($rawData, 6, 1));
$body = substr($rawData, 7, -4); // 去掉头尾
$crc = substr($rawData, -4);
if (md5($body) !== $crc) {
$server->close($fd);
return;
}
// 处理业务...
});
小结
实现自定义 TCP 协议的核心是让 Swoole 能正确切分消息。你可以选择：
- 简单文本协议：用 EOF 分隔
- 通用二进制协议：用 包头长度字段 配合 Swoole 的自动解析
- 复杂协议：在基础解析上自行提取字段并校验
只要包头中包含长度信息，Swoole 就能帮你完成粘包处理，剩下的交给业务逻辑即可。
