Easyswoole源码分析-4-start


////////////////////////////////////////////////////////////////////
//                          _ooOoo_                               //
//                         o8888888o                              //
//                         88" . "88                              //
//                         (| ^_^ |)                              //
//                         O\  =  /O                              //
//                      ____/`---'\____                           //
//                    .'  \\|     |//  `.                         //
//                   /  \\|||  :  |||//  \                        //
//                  /  _||||| -:- |||||-  \                       //
//                  |   | \\\  -  /// |   |                       //
//                  | \_|  ''\---/''  |   |                       //
//                  \  .-\__  `-`  ___/-. /                       //
//                ___`. .'  /--.--\  `. . ___                     //
//            \  \ `-.   \_ __\ /__ _/   .-` /  /                 //
//      ========`-.____`-.___\_____/___.-`____.-'========         //
//                           `=---='                              //
//      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^        //
//         佛祖保佑       永无BUG       永不修改                     //
////////////////////////////////////////////////////////////////////

1.简介

启动算是框架的核心部分了，阅读起来有些地方理解起来还是有点困难的，这些部分单独拿出来解析。

2.知识点

1.apc_clear_cache
2.opcache_reset
3.final
4.PHP中Closure类详解

3. 核心代码

start类下的exec方法的核心代码

public function exec(array $args): ?string
{
        // TODO: Implement exec() method.
        //---------------------------------1.清理apc缓存------------------------------
        Utility::opCacheClear();
        //---------------------------------2.展示Logo------------------------------
        $response = Utility::easySwooleLog();
        $mode = 'develop';
        //---------------------------------3.线上|开发配置------------------------------
        if(!Core::getInstance()->isDev()){
            $mode = 'produce';
        }
        $conf = Config::getInstance();
        //---------------------------------4.是否daemon化------------------------------
        if(in_array("d",$args) || in_array("daemonize",$args)){
            $conf->setConf("MAIN_SERVER.SETTING.daemonize", true);
        }
        //---------------------------------5.创建主服务------------------------------
        Core::getInstance()->createServer();
        $serverType = $conf->getConf('MAIN_SERVER.SERVER_TYPE');
        //---------------------------------6.cli展示信息------------------------------
        ·
        · 省略
        ·
        //---------------------------------7.启动------------------------------
        Core::getInstance()->start();
        return null;
}

3.清理apc缓存

核心代码

public static function opCacheClear()
{
        if (function_exists('apc_clear_cache')) {
            // https://www.php.net/manual/zh/function.apc-clear-cache.php
            // 1.根据官方手册来看，apc_clear_cache函数如果传递的参数为omitted或者其它字符将会清除系统缓存
            // 2.如果运行在cli则只清除命令行缓存
            // 3.如果http请求则清除的是http缓存
            apc_clear_cache();
        }
        // https://www.jianshu.com/p/f089b6d19382
        if (function_exists('opcache_reset')) {
            opcache_reset();
        }
}

展示logo略略略
线上|开发配置略略略
是否daemon化略略略

额。都略略略了，，，，其实核心部分在创建主服务。。。。

4. 创建主服务

Core::getInstance()->createServer();

function createServer()
{
        $conf = Config::getInstance()->getConf('MAIN_SERVER');
        //---------------------------------1.创建swoole server------------------------------
        ServerManager::getInstance()->createSwooleServer(
            $conf['PORT'],$conf['SERVER_TYPE'],$conf['LISTEN_ADDRESS'],$conf['SETTING'],$conf['RUN_MODEL'],$conf['SOCK_TYPE']
        );
        //---------------------------------2.注册默认的回调事件------------------------------
        $this->registerDefaultCallBack(ServerManager::getInstance()->getSwooleServer(),$conf['SERVER_TYPE']);
        //---------------------------------3.hook mainServerCreate方法------------------------------
        EasySwooleEvent::mainServerCreate(ServerManager::getInstance()->getMainEventRegister());
        //---------------------------------4.注册Console和crontab(这两个以后单独拿出来分析)------------------------------
        $this->extraHandler();
        return $this;
}

创建swoole server

这里面的Dispatcher、Request、Response类后面单独拿出来介绍。写文章的时候会把人绕晕

/**
     *  根据type创建不同的swoole服务，详细参数参考swoole手册
     *
     * @param $port
     * @param $type
     * @param string $address
     * @param array $setting
     * @param array ...$args
     * @return bool
     * CreateTime: 2019/5/27 下午3:11
     */
    function createSwooleServer($port,$type ,$address = '0.0.0.0',array $setting = [],...$args):bool
    {
        switch ($type){
            // https://wiki.swoole.com/wiki/page/p-server.html
            case EASYSWOOLE_SERVER:{
                $this->swooleServer = new \swoole_server($address,$port,...$args);
                break;
            }
            // https://wiki.swoole.com/wiki/page/327.html
            case EASYSWOOLE_WEB_SERVER:{
                $this->swooleServer = new \swoole_http_server($address,$port,...$args);
                break;
            }
            // https://wiki.swoole.com/wiki/page/397.html
            case EASYSWOOLE_WEB_SOCKET_SERVER:{
                $this->swooleServer = new \swoole_websocket_server($address,$port,...$args);
                break;
            }
            default:{
                Trigger::getInstance()->error('"unknown server type :{$type}"');
                return false;
            }
        }
        if($this->swooleServer){
            // https://wiki.swoole.com/wiki/page/13.html
            $this->swooleServer->set($setting);
        }
        return true;
    }

注册默认的回调事件

