swoole支持固定包头+包体和以EOF为结尾的两种分包。
具体代码实现可以参考ti-rpc,这个代码片段。
public static function encode(array $data, $type = "tcp")
{
if ('tcp' == $type) {
if ('eof' == self::$tcpPack) {
$data = json_encode($data) . '\r\n';
} else if ('length' == self::$tcpPack) {
$data = json_encode($data);
$data = pack('N', strlen($data)) . $data;
}
return $data;
} else {
return json_encode($data);
}
}
/*
* @desc : 配置packet的拆包方式
*/
public static function decode($jsonString, $type = "tcp")
{
if ('tcp' == $type) {
if ('eof' == self::$tcpPack) {
$jsonString = str_replace('\r\n', '', $jsonString);
} else if ('length' == self::$tcpPack) {
$header = substr($jsonString, 0, 4);
$len = unpack('Nlen', $header);
$len = $len['len'];
$jsonString = substr($jsonString, 4, $len);
}
return json_decode($jsonString, true);
} else {
return json_decode($jsonString, true);
}
}
https://wiki.swoole.com/wiki/...
以EOF分包,有两种情况,一种是以末尾的EOF进行分包,一种是以数据中出现的EOF进行分包,后者效率比较低。
然后就是包头定长+包体这种了。
首先要知道网络字节序,以及本地字节序,说白了就是多字节在传输中的先后顺序
https://www.v2ex.com/t/330173
大端 :数据的高字节放在内存的低地址上,小端反之。
php中常用的函数就是pack()和unpack()两个函数。
上边代码就是先获取数据长度,然后用4字节的整型格式写入二进制字符串中。
最后解包,然后根据长度截取数据。
在swoole中也有相关的配置,如一楼给你的链接