1.什么是 TCP 粘包？
TCP 粘包是指發(fā)送方發(fā)送的若干包數(shù)據(jù) 到 接收方接收時(shí)粘成一包，從接收緩沖區(qū)看痹换，后一包數(shù)據(jù)的頭緊接著前一包數(shù)據(jù)的尾泻帮。
2.TCP 出現(xiàn)粘包的原因肝陪？
發(fā)送方：發(fā)送方需要等緩沖區(qū)滿才發(fā)送出去，造成粘包
接收方：接收方不及時(shí)接收緩沖區(qū)的包刑顺，造成多個(gè)包接收
3.粘包的處理
//-----客戶端處理
$client = new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_SYNC);
$client->connect('127.0.0.1',9800);
//發(fā)送數(shù)據(jù)氯窍，需要做粘包處理
//$client->send('我是客戶端');
//為了處理粘包，我們和服務(wù)端約定一個(gè)分隔符（比如\r\n）
for($i=0;$i<10;$i++){
$client->send("123456\r\n");
}
//接收數(shù)據(jù)
var_dump($client->recv());
//關(guān)閉蹲堂，關(guān)閉不能這么草率狼讨，需要做應(yīng)答
$client->close();
//-----服務(wù)端處理
//接收到客戶端消息
$server->on('receive',function($server, $fd, $from_id, $data){
//echo "接收到客戶端消息:{$fd}".PHP_EOL;
$server->send($fd, "Server: 我是服務(wù)端");
$data = explode("\r\n",$data);
/*foreach($data as $v){
if(!empty($v)){
var_dump($v);
}
}*/
var_dump($data);
});
//處理打印 var_dump($data);
//處理之前看到的數(shù)據(jù)
123456123456123456123456123456123456
//處理之后看到的數(shù)據(jù)
array(11) {
[0]=>
string(6) "123456"
[1]=>
string(6) "123456"
[2]=>
string(6) "123456"
[3]=>
string(6) "123456"
[4]=>
string(6) "123456"
[5]=>
string(6) "123456"
[6]=>
string(6) "123456"
[7]=>
string(6) "123456"
[8]=>
string(6) "123456"
[9]=>
string(6) "123456"
[10]=>
string(0) ""
}
在swoole中怎么處理的呢？
//EOF 結(jié)束協(xié)議
//通過約定結(jié)束符柒竞，來確定包數(shù)據(jù)是否發(fā)送完畢
//開啟open_eof_check=true,并用package_eof來設(shè)置一個(gè)完整數(shù)據(jù)結(jié)尾字符政供，同時(shí)設(shè)置自動(dòng)拆分open_eof_split
$server->set([
'worker_num'=>2,
'open_eof_check'=>true,
'package_eof'=>"\r\n",
'open_eof_split'=>true
]);
注意：
1、要保證業(yè)務(wù)數(shù)據(jù)里不能出現(xiàn)package_eof設(shè)置的字符,否則將導(dǎo)致數(shù)據(jù)錯(cuò)誤了朽基。
2布隔、可以手動(dòng)拆包，去掉open_eof_split,自行 explode("\r\n", $data),然后循環(huán)發(fā)送
