Swoole怎么实现一个自定义的TCP协议

36次阅读

使用Swoole实现自定义TCP协议需解决粘包问题,可通过EOF分隔或固定包头+包体格式。1. EOF方式在消息末尾添加特殊字符如n,配置open_eof_split和package_eof即可;2. 推荐使用带长度字段的二进制协议,设置open_length_check、package_length_type等参数,使Swoole自动解析;3. 对复杂协议可结合长度检测并手动提取命令码、版本、校验和等字段,在receive回调中完成校验与业务处理。核心是利用Swoole的协议解析能力正确切分消息边界。

Swoole怎么实现一个自定义的TCP协议

要使用 Swoole 实现一个自定义的 TCP 协议,关键在于解决“粘包”问题。TCP 是流式协议,数据可能被拆分或合并传输,因此你需要在应用层定义一种规则来划分消息边界。Swoole 提供了多种方式支持自定义协议解析,最常用的是通过设置 EOF 或使用 固定包头 + 包体 格式。

1. 使用固定分隔符(EOF)实现简单协议

这种方式适合调试或简单场景。你可以在每条消息末尾添加一个特殊字符作为结束标记,比如换行符 n 或自定义字符串 ###

Swoole 服务器配置示例如下:

$server = new SwooleServer("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_typepackage_body_offset 等参数。

假设你的协议格式如下:

  • 前 4 字节:包体长度(int,大端)
  • 后续数据:实际内容

服务端配置:

Swoole怎么实现一个自定义的TCP协议

通义万相

通义万相,一个不断进化的ai艺术创作大模型

Swoole怎么实现一个自定义的TCP协议596

查看详情 Swoole怎么实现一个自定义的TCP协议

$server = new SwooleServer("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) . " bytesn";     $server->send($fd, "ok"); });  $server->start();

客户端发送时需先写入长度:

$client = new SwooleClient(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 就能帮你完成粘包处理,剩下的交给业务逻辑即可。

react 字节 swoole swoole EOF 字符串 int

text=ZqhQzanResources