provider/core/protocol/BaseProtocol.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;

use com\fenqile\fsof\common\config\FSOFConstants;

abstract class BaseProtocol implements IProtocol
{
	protected  $server;
	protected  $swoole_server;
	
	function __construct()
	{
        $this->init();
	}

    abstract public function init();
        
    public function setServer($server) 
    {
        $this->server = $server;
    }
    
    public function getAppConfig()
    {
    	return $this->server->getAppConfig();
    }

	public function getAppName()
	{
		return $this->server->getAppName();
	}

    public function getAppRunTimeEnv()
    {
    	return $this->server->getAppRunTimeEnv();
    }
    
    public function onStart($server, $workerId)
    {
    	$this->swoole_server = $server;
    	
    	//监控app重加载时间
        $this->server->getAppMonitor()->onAppReload();
        
        //当worker_id为0时添加定时器,驱动app监控信息上报
//		if($workerId == 0)
//		{
//			$this->swoole_server->addtimer(FSOFConstants::FSOF_MONITOR_TIMER);	//5分钟监控一次数据5*60*1000
//		}

        \Logger::getLogger(__CLASS__)->debug("protocol onStart():{$workerId}");
    }
    
    public function onConnect($server, $fd, $fromId)
    {

    }
    
    public function onReceive($server,$clientId, $fromId, $data, $reqInfo = null)
    {
    	
    }

    public function onClose($server, $fd, $fromId)
    {

    }
    
    public function onShutdown($serv, $workerId)
    {
    	
    }

 	public function onTask($serv, $taskId, $fromId, $data)
 	{
 		
 	}
 	
    public function onFinish($serv, $taskId, $data)
    {
    	
    }
    
    public function onTimer($serv, $interval)
    {
        switch( $interval ) 
        {
            case FSOFConstants::FSOF_MONITOR_TIMER:
            {
            	$this->server->getAppMonitor()->uploadMonitorData();
                break;
            }
        }
    }
    
    public function onRequest($request, $response)
    {
    	
    }
}