美文网首页
hyperf源码分析

hyperf源码分析

作者: rosekissyou | 来源:发表于2020-11-27 16:32 被阅读0次

    本分析基于hyperf2.0

    具体详情参考https://hyperf.wiki/2.0/#/

    # 1 下载image

    dockerpull hyperf/hyperf:latest

    # 加载image成为容器

    dockerrun -it -v D:\wwwroot\code\demo:/hyperf-skeleton -p 2804:9501 --name=hyperfdemo2804 hyperf/hyperf:latest

    composer安装

    # 镜像容器运行后,在容器内安装 Composer

    wgethttps://mirrors.aliyun.com/composer/composer.phar

    chmodu+x composer.phar

    mvcomposer.phar /usr/local/bin/composer

    # 通过 Composer 安装 hyperf/hyperf-skeleton 项目

    composercreate-project hyperf/hyperf-skeleton

    # 基本上全部回车就可以了

    查看hyperf.php文件

    #!/usr/bin/env php

    <?php

    ini_set('display_errors','on');

    ini_set('display_startup_errors','on');

    error_reporting(E_ALL);

    ! defined('BASE_PATH') && define('BASE_PATH', dirname(__DIR__,1));

    ! defined('SWOOLE_HOOK_FLAGS') && define('SWOOLE_HOOK_FLAGS', SWOOLE_HOOK_ALL);

    requireBASE_PATH .'/vendor/autoload.php';

    // Self-called anonymous function that creates its own scope and keep the global namespace clean.

    (function(){

        Hyperf\Di\ClassLoader::init();

    /**@var\Psr\Container\ContainerInterface $container */

    $container =requireBASE_PATH .'/config/container.php';

        $application = $container->get(\Hyperf\Contract\ApplicationInterface::class);

        $application->run();

    })();

    PHP ini 设置, 按需设置即可, 比如这里还可以设置时区

    常量 BASE_PATH, hyperf 只设置了这个一个常量, 用来所有 路径 相关的场景

    config/container.php, container 的初始化, 重中之重的内容

    Application->run(), 完整的是 Symfony\Component\Console\Application, 用来跑 cli 应用

    用了一个闭包的写法,避免外部变量影响内部,主要是实例化一个ioc容器,创建控制台应用程序

    重点  重点  重点 (重要的事情说三遍) hyperf所采用的Di容器的概念也就是这里

    $container =newContainer((newDefinitionSourceFactory(true))());

    这里是实例化ioc容器,其实是去加载了composer.lock里面的内容,

    进入  Hyperf\Di\Definition\DefinitionSourceFactory.php

    <?php

    declare(strict_types=1);

    /**

    * This file is part of Hyperf.

    *

    *@linkhttps://www.hyperf.io

    *@documenthttps://hyperf.wiki

    *@contactgroup@hyperf.io

    *@licensehttps://github.com/hyperf/hyperf/blob/master/LICENSE

    */

    namespaceHyperf\Di\Definition;

    useHyperf\Config\ProviderConfig;

    useHyperf\Di\Exception\Exception;

    classDefinitionSourceFactory

    {

    /**

    *@varbool

        */

    protected$enableCache =false;

    /**

    *@varstring

        */

    protected$baseUri;

    publicfunction__construct(bool$enableCache =false)

        {

    $this->enableCache = $enableCache;

    if(! defined('BASE_PATH')) {

    thrownewException('BASE_PATH is not defined.');

            }

    $this->baseUri = BASE_PATH;

        }

    publicfunction__invoke()

        {

    $configDir =$this->baseUri .'/config';

            $configFromProviders = [];

    if(class_exists(ProviderConfig::class)) {

                $configFromProviders = ProviderConfig::load();

            }

    $serverDependencies = $configFromProviders['dependencies'] ?? [];

    if(file_exists($configDir .'/autoload/dependencies.php')) {

    $definitions =include$configDir .'/autoload/dependencies.php';

                $serverDependencies = array_replace($serverDependencies, $definitions ?? []);

            }

    returnnewDefinitionSource($serverDependencies);

        }

    }

    __invoke() 方法也是魔术方法,会被同时调用, __invoke 方法定位到了/config 目录,

    可以看到加载完composer.lock之后经过处理的 load() 返回值,处理完container.php,返回值回到hyperf.php 是一个对象,

    包含了初始化好的Di和其他需要的工厂类,例如需要用到的mysql扩展类

    然后会判断是否 \Psr\Container\ContainerInterface

    可以在下面的完整参数里面看到第一个就是它,如果初始化后没有这个会报错

    并且取用 PSR Container 加载

    接下来是常用的

    php bin/hyperf.phpstart

    这里的start也就是启动项目

    在 Hyperf/Server\Command 的 StartServer 定义了start

    publicfunction__construct(ContainerInterface $container)

        {

    $this->container = $container;

    parent::__construct('start');

    $this->setDescription('Start hyperf servers.');

        }

    然后就是start真正执行的代码

    protectedfunctionexecute(InputInterface $input, OutputInterface $output)

        {

    $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) {

    thrownewInvalidArgumentException('At least one server should be defined.');

            }

            $serverFactory->configure($serverConfig);

    Runtime::enableCoroutine(true, swoole_hook_flags());

            $serverFactory->start();

    return0;

        }

    这里会检查运行环境,同时至少需要开启一个server

    相关文章

      网友评论

          本文标题:hyperf源码分析

          本文链接:https://www.haomeiwen.com/subject/lswxwktx.html