环境说明： 系统：Ubuntu14.04 （安装教程包括CentOS6.5）
PHP版本：PHP-5.5.10
swoole版本：1.7.8-alpha

1.为什么要提供自定义协议

熟悉TCP通信的朋友都会知道，TCP是一个流式协议。客户端向服务器发送的一段数据，可能并不会被服务器一次就完整的收到;客户端向服务器发送的多段数据，可能服务器一次就收到了全部的数据。而实际应用中，我们希望在服务器端能一次接收一段完整的数据，不多也不少。传统的TCP服务器中，往往需要由程序员维护一个缓存区，先将读到的数据放进缓存区中，然后再通过预先设定好的协议内容，来区分一段完整数据的开头、长度和结尾，并将一段完整的数据交给逻辑部分处理。这就是自定义协议的功能。
而在Swoole中，已经在底层实现了一个数据缓存区，并内置好了几个常用的协议类型，直接在底层做好了数据的拆分，保证了在onReceive回调函数中，一定能收到一个（或数个）完整的数据段。数据缓存区的大小可以通过配置选项package_max_length来控制。下面我就将讲解如何使用这些内置协议。

2.EOF标记型协议

第一个比较常用的协议就是EOF标记协议。协议的内容是通过规定一个一定不会出现在正常数据中的字符或者字符串，用这个来标记一段完整数据的结尾。这样，只要发现这个结尾，就可以认定之前的数据已经结束，可以开始接收一个新的数据段了。
在Swoole中，可以通过open_eof_check和package_eof两个配置项来开启。其中，open_eof_check指定开启了EOF检测，package_eof指定了具体的EOF标记。通过这两个选项，Swoole底层就会自动根据EOF标记来缓存和拆分收到的数据包。示例如下：

$this->serv->set(array(
    'package_max_length' => 8192,
    'open_eof_check'=> true,
    'package_eof' => "\r\n"
));

就这样，swoole就已经开启了EOF标记协议的解析。那么让我们来测试一下效果：
服务器这边：

// Server
public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {    echo "Get Message From Client {$fd}:{$data}\n";
}

客户端这边：

$msg_eof = "This is a Msg\r\n";

$i = 0;
while( $i < 100 ) {    $this->client->send( $msg_eof );
    $i ++;
}

然后运行一下，你会发现：哎不对啊，为什么还是一次收到了好多数据啊！
这是因为，在Swoole中，采用的不是遍历识别的方法，而只是简单的检查每一次接收到的数据的末尾是不是定义好的EOF标记。因此，在开启EOF检测后，onReceive回调中还是可能会一次收到多个数据包。
这要怎么办？你会发现，虽然是多个数据包，但是实际上收到的是N个完整的数据片段，那就只需要根据EOF把每个包再拆出来，一个个处理就好啦。
修改后的服务器端代码如下：

public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {    $data_list = explode("\r\n", $data);
    foreach ($data_list as $msg) {        if( !empty($msg) ) {            echo "Get Message From Client {$fd}:{$msg}\n";
        }

    }
}

再次运行，妥了～
点此查看完整实例
另外，如果担心这样运行多段数据会长时间占用Worker，可以采用把数据+fd转发给Task进程的做法。如何转发请读者自己尝试实现。

============================================我是分割线========================================

下面开始把源代码 转换到 fd+task里 并通知客户端

首先server端代码如下  代码格式没做对齐

<?php
class Server
{private $serv;public function __construct() {$this->serv = new swoole_server("0.0.0.0", 9501);$this->serv->set(array('worker_num' => 8,'daemonize' => false,'max_request' => 10000,'dispatch_mode' => 2,'package_max_length' => 8192,'open_eof_check'=> true,'package_eof' => "\r\n",'task_worker_num'=>8,));$this->serv->on('Start', array($this, 'onStart'));$this->serv->on('Connect', array($this, 'onConnect'));$this->serv->on('Receive', array($this, 'onReceive'));$this->serv->on('Close', array($this, 'onClose'));//自己增加的$this->serv->on('Task', array($this, 'onTask'));$this->serv->on('Finish', array($this, 'onFinish'));$this->serv->start();}public function onStart( $serv ) {echo "Start\n";}public function onConnect( $serv, $fd, $from_id ) {echo "Client {$fd} connect\n";}public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {// echo "Get Message From Client {$fd}:{$data}\n";// // send a task to task worker.$param = array('fd' => $fd,'data'=>$data,);//$data_list = explode("\r\n", $data);//先尝试直接转走 教给task 这里不能打开上面的注释 因为一次性还是会有可能进来很多$serv->task( json_encode( $param ) );echo "Continue Handle Worker\n";}public function onClose( $serv, $fd, $from_id ) {echo "Client {$fd} close connection\n";}public function onTask($serv,$task_id,$from_id, $data) {echo "This Task {$task_id} from Worker {$from_id}\n";$fd = json_decode( $data , true )['fd'];$data_arr = json_decode( $data , true )['data'];$data_list = explode("\r\n", $data_arr);// print("收到的Data: {$data}\n"); 这里还是会一次收到好多个foreach ($data_list as $msg) {if( !empty($msg) ) {echo "Get Message From Client {$fd}:{$msg}\n";}}$serv->send( $fd , "Data in Task {$task_id}");//这里给客户端发个消息吧 告诉他现在做完了echo "send is ok？\n";return "Task {$task_id}'s result";//返回结果onfinsh}public function onFinish($serv,$task_id, $data) {echo "Task {$task_id} finish\n";echo "Result: {$data}\n";}}
new Server();

client 客户端

<?php
class Client
{private $client;public function __construct() {$this->client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);$this->client->on('Connect', array($this, 'onConnect'));$this->client->on('Receive', array($this, 'onReceive'));$this->client->on('Close', array($this, 'onClose'));$this->client->on('Error', array($this, 'onError'));}public function connect() {$fp = $this->client->connect("127.0.0.1", 9501 , 1);if( !$fp ) {echo "Error: {$fp->errMsg}[{$fp->errCode}]\n";return;}}public function onReceive( $cli, $data ) {echo "Get Message From Server: {$data}\n";}public function onConnect( $cli) {$msg_eof = "This is a Msg\r\n";//      $msg_length = pack("N" , strlen($msg_normal) ). $msg_normal;//  $msg_length = pack("N" , strlen($msg_eof) ). $msg_eof;$i = 0;while(1){if( $i < 100 ) { //有可能会分几次发 因为一次可能处理不完//            $this->client->send( $msg_length );$this->client->send( $msg_eof );$i ++;}else{break; //这里一定加个else 不然的话 无法收到返回信息 会被while(1) 始终阻塞在那里}}}public function onClose( $cli) {echo "Client close connection\n";}public function onError() {}public function send($data) {$this->client->send( $data );}public function isConnected() {return $this->client->isConnected();}
}
$cli = new Client();
$cli->connect();

运行结果如下 server端

下面运行客户端