hyperf| hyperf 源碼解讀 2: start

date: 2019-08-19 23:03:15
title: hyperf| hyperf 源碼解讀 2: start

上篇我們跟著 php bin/hyperf.php 命令, 看到了框架的核心 container, 這篇我們跟著 php bin/hyperf.php start, 來會一會強大到爆炸的 swoole

開始之前, 請確保自己具備一定的 swoole 基礎(chǔ)知識, 這篇適合你:

千萬不要小看了 基礎(chǔ)知識, 與其一直卡殼浪費時間, 不如沉下心來好好讀一下 swoole wiki, 看似 艱辛, 絕對比沒有這些基礎(chǔ)知識導(dǎo)致的時間浪費要劃算得多得多得多 !

Command 基礎(chǔ)

從上一篇的 blog 可知, hyperf 源碼解讀 1: 啟動, php bin/hyperf.php 執(zhí)行的命令, 是基于 Symfony\Component\Console\Application 提供的命令行應(yīng)用提供的功能, 初始內(nèi)置的 command, 是有 ConfigProvider 配置項中的 command 字段設(shè)置的. 那么, 我們將要執(zhí)行的 start 命令, 是由哪個 command 提供的呢?

可以根據(jù) gen:command 命令生成的 demo 代碼, 了解到:

// \App\Command\TestCommand
public function __construct(ContainerInterface $container)
{
    $this->container = $container;

    // 命令的名字通常在這里配置
    parent::__construct('t');
}

對應(yīng)的 start 命令, 就可以通過全局搜索 parent::__construct('start') 查詢到

搜索是很重要的能力, 甚至可以上升到 搜商. 你并不需要特別熟悉一個事物, 但是你依舊有 能力 進行處理, 搜商就是這樣的一個基礎(chǔ)能力. 閱讀源碼也是提高搜商的一個有力方法.

OK, 就定位到了我們 start 命令對應(yīng)的代碼: \Hyperf\Server\Command\StartServer

StartServer 一覽

/**
 * @Command
 */
class StartServer extends SymfonyCommand
{
    /**
     * @var ContainerInterface
     */
    private $container;

    public function __construct(ContainerInterface $container)
    {
        parent::__construct('start');
        $this->container = $container;

        $this->setDescription('Start swoole server.');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        \Swoole\Runtime::enableCoroutine(true);

        $this->checkEnvironment($output);

        $serverFactory = $this->container->get(ServerFactory::class)
            ->setEventDispatcher($this->container->get(EventDispatcherInterface::class))
            ->setLogger($this->container->get(StdoutLoggerInterface::class));

        $serverConfig = $this->container->get(ConfigInterface::class)->get('server', []);
        if (! $serverConfig) {
            throw new \InvalidArgumentException('At least one server should be defined.');
        }

        $serverFactory->configure($serverConfig);
        $serverFactory->start();
    }

    private function checkEnvironment(OutputInterface $output)
    {
        if (ini_get_all('swoole')['swoole.use_shortname']['local_value'] !== 'Off') {
            $output->writeln('<error>ERROR</error> Swoole short name have to disable before start server, please set swoole.use_shortname = \'Off\' into your php.ini.');
            exit(0);
        }
    }
}
  • @Command 注解, container 初始化的時候會有 scan 注解, 就能把這個類解析為 command 來使用
  • execute() 是 command 實際執(zhí)行的方法, \Symfony\Component\Console\Command\Command 作為基類采用這個方法, 而 \Hyperf\Command\Command 作為基類, 則是使用 handle() 方法
  • $serverFactory = $this->container->get(ServerFactory::class): container 的經(jīng)典使用場之一, 由 container 來解決類的初始化, 使用放直接使用即可

ServerFactory 細節(jié)

還是上面的代碼:

$serverFactory = $this->container->get(ServerFactory::class)
  ->setEventDispatcher($this->container->get(EventDispatcherInterface::class))
  ->setLogger($this->container->get(StdoutLoggerInterface::class));

$serverConfig = $this->container->get(ConfigInterface::class)->get('server', []);
if (! $serverConfig) {
    throw new \InvalidArgumentException('At least one server should be defined.');
}