private function registerDefaultCallBack(\swoole_server $server,int $serverType)
    {
        //---------------------------------1.非swoole_server------------------------------
        if($serverType !== EASYSWOOLE_SERVER){
                     ···
            //---------------------------------1.1具体这里的Dispatcher有啥用还不清楚，等用到的时候再分析------------------------------
            $dispatcher = new Dispatcher($namespace,$depth,$max);
            $dispatcher->setControllerPoolWaitTime($waitTime);
            $httpExceptionHandler = Di::getInstance()->get(SysConst::HTTP_EXCEPTION_HANDLER);
            if(!is_callable($httpExceptionHandler)){
                $httpExceptionHandler = function ($throwable,$request,$response){
                    $response->withStatus(Status::CODE_INTERNAL_SERVER_ERROR);
                    $response->write(nl2br($throwable->getMessage()."\n".$throwable->getTraceAsString()));
                    Trigger::getInstance()->throwable($throwable);
                };
                Di::getInstance()->set(SysConst::HTTP_EXCEPTION_HANDLER,$httpExceptionHandler);
            }
            //---------------------------------1.2设置异常处理------------------------------
            $dispatcher->setHttpExceptionHandler($httpExceptionHandler);
            //---------------------------------1.3注册回调onRequest方法------------------------------
            EventHelper::on($server,EventRegister::onRequest,function (\swoole_http_request $request,\swoole_http_response $response)use($dispatcher){
                $request_psr = new Request($request);
                $response_psr = new Response($response);
                try{
                    //---------------------------------1.4 hook EasySwooleEvent的onRequest方法------------------------------
                    if(EasySwooleEvent::onRequest($request_psr,$response_psr)){
                        $dispatcher->dispatch($request_psr,$response_psr);
                    }
                }catch (\Throwable $throwable){
                    call_user_func(Di::getInstance()->get(SysConst::HTTP_EXCEPTION_HANDLER),$throwable,$request_psr,$response_psr);
                }finally{
                    try{
                        //---------------------------------1.5 hook EasySwooleEvent的afterRequest方法------------------------------
                        EasySwooleEvent::afterRequest($request_psr,$response_psr);
                    }catch (\Throwable $throwable){
                        call_user_func(Di::getInstance()->get(SysConst::HTTP_EXCEPTION_HANDLER),$throwable,$request_psr,$response_psr);
                    }
                }
                $response_psr->__response();
            });
        }
        //---------------------------------2 注册onTask方法------------------------------
        EventHelper::on($server,EventRegister::onTask,function (\swoole_server $server, Task $task){
            $finishData = null;
            $taskObj = $task->data;

            //---------------------------------2.1 判断是否为使用快速任务模板------------------------------
            // 可通过继承EasySwoole\EasySwoole\Swoole\Task\QuickTaskInterface,增加run方法,即可实现一个任务模板,通过直接投递类名运行任务:
            if(is_string($taskObj) && class_exists($taskObj)){
                          ···
            }
            //---------------------------------2.2 判断是否为异步任务模板------------------------------
            // 当任务比较复杂，逻辑较多而且固定时，可以预先创建任务模板，并直接投递任务模板，以简化操作和方便在多个不同的地方投递相同的任务，首先需要创建一个任务模板
            if($taskObj instanceof AbstractAsyncTask){
                         ···
            //---------------------------------2.3 SuperClosure是否继承SuperClosure(这里的知识点很重要，也不是很好理解，Closure类)------------------------------
            }else if($taskObj instanceof SuperClosure){
                        ···
            //---------------------------------2.4如果传递的为方法 ------------------------------
            }else if(is_callable($taskObj)){
                        ···
            }
            finish :{
                $task->finish($finishData);
            }
        });
        //---------------------------------3 注册onFinish方法 ------------------------------
        EventHelper::on($server,EventRegister::onFinish,function (\swoole_server $serv, int $task_id,$data){
            return $data;
        });

        //---------------------------------4 注册默认的worker start ------------------------------
        EventHelper::registerWithAdd(ServerManager::getInstance()->getMainEventRegister(),EventRegister::onWorkerStart,function (\swoole_server $server,$workerId){
          ···
        });
    }

5.cli展示信息

额。这里自己去看吧。

6. 启动

Core::getInstance()->start();

function start()
    {
        //给主进程也命名
        $serverName = Config::getInstance()->getConf('SERVER_NAME');
        if(PHP_OS != 'Darwin'){
            cli_set_process_title($serverName);
        }
        //启动
        ServerManager::getInstance()->start();
    }

ServerManager::getInstance()->start();

function start()
    {
        // 将EventHelper::registerWithAdd注册的回调绑定到服务,启动的时候只注册了workerStart
        $events = $this->getMainEventRegister()->all();
        foreach ($events as $event => $callback){
            $this->getSwooleServer()->on($event, function (...$args) use ($callback) {
                foreach ($callback as $item) {
                    call_user_func($item,...$args);
                }
            });
        }
        //  子服务，启动的时候只有CONSOLE(这里单独拿出来讲)
        $this->registerSubPortCallback();
        $this->isStart = true;
        // 启动
        $this->getSwooleServer()->start();
    }

7.结语

主要记录学习，不当地方请指出

8.相关连接

Easyswoole手册
Swoole手册

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,921评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 87,635评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,393评论 0赞 338
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,836评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,833评论 5赞 368
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,685评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,043评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,694评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 42,671评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,670评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,779评论 1赞 332
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,424评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,027评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,984评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,214评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,108评论 2赞 351
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,517评论 2赞 343