# Swoole编程指南-EOF协议
[原文链接](http://www.catplanet.me/?id=12)
[TOC]
## 什么是EOF协议
EOF(End of File)是一个结束标记,意思为在逐个读取数据流中的数据时,如果发现读到EOF标记,就代表已经读到了数据末尾。在TCP的数据流中,使用EOF协议的数据流特征如下:
> | 数据 | EOF | 数据 |EOF|
在每一串正常数据的末尾,添加一个预先规定的、绝对不会出现在数据中的字符串作为结束标记。这样接收到的数据就可以根据这个EOF标记来切分数据。
## 开启EOF支持
在Swoole中,可以使用如下配置选项来开启EOF功能:
```
$server->set([
'open_eof_split' => true, // 开启EOF检测
'package_eof' => '/r/n' , // 设置EOF标记
]);
```
其中,open_eof_split选项会开启Swoole底层对接收到的数据从头开始依次扫描检查,当找到第一个EOF标记时,将已经扫描过的数据作为一个完整的数据包通过onReceive回调发送给PHP层处理。这里需要注意的是,package_eof只允许设置长度不超过8的字符串。
这里要注意到,open_eof_split选项是依次扫描数据中的EOF标记的,这样虽然保证每次回调都只会收到一个完整的数据包,但是性能较差。因此Swoole还提供了另外一个不同的选项:
```
$server->set([
'open_eof_check' => true, // 开启EOF检测
]);
```
open_eof_check同样会开启EOF检测。不同的是,open_eof_check只检查接收数据的末尾是否为EOF标记。相比于open_eof_split,这种方式性能最好,几乎没有损耗。但是如果同时收到了N条带有EOF标记的数据,这种方式会同时将N个数据包合并为一个回调给PHP层处理,因此需要在PHP层通过EOF标记对数据做二次拆分。
## 实战
为了演示效果,我将直接使用open_eof_check选项,并演示如何拆分数据包。 首先是服务器端代码,如下:
```
class Server
{
private $serv;
public function __construct()
{
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 1,
'open_eof_check' => true,
'package_eof' => "\r\n",
));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->start();
}
public function onConnect( $serv, $fd, $from_id )
{
echo "Client {$fd} connect\n";
}
public function onReceive( swoole_server $serv, $fd, $from_id, $data )
{
$data_list = explode("\r\n", $data);
foreach ($data_list as $item)
{
if(empty($item))
continue;
var_dump($item);
$serv->send($fd, $item . "\r\n");
}
}
public function onClose( $serv, $fd, $from_id )
{
echo "Client {$fd} close connection\n";
}
}
new Server();
```
可以看到,在接收到数据后,我先将接收到的数据用EOF标记作为分隔符做了一次拆分,这样就能得到一个个独立的完整数据包,然后依次处理即可。
- SD3.X简介
- 捐赠SD项目
- VIP服务
- 基础篇
- 搭建环境
- 使用Composer安装/更新SD框架
- 启动命令
- 开发注意事项
- 框架配置
- 配置文件夹
- server.php
- ports.php
- business.php
- mysql.php
- redis.php
- timerTask.php
- log.php
- consul.php
- catCache.php
- client.php
- 自定义配置
- 框架入口
- MVC架构
- 加载器-Loader
- 控制器-Controller
- 模型-Model
- 视图-View
- 同步任务-Task
- 封装器
- Swoole编程指南-EOF协议
- Swoole编程指南-固定包头协议
- 封装器-Pack
- 路由器
- TCP相关
- 绑定UID
- Send系列
- Sub/Pub
- 获取服务器信息
- Http相关
- HttpInput
- HttpOutput
- 默认路由规则
- WebSocket相关
- 使用SSL
- 公共函数
- 进阶篇
- 内核优化
- 封装器路由器原理剖析
- 对象池
- 上下文-Context
- 中间件
- 进程管理
- 创建自定义进程
- 进程间RPC
- 自定义进程如何使用连接池
- 异步连接池
- Redis
- Mysql
- Mqtt
- HttpClient
- Client
- AMQP
- RPC
- 日志工具-GrayLog
- 微服务-Consul
- Consul基础
- 搭建Consul服务器
- SD中Consul配置
- 微服务
- 选举-Leader
- Consul动态配置定时任务
- 熔断与降级
- 集群-Cluster
- 高速缓存-CatCache
- 万物-Actor
- Actor原型
- Actor的创建
- Actor间的通讯
- 消息派发-EventDispatcher
- 延迟队列-TimerCallBack
- 协程
- 订阅与发布
- MQTT简易服务器
- AMQP异步任务调度
- 自定义命令-Console
- 调试工具Channel
- 特别注意事项
- 日常问题总结
- 实践案例
- 物联网自定义协议
- Actor在游戏的应用
- Mongodb以及一些同步扩展的使用
- 自定义进程使用MQTT客户端
- 开发者工具
- SDHelper