EasySwoole 服务启动过程以及主体设计流程源码解析
本文主要讲解EasySwoole 服务的启动过程，会通过源码片段讲解主体的设计流程
命令启动
当我们通过php easyswoole start启动EasySwoole 服务时，命令真正到达的文件是 easyswoole项目\vendor\easyswoole\easyswoole\bin\easyswoole，命令start执行的整体流程如下图：
主要方法为：serverStart($options);，其重要执行代码如下：
$conf = Conf::getInstance();
$inst = Core::getInstance()->initialize();
$inst->run();- 初始化Conf，即Config对象（Config类为一个单例对象），加载全局配置信息，默认配置
Config.php内容如下：
return [
'SERVER_NAME'=>"EasySwoole",
'MAIN_SERVER'=>[
'HOST'=>'0.0.0.0',
'PORT'=>9501,
'SERVER_TYPE'=>\EasySwoole\Core\Swoole\ServerManager::TYPE_WEB_SERVER,
'SOCK_TYPE'=>SWOOLE_TCP,//该配置项当为SERVER_TYPE值为TYPE_SERVER时有效
'RUN_MODEL'=>SWOOLE_PROCESS,
'SETTING'=>[
'task_worker_num' => 8, //异步任务进程
'task_max_request'=>10,
'max_request'=>5000,//强烈建议设置此配置项
'worker_num'=>8
],
],
'DEBUG'=>true,
'TEMP_DIR'=>null,//若不配置，则默认框架初始化
'LOG_DIR'=>null,//若不配置，则默认框架初始化
'EASY_CACHE'=>[
'PROCESS_NUM'=>1,//若不希望开启，则设置为0
'PERSISTENT_TIME'=>0//如果需要定时数据落地，请设置对应的时间周期，单位为秒
],
'CLUSTER'=>[
'enable'=>false,
'token'=>null,
'broadcastAddress'=>['255.255.255.255:9556'],
'listenAddress'=>'0.0.0.0',
'listenPort'=>'9556',
'broadcastTTL'=>5,
'nodeTimeout'=>10,
'nodeName'=>'easySwoole',
'nodeId'=>null
]
];- 执行入口文件Code.php对象的
initialize()方法 - 执行入口文件Code.php对象的
run()方法
ps：此处插入说明一个点，EasySwoole中单例类都复用同一个trait
trait Singleton
{
private static $instance;
static function getInstance(...$args)
{
if(!isset(self::$instance)){
self::$instance = new static(...$args);
}
return self::$instance;
}
}入口文件
Easywechat 真实入口文件为EasySwoole\Core\Core，上述已经说到命令启动时，执行了以下代码：
Core::getInstance();
$inst = Core::getInstance()->initialize();
$inst->run();在整个EasySwoole生命周期中，Core对象只会被实例化一次，Code的初始化做了如下操作：
public function __construct()
{
defined('SWOOLE_VERSION') or define('SWOOLE_VERSION',intval(phpversion('swoole')));
defined('EASYSWOOLE_ROOT') or define('EASYSWOOLE_ROOT',realpath(getcwd()));
if(file_exists(EASYSWOOLE_ROOT.'/EasySwooleEvent.php')){
require_once EASYSWOOLE_ROOT.'/EasySwooleEvent.php'; //引入全局初始化事件类
}
$this->sysDirectoryInit(); //设置temp目录和log目录，路径可配置化
}- 定义了全局宏
SWOOLE_VERSION和EASYSWOOLE_ROOT - 引入了全局初始化事件类
EasySwooleEvent.php -
$this->sysDirectoryInit();设置temp目录和log目录，路径可配置化
Core类中的initialize方法：
public function initialize():Core
{
Di::getInstance()->set(SysConst::VERSION,'2.1.2');
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_MAX_DEPTH,3);
EasySwooleEvent::frameInitialize();
$this->errorHandle();
return $this;
}- DI容器注入
SysConst::VERSION和SysConst::HTTP_CONTROLLER_MAX_DEPTH的值 - 执行全局事件类
EasySwooleEvent::frameInitialize();事件 -
$this->errorHandle();注册系统中的set_error_handler、register_shutdown_function
Core类的run方法为核心功能：
public function run():void
{
ServerManager::getInstance()->start();
}- 实例化
ServerManager类，并执行start()启动整个服务
服务管理类 ServerManager
ServerManager是一个单例对象，在整个EasySwoole生命周期中，ServeManager对象只会被实例化一次.ServeManager 的 run 方法干了下面几件事：
public function start():void
{
$this->createMainServer();
Cache::getInstance();
Cluster::getInstance()->run();
CronTab::getInstance()->run();
$this->attachListener();
$this->isStart = true;
$this->getServer()->start();
}-
createMainServer()创建主服务 - 初始化缓存服务
cache，添加对应的CacheProcess。（Easyswoole的缓存服务是基于swoole_process的管道通信，后续会专门解析下系统组件cache的源码） -
Cluster集群模式的注册 (有兴趣的可以通过链接看看) -
CronTab服务开启，后面说下crontab的使用 -
attachListener事件监听，子服务多端口监听 -
$this->getServer()->start();调用swoole_server的start方法，正式启动Easyswoole服务
ServerManager 类的createMainServer（）方法：
（1）读取配置，创建对应的swoole_server服务
case self::TYPE_SERVER:{
$this->mainServer = new \swoole_server($host,$port,$runModel,$sockType);
break;
}
case self::TYPE_WEB_SERVER:{
$this->mainServer = new \swoole_http_server($host,$port,$runModel,$sockType);
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']}"));
}
}（2）注册事件，onWorker、onTask、onFinish、onRequest等；还有easySwoole事件mainServerCreate，开发者可以在mainServerCreate事件设置Crontab 服务等
$register = new EventRegister();//事件容器
$this->finalHook($register);
EasySwooleEvent::mainServerCreate($this,$register);
$events = $register->all();（3）事件注册的过程中，还做了如下操作：实例化对象池。开发者可以通过配置，在此实例化mysql连接池等：
//实例化对象池管理
PoolManager::getInstance();
PoolManager::getInstance()->__workerStartHook($workerId);（4）在onRequest事件中，还执行了EasySwooleEvent的onRequest和afterAction，开发者可以在此自定义处理代码，如日志统一刷出等
EasySwooleEvent::onRequest($request_psr,$response_psr);
$dispatcher->dispatch($request_psr,$response_psr);
EasySwooleEvent::afterAction($request_psr,$response_psr);ServerManager 中 Cache::getInstance() 全局跨进程Cache的注册：
function __construct()
{
$num = intval(Config::getInstance()->getConf("EASY_CACHE.PROCESS_NUM"));
if($num <= 0){
return;
}
$this->cliTemp = new SplArray();
//若是在主服务创建，而非单元测试调用
if(ServerManager::getInstance()->getServer()){
//创建table用于数据传递
TableManager::getInstance()->add(self::EXCHANGE_TABLE_NAME,[
'data'=>[
'type'=>Table::TYPE_STRING,
'size'=>10*1024
],
'microTime'=>[
'type'=>Table::TYPE_STRING,
'size'=>15
]
],2048);
$this->processNum = $num;
for ($i=0;$i < $num;$i++){
ProcessManager::getInstance()->addProcess($this->generateProcessName($i),CacheProcess::class);
}
}
}Cache 服务基于 swoole_table 实现全局数据共享和传递。
以上是EasySwoole服务启动过程中的主体设计，其中包括了各种组件的实例化，如PoolManager（对象池）、cache、CronTab等。
![[SQL Server Mobile 开发基础] ppt 和 demo](/images/no-images.jpg)
