>[info] TCP粘包问题的处理 1. 特殊字符 * 根据客户端与服务端相互约定的特殊的符号，对接收的数据进行分割处理 2. 固定包头+包体协议（主流） * 通过与在数据传输之后会在tcp的数据包中携带上数据的长度，然后呢服务端就可以根据这个长度，对于数据进行截取 >[info] 特殊字符  1. **使用原生PHP处理** * **服务端代码** ~~~ <?php echo swoole_get_local_ip()['ens33'] . ':9503' . PHP_EOL; // 实例化swoole 服务端 $server = new Swoole\Server("0.0.0.0", 9503); // 连接 $server->on('connect', function ($server, $fd){ echo "connection open: {$fd}\n"; }); // 消息 $server->on('receive', function ($server, $fd, $reactor_id, $data) { // 把字符串打散为数组 var_dump(explode("\r\n" , $data)); echo '接收到数据：' . $fd . "\n"; $server->send($fd, "Swoole:ok"); // $server->close($fd); }); // 关闭 $server->on('close', function ($server, $fd) { echo "connection close: {$fd}\n"; }); // 打开 $server->start(); ~~~ * **客户端代码** ~~~ <?php // 实例化客户端 $client = new Swoole\Client(SWOOLE_SOCK_TCP); // 建立连接 if (!$client->connect('127.0.0.1', 9503, -1)) { exit("connect failed. Error: {$client->errCode}\n"); } // 结尾 $end = "\r\n"; // 循环发送信息 for ($i = 0;$i < 20;$i++) { // 发送 $client->send("hello_world_" . $end); } // 获取服务端数据 echo $client->recv(); // 不断开连接 // while (true){} // 关闭 //$client->close(); ~~~ * **执行效果** 1. 开启服务端监听 * 得到的数据是已经处理好了的  2. 客户端运行  2. **使用swoole 内置函数处理粘包问题** 函数：**open_eof_check** 手册地址：https://wiki.swoole.com/#/server/setting?id=open_eof_check  * **服务端代码** ~~~ <?php echo swoole_get_local_ip()['ens33'] . ':9503' . PHP_EOL; // 实例化swoole 服务端 $server = new Swoole\Server("0.0.0.0", 9503); $server->set([ 'open_eof_check' => true, //打开EOF检测 'package_eof' => "\r\n", //设置EOF ]); // 连接 $server->on('connect', function ($server, $fd){ echo "connection open: {$fd}\n"; }); // 消息 $server->on('receive', function ($server, $fd, $reactor_id, $data) { echo '接收到数据：' . $data . "\n"; $server->send($fd, "Swoole:ok"); // $server->close($fd); }); // 关闭 $server->on('close', function ($server, $fd) { echo "connection close: {$fd}\n"; }); // 打开 $server->start(); ~~~ * **客户端代码** ~~~ <?php // 实例化客户端 $client = new Swoole\Client(SWOOLE_SOCK_TCP); // 建立连接 if (!$client->connect('127.0.0.1', 9503, -1)) { exit("connect failed. Error: {$client->errCode}\n"); } // 结尾 $end = "\r\n"; // 循环发送信息 for ($i = 0;$i < 20;$i++) { // 发送 $client->send("hello_world_" . $end); } // 获取服务端数据 echo $client->recv(); // 不断开连接 // while (true){} // 关闭 //$client->close(); ~~~ * **执行效果** 1. 开启服务端监听  2. 客户端执行  ***** >[info] 固定包头+包体协议 客户端和服务端都需要设置，并且type类型和offset偏移都需要保持一致。  * 函数：**open_length_check** 手册地址：https://wiki.swoole.com/#/server/setting?id=open_length_check  * **客户端代码** ~~~ <?php // 实例化客户端 $client = new Swoole\Client(SWOOLE_SOCK_TCP); // 建立连接 if (!$client->connect('127.0.0.1', 9503, -1)) { exit("connect failed. Error: {$client->errCode}\n"); } // pack() # 将数据打包成一个二进制字符串 // unpack() # 解析二进制字符 // 循环发送信息 for ($i = 0;$i < 10;$i++) { $conText = '123'; // 利用pack 打包长度 $len = pack('n' , strlen($conText)); var_dump($len); // 组包 $sendData = $len . $conText; var_dump($sendData); // 发送 $client->send($sendData); } // 获取服务端数据 echo $client->recv(); // 不断开连接 // while (true){} // 关闭 //$client->close(); ~~~ * **服务端代码** ~~~ <?php echo swoole_get_local_ip()['ens33'] . ':9503' . PHP_EOL; // 实例化swoole 服务端 $server = new Swoole\Server("0.0.0.0", 9503); // 配置 $server->set([ 'open_length_check' => true, 'package_max_length' => 1 * 1024 * 1024, 'package_length_type' => 'n', 'package_length_offset' => 0, 'package_body_offset' => 2, ]); // 连接 $server->on('connect', function ($server, $fd){ echo "connection open: {$fd}\n"; }); // 消息 $server->on('receive', function ($server, $fd, $reactor_id, $data) { /* var_dump($data); // 解包 $fooLen = unpack('n' , substr($data , 0 , 2))[1]; var_dump($fooLen); // 得到真正的数据 $conText = substr($data , 2 , $fooLen); var_dump($conText);*/ echo "接收到数据：" . $data . PHP_EOL; $server->send($fd, "Swoole:ok"); // $server->close($fd); }); // 关闭 $server->on('close', function ($server, $fd) { echo "connection close: {$fd}\n"; }); // 打开 $server->start(); ~~~ * **运行效果** 1. 开启服务端监听  2. 客户端运行