二 分析easyswoole源码(启动服务)
2018-08-07 08:53:14来源:博客园 阅读 ()
前文连接,阅读的时候最好参照EasySwoole2.1.2的源码
$inst->run();//启动服务
这里实际调用的是Core的start方法ServerManager::getInstance()->start();
这个方法主要是启动swoole服务的
//创建主服务 $this->createMainServer();
在这块代码里主要是核心,是在swoole执行start服务前设置相关配置以及配置相关回调函数。具体代码如下
先给服务器配置相关运行参数
$conf = Config::getInstance()->getConf("MAIN_SERVER");//获取Config.php 中配置的MAIN_SERVER数组 $runModel = $conf['RUN_MODEL'];//获取运行模式 默认是SWOOLE_PROCESS模式,使用进程模式,业务代码在Worker进程中执行 $host = $conf['HOST'];//获取运行的host 'HOST'=>'0.0.0.0', $port = $conf['PORT'];//获取配置的运行端口为9501 'PORT'=>9501, $setting = $conf['SETTING'];//这里设置的相关的配置项,这些配置做一些解释,参照https://wiki.swoole.com/wiki/page/274.html 'SETTING'=>[ 'task_worker_num' => 8, //配置Task进程的数量,配置此参数后将会启用task功能。所以Server务必要注册onTask、onFinish2个事件回调函数。如果没有注册,服务器程序将无法启动。 'task_max_request'=>10,//设置task进程的最大任务数。一个task进程在处理完超过此数值的任务后将自动退出。这个参数是为了防止PHP进程内存溢出。如果不希望进程自动退出可以设置为0,炒鸡重要,进程中的数据,如果有一个global数组,或者全局变量,不设置这个就会不回收最终导致内存溢出 'max_request'=>5000,//设置worker进程的最大任务数,这个和task_max_request功能一样,为了解决PHP进程内存溢出问题 'worker_num'=>8//设置启动的Worker进程数 ], //其实这里还有2个配置,是前文中提到的,在前文19行$this->sysDirectoryInit();会初始化配置pid_file和log_file pid_file //在Server启动时自动将master进程的PID写入到文件,在Server关闭时自动删除PID文件。 log_file //指定swoole错误日志文件。在swoole运行期发生的异常信息会记录到这个文件中。默认会打印到屏幕。 $sockType = $conf['SOCK_TYPE'];//指定当前运行的服务是什么服务器。有tcp服务,http服务,websocket服务。默认是tcp服务 switch ($conf['SERVER_TYPE']){ case self::TYPE_SERVER:{ $this->mainServer = new \swoole_server($host,$port,$runModel,$sockType);//创建mainServer,这里创建了一个tcp服务器 break; } case self::TYPE_WEB_SERVER:{ $this->mainServer = new \swoole_http_server($host,$port,$runModel,$sockType);//web方式是默认 break; } case self::TYPE_WEB_SOCKET_SERVER:{ $this->mainServer = new \swoole_websocket_server($host,$port,$runModel,$sockType); break; } default:{ Trigger::throwable(new \Exception("unknown server type :{$conf['SERVER_TYPE']}")); } } $this->mainServer->set($setting);//将上面的相关服务启动配置到mainServer
创建默认的事件注册器,给服务注册默认的是事件处理函数
$register = new EventRegister(); $this->finalHook($register); EasySwooleEvent::mainServerCreate($this,$register);//这里是框架全局事件mainServerCreate主服务创建事件 $events = $register->all(); //然后循环给swoole服务器绑定回调函数。这里同一个回调方法设置多个回调函数 foreach ($events as $event => $callback){ $this->mainServer->on($event, function () use ($callback) { $ret = []; $args = func_get_args(); foreach ($callback as $item) { array_push($ret,Invoker::callUserFuncArray($item, $args)); } if(count($ret) > 1){ return $ret; } return array_shift($ret); }); }
这里提一下finalHook具体做了什么操作
$this->finalHook($register);
//实例化对象池管理 PoolManager::getInstance(); //register,先绑定一个workerStart回调函数。此事件在Worker进程/Task进程启动时发生。这里创建的对象可以在进程全局周期内使用。 $register->add($register::onWorkerStart,function (\swoole_server $server,int $workerId){ PoolManager::getInstance()->__workerStartHook($workerId); $workerNum = Config::getInstance()->getConf('MAIN_SERVER.SETTING.worker_num'); $name = Config::getInstance()->getConf('SERVER_NAME'); if(PHP_OS != 'Darwin'){ if($workerId <= ($workerNum -1)){//判断当前是否是worker进程 $name = "{$name}_Worker_".$workerId; }else{//这个是task进程 $name = "{$name}_Task_Worker_".$workerId; } cli_set_process_title($name);//设置当前的进程名称 //图片 } }); //EventHelper 是一个框架提供的默认的事件处理函数(这些放到后面具体讲述) EventHelper::registerDefaultOnTask($register);//注册默认的task回调,处理task任务的具体函数 EventHelper::registerDefaultOnFinish($register);//注册默认的task任务完成后的回调 EventHelper::registerDefaultOnPipeMessage($register);//注册pipeMessage回调函数 $conf = Config::getInstance()->getConf("MAIN_SERVER"); //如果是http服务器或者websocket,需要注册request回调函数 if($conf['SERVER_TYPE'] == self::TYPE_WEB_SERVER || $conf['SERVER_TYPE'] == self::TYPE_WEB_SOCKET_SERVER){ if(!$register->get($register::onRequest)){ EventHelper::registerDefaultOnRequest($register);//这里包含了请求,然后路由解析,处理返回的功能。就跟一般web框架类似 } }
系统启动后,在worker启动的时候,会进行改名的操作,如下图
最后注册相关的cache监听端口等就启动swoole服务了。
Cache::getInstance(); //这里注册Cache Cluster::getInstance()->run(); //实现RPC CronTab::getInstance()->run(); //定时任务 $this->attachListener();//Swoole提供了swoole_server::addListener来增加监听的端口。业务代码中可以通过调用swoole_server::connection_info来获取某个连接来自于哪个端口。这里框架启动的时候host配置的是0.0.0.0 所以监听所有地址,就没必要设置这个了 $this->isStart = true; $this->getServer()->start();//启动swoole服务器,在这之前创建的对象都在程序全局期中
下篇文章介绍TableManager。因为它在很多地方都被用到了。
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- thinkPHP5分页功能实现方法分析 2020-02-08
- Laravel框架实现redis集群的方法分析 2020-01-17
- 分析php中注册器模式类用法实例 2019-12-02
- 实例分析ThinkPHP关联模型的操作 2019-11-29
- php自动加载机制的深入分析 2019-10-28
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash