[PHP知识库]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) 函数或Hyperf\Utils\Coroutine::create(callable $callable)

下面进行实操

public function sprocess(){
        $wg = new \Hyperf\Utils\WaitGroup();
        $result = [];
        // 计数器加二
        $wg->add(3);
        // 创建协程 A
        co(function () use ($wg,&$result) {
            sleep(2);
            // some code
            // 计数器减一
            $result[] = '-1';
            $wg->done();
            //当我们希望在协程结束时运行一些代码时当我们希望在协程结束时运行一些代码时，
            //可以通过 defer(callable $callable) 函数或 Hyperf\Coroutine::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);

    }