Swoole怎么实现一个自定义的TCP协议-Swoole-PHP中文网

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

穿越時空

发布： 2025-09-28 11:45:01

原创

946人浏览过

使用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 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，大端）
后续数据：实际内容

服务端配置：

通义万相

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

596

查看详情

$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;
    }

    // 处理业务...
});

登录后复制