$serverFactory->configure($serverConfig);

$serverFactory->start();
  • 實例化 ServerFactory 時, 配置好框架的基礎(chǔ)組件 Event(事件模塊) / Logger(日志模塊)
  • 從框架通的 Config(配置) 組件獲取 server 配置, 即 config/autoload/server.php 文件的配置內(nèi)容
  • server start, 配置好了 swoole server 后, 使用 Swoole\Server->start() 啟動服務(wù)即可

server config 的實現(xiàn)細節(jié)

server config 的實現(xiàn)細節(jié), 直接跟讀代碼定位到:

// \Hyperf\Server\Server::initServers
    protected function initServers(ServerConfig $config)
    {
        $servers = $this->sortServers($config->getServers());

        foreach ($servers as $server) {
            $name = $server->getName();
            $type = $server->getType();
            $host = $server->getHost();
            $port = $server->getPort();
            $sockType = $server->getSockType();
            $callbacks = $server->getCallbacks();
            ...
  • 先根據(jù) swoole 的限制, 如果配置了多個 server, 需要先啟動 http/ws server, 再通過 addPort() 的方式添加其余的 server, 這一步 hyperf 框架已經(jīng)處理掉了
  • 綁定 swoole server 需要 callback(回調(diào)函數(shù))
  • 觸發(fā) BeforeMainServerStart / BeforeServerStart 等事件

深入 server start

等等, server start 這么簡單 ?! 再來回顧一下 php bin/hyperf.php start:

root@820d21e61cd8 /d/hyperf-demo# php bin/hyperf.php start
Scanning ...
Scan completed.
[DEBUG] Event Hyperf\Framework\Event\BootApplication handled by Hyperf\Di\Listener\BootApplicationListener listener.
[DEBUG] Event Hyperf\Framework\Event\BootApplication handled by Hyperf\Config\Listener\RegisterPropertyHandlerListener listener.
[DEBUG] Event Hyperf\Framework\Event\BootApplication handled by Hyperf\RpcClient\Listener\AddConsumerDefinitionListener listener.
[DEBUG] Event Hyperf\Framework\Event\BootApplication handled by Hyperf\Paginator\Listener\PageResolverListener listener.
[DEBUG] Event Hyperf\Framework\Event\BootApplication handled by Hyperf\JsonRpc\Listener\RegisterProtocolListener listener.
[DEBUG] Event Hyperf\Framework\Event\BeforeMainServerStart handled by Hyperf\Amqp\Listener\BeforeMainServerStartListener listener.
[DEBUG] Event Hyperf\Framework\Event\BeforeMainServerStart handled by Hyperf\Process\Listener\BootProcessListener listener.
[DEBUG] Event Hyperf\Framework\Event\OnStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Framework\Event\OnManagerStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[INFO] Worker#1 started.
[INFO] TaskWorker#2 started.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\AfterWorkerStartListener listener.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Framework\Event\MainWorkerStart handled by Hyperf\Amqp\Listener\MainWorkerStartListener listener.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\AfterWorkerStartListener listener.
[INFO] Process[queue.default.0] start.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Process\Listener\LogBeforeProcessStartListener listener.
[INFO] Worker#0 started.
[INFO] Process[TestConsumer-hyperf.1] start.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Process\Listener\LogBeforeProcessStartListener listener.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[INFO] HTTP Server listening at 0.0.0.0:9501
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\AfterWorkerStartListener listener.
[INFO] TaskWorker#3 started.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[DEBUG] Event Hyperf\Framework\Event\AfterWorkerStart handled by Hyperf\Server\Listener\AfterWorkerStartListener listener.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Server\Listener\InitProcessTitleListener listener.
[INFO] Process[TestConsumer-hyperf.0] start.
[DEBUG] Event Hyperf\Process\Event\BeforeProcessHandle handled by Hyperf\Process\Listener\LogBeforeProcessStartListener listener.

是的, 使用了 Event 機制帶來的靈活性, swoole Process 就是這個過程中啟動的, 而 hyperf 中很多組件底層都是使用的 swoole Process 實現(xiàn)的, 這里只給出調(diào)用鏈路, 感興趣的小伙伴自己去瞧哦:

// 觸發(fā) BeforeMainServerStart 事件
// vendor/hyperf/server/src/Server.php:110
$this->eventDispatcher->dispatch(new BeforeMainServerStart($this->server, $config->toArray()));

// 事件監(jiān)聽器處理
\Hyperf\Process\Listener\BootProcessListener::process

// 啟動 swoole process
\Hyperf\Process\AbstractProcess::bind

// 對應(yīng)的 swoole 方法
\Swoole\Server::addProcess

寫在最后

start 命令對源碼閱讀確實是一個相當有挑戰(zhàn)的部分:

  • 對 swoole 方法的封裝, 要發(fā)揮出 swoole 超強能力, 所以說 swoole 的基礎(chǔ)知識很重要
  • hyperf 多個基礎(chǔ)組件的聯(lián)動, 包括 container / event / log / config

希望看到這里, 你可以感受到 hyperf 和 swoole 的強大之處, 頭腦中大概能對 hyperf 運行的 生命周期 有個大致的了解

下篇我們開始協(xié)程的話題, 以及轉(zhuǎn)到協(xié)程下編程必備的組件, 協(xié)程編程須知等內(nèi)容.

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末卒废,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子昭抒,更是在濱河造成了極大的恐慌淑蔚,老刑警劉巖脊串,帶你破解...
    沈念sama閱讀 212,657評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件飘庄,死亡現(xiàn)場離奇詭異镰禾,居然都是意外死亡羡亩,警方通過查閱死者的電腦和手機丹禀,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,662評論 3 385
  • 文/潘曉璐 我一進店門状勤,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人湃崩,你說我怎么就攤上這事荧降。” “怎么了攒读?”我有些...
    開封第一講書人閱讀 158,143評論 0 348
  • 文/不壞的土叔 我叫張陵朵诫,是天一觀的道長。 經(jīng)常有香客問我薄扁,道長剪返,這世上最難降的妖魔是什么废累? 我笑而不...
    開封第一講書人閱讀 56,732評論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮脱盲,結(jié)果婚禮上邑滨,老公的妹妹穿的比我還像新娘。我一直安慰自己钱反,他們只是感情好掖看,可當我...
    茶點故事閱讀 65,837評論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著面哥,像睡著了一般哎壳。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上尚卫,一...
    開封第一講書人閱讀 50,036評論 1 291
  • 那天归榕,我揣著相機與錄音,去河邊找鬼吱涉。 笑死刹泄,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的怎爵。 我是一名探鬼主播特石,決...
    沈念sama閱讀 39,126評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼疙咸!你這毒婦竟也來了县匠?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,868評論 0 268
  • 序言:老撾萬榮一對情侶失蹤撒轮,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后贼穆,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體题山,經(jīng)...
    沈念sama閱讀 44,315評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,641評論 2 327
  • 正文 我和宋清朗相戀三年故痊,在試婚紗的時候發(fā)現(xiàn)自己被綠了顶瞳。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,773評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡愕秫,死狀恐怖慨菱,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情戴甩,我是刑警寧澤符喝,帶...
    沈念sama閱讀 34,470評論 4 333
  • 正文 年R本政府宣布,位于F島的核電站甜孤,受9級特大地震影響协饲,放射性物質(zhì)發(fā)生泄漏畏腕。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 40,126評論 3 317
  • 文/蒙蒙 一茉稠、第九天 我趴在偏房一處隱蔽的房頂上張望描馅。 院中可真熱鬧,春花似錦而线、人聲如沸铭污。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,859評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽况凉。三九已至,卻和暖如春各拷,著一層夾襖步出監(jiān)牢的瞬間刁绒,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,095評論 1 267
  • 我被黑心中介騙來泰國打工烤黍, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留知市,地道東北人。 一個月前我還...
    沈念sama閱讀 46,584評論 2 362
  • 正文 我出身青樓速蕊,卻偏偏與公主長得像嫂丙,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子规哲,可洞房花燭夜當晚...
    茶點故事閱讀 43,676評論 2 351

推薦閱讀更多精彩內(nèi)容