hyperf 协程

hyperf 协程

在聊协程是什么之前，我们先聊聊传统 PHP-FPM 架构的运作模式，PHP-FPM 是一个多进程的 FastCGI 管理程序，是绝大多数 PHP 应用所使用的运行模式。假设我们使用 Nginx 提供 HTTP 服务（Apache 同理），所有客户端发起的请求最先抵达的都是 Nginx，然后 Nginx 通过 FastCGI 协议将请求转发给 PHP-FPM 处理，PHP-FPM 的 Worker 进程 会抢占式的获得 CGI 请求进行处理，这个处理指的就是，等待 PHP 脚本的解析，等待业务处理的结果返回，完成后回收子进程，这整个的过程是阻塞等待的，也就意味着 PHP-FPM 的进程数有多少能处理的请求也就是多少，假设 PHP-FPM 有 200 个 Worker 进程，一个请求将耗费 1 秒的时间，那么简单的来说整个服务器理论上最多可以处理的请求也就是 200 个，QPS 即为 200/s，在高并发的场景下，这样的性能往往是不够的，尽管可以利用 Nginx 作为负载均衡配合多台 PHP-FPM 服务器来提供服务，但由于 PHP-FPM 的阻塞等待的工作模型，一个请求会占用至少一个 MySQL 连接，多节点高并发下会产生大量的 MySQL 连接，而 MySQL 的最大连接数默认值为 100，尽管可以修改，但显而易见该模式没法很好的应对高并发的场景。

根据问档协程有3种创建方式

co(callable $callable) 或 go(callable $callable) 函数或HyperfUtilsCoroutine::create(callable $callable)

下面进行实 ***

public function sprocess(){
        $wg = new HyperfUtilsWaitGroup();
        $result = [];
        // 计数器加二
        $wg->add(3);
        // 创建协程 A
        co(function () use ($wg,&$result) {
            sleep(2);
            // some code
            // 计数器减一
            $result[] = '-1';
            $wg->done();
            //当我们希望在协程结束时运行一些代码时当我们希望在协程结束时运行一些代码时，
            //可以通过 defer(callable $callable) 函数或 HyperfCoroutine::defer(callable $callable)
            // 将一段函数以 栈(stack) 的形式储存起来，栈(stack)
            // 内的函数会在当前协程结束时以 先进后出 的流程逐个执行。
            Coroutine::defer(function($query){
                var_dump(1);
            });
        });
        // 创建协程 B
        co(function () use ($wg,&$result) {
            sleep(3);
            // some code
            // 计数器减一
            $result[] = '-2';
            $wg->done();

            Coroutine::defer(function($query){
                var_dump(2);
            });
        });
        // 创建协程 C
        co(function () use ($wg,&$result) {
            // some code
            // 计数器减一
            $result[] = '-3';
            $wg->done();

            Coroutine::defer(function($query){
                var_dump(3);
            });
        });
        // 等待协程 A 和协程 B 运行完成
        $wg->wait();
        var_dump($result);
        var_dump( Coroutine::inCoroutine());//判断当前是否处于协程环境内
        var_dump( Coroutine::id());//获得当前协程的 ID
    }

访问结果：

 

 public function sprocess(){
        #比如我们希望最大设置的协程数为 5 ，也就意味着 Parallel 里最多只会有 5 个协程在运行，只有当 5 个里有协程完成结束后，后续的协程才会继续启动
        $parallel = new Parallel(5);
        $parallel->add(function () {
            sleep(1);
            return Coroutine::id();
        }, 'foo');
        $parallel->add(function () {
            sleep(1);
            return Coroutine::id();
        }, 'bar');

        try{
            // $results 结果为 [1, 2]
            $results = $parallel->wait();
        } catch(ParallelExecutionException $e){
            $e->getResults(); //获取协程中的返回值。
            $e->getThrowables(); //获取协程中出现的异常。
        }
        var_dump($results);


       #目前比较常用的协程方式
        $result1 = parallel([
            function () {
                sleep(1);
                return Coroutine::id();
            },
            function () {
                sleep(1);
                return Coroutine::id();
            }
        ]);
        #$result1  [3,4]
        var_dump($result1);

        #给协程返回值添加一个key值
        $result = parallel([
            'bar' => function () {
                sleep(1);
                return Coroutine::id();
            },
            'foo' => function () {
                sleep(1);
                return Coroutine::id();
            }
        ]);
        #返回结果{"bar":3,"foo":4}
        var_dump($result);

    }