provider/core/protocol/BufferedProtocol.php

<?php
/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */
namespace com\fenqile\fsof\provider\core\protocol;


abstract class BufferedProtocol extends BaseProtocol
{
    protected $requests;

   	const STATUS_FINISH = 1; //完成，进入处理流程
    const STATUS_WAIT   = 2; //等待数据
    const STATUS_ERROR  = 3; //错误，丢弃此包
    
    public function onReceive($server, $clientId, $fromId, $data, $reqInfo = null)
    {
    	// 检查buffer
        $ret = $this->checkBuffer($clientId, $data);
        \Logger::getLogger(__CLASS__)->debug("ret = ${ret}");

        switch($ret)
        {
            case self::STATUS_ERROR:
            	unset($this->requests[$clientId]);
                return true;           // 错误的请求
            case self::STATUS_WAIT:
                return true;          //数据不完整，继续等待
            default:
                break;                 // 完整数据
        }

        $request = $this->requests[$clientId];
		if (!empty($reqInfo))
		{
			$request->reqInfo = $reqInfo;
		}
        $this->server->setRequest($request);
        $this->onOneRequest($clientId, $request);
        unset($this->requests[$clientId]);
    }

    abstract public function checkBuffer($client_id, $data);

    abstract public function onOneRequest($client_id, $request);
    
    public function onClose($server, $fd, $fromId)
    {
        unset($this->requests[$fd]);
    }
}