Laravel系列6.4管道过滤器

Posted 码农老张Zy

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Laravel系列6.4管道过滤器相关的知识,希望对你有一定的参考价值。

管道过滤器

通过之前的三篇文章,我们已经学习完了服务容器相关的内容,可以说,服务容器就是整个 Laravel 框架的灵魂,从启动的第一步开始就是创建容器并且加载所有的服务对象。而说起管道,其实大家也不会太陌生,在程序开发的世界中,管道模式的应用随处可见,同样在 Laravel 框架中,它也是核心一般的存在。甚至可以说,管道和服务容器的组合,才让我们有了一个这样的框架可以使用。

什么是管道

前面说过,管道模式非常常见,为什么这么说呢?

ps -ef | grep php

常见不?经常用吧?这个 Linux 命令就是一个管道命令。前面一条命令的结果交给后面一条命令来执行,就像一条管道一样让这个命令请求的结果向下流动,这就是管道模式的应用。

除了这个你还能想到什么呢?如果你跟过我的 PHP 设计模式系列的话,那么 责任链模式 很明显就是管道模式在 面向对象 语言中的应用呀。


管道模式一般是和过滤器一起使用的,什么是过滤器呢?其实就是我们要处理请求的那些中间方法,比如说上面命令中的 grep ,或者是 wc 、awk 这些的命令。大家其实很快就能发现,在 Laravel 框架中,我们的中间件就是一个个的过滤器。而我们要处理的数据,就是那个 Request 请求对象。

Laravel 中管道的加载应用

还记得我们在服务容器中看到过的一个 sendRequestThroughRouter() 方法吗?另外在最早讲中间件时,我们也讲过这里,我们再来看看它的代码。

protected function sendRequestThroughRouter($request)

    $this->app->instance('request', $request);

    Facade::clearResolvedInstance('request');

    $this->bootstrap();

    return (new Pipeline($this->app))
                ->send($request)
                ->through($this->app->shouldSkipMiddleware() ? [] : $this->middleware)
                ->then($this->dispatchToRouter());

在这段代码中,最后返回的那个 Pipeline 对象就是一个管道对象。我们来看看它的这几个方法是什么意思。

public function __construct(Container $container = null)

    $this->container = $container;


public function send($passable)

    $this->passable = $passable;

    return $this;


public function through($pipes)

    $this->pipes = is_array($pipes) ? $pipes : func_get_args();

    return $this;

构造函数、send() 和 through() 方法都比较简单,就是给当前的对象中的属性赋值,这个没什么特别的。不过在 Pipeline 对象中,所有的方法都是会 return 一个 $this ,其实也就是实现了对象的链式调用。

重点在于 then() 方法。

public function then(Closure $destination)

    $pipeline = array_reduce(
        array_reverse($this->pipes()), $this->carry(), $this->prepareDestination($destination)
    );

    return $pipeline($this->passable);

这个方法也出乎意料的简单吧?里面只用了一个 array_reduce() ,OK,到这里,你就可以和面试官吹牛了,Laravel 中的管道,或者说中间件,其实最核心的就是这个 array_reduce() 方法。要搞清楚 then() 方法是在干什么,我们就要先搞明白 array_reduce() 是在干嘛。

array_reduce

array_reduce() 这个函数在官方文档的签名是这样的:

array_reduce(array $array, callable $callback, mixed $initial = null): mixed

它的作用是将回调函数 callback 迭代地作用到 array 数组中的每一个单元中,从而将数组简化为单一的值。如果指定了可选参数 initial,该参数将用作处理开始时的初始值,如果数组为空,则会作为最终结果返回。

callback 这个回调函数会有两个参数,分别是 carry 携带上次迭代的返回值,如果迭代是第一次,那么这个值就是 initial 。另一个参数是 item ,也就是数组中的每个值。

看不懂吧?正常,我也看不懂,别慌,看例子。

function sum($carry, $item)

    $carry += $item;
    return $carry;


function product($carry, $item)

    $carry *= $item;
    return $carry;


$a = array(1, 2, 3, 4, 5);
$x = array();

var_dump(array_reduce($a, "sum")); // int(15)
var_dump(array_reduce($a, "product", 10)); // int(1200), because: 10*1*2*3*4*5
var_dump(array_reduce($x, "sum", "No data to reduce")); // string(17) "No data to reduce"

这段代码是官网上的例子。我们定义了一个 sum() 方法用于累加,另外再定义了一个 product() 方法用于阶乘。前两段测试的结果可以看出,通过将第一个数组传递进去,然后调用 sum() 方法,我们完成了累加的功能,输出了一个唯一的结果值。第二段则是增加了第三个参数给了个默认的 10 ,结果就是多乘了一个 10 的累乘结果。而最后一段则是一个空的数组,返回的是 initial 给定的结果。

框架中 array_reduce 的参数

搞清楚了 array_reduce() 我们再回来看看框架源码中给出的参数。第一个参数是使用 array_reverse() 返回之后的 pipes 里面的内容,这个 pipes 是我们通过 through() 方法传递进来的。再回到 Kernel 中,我们会发现这个方法传递进去的参数正是我们框架中加载的中间件 $middleware 成员变量。

之前的 bootstrap() 过程中,我们已经将所有的 app/Http/Kernel.php 中注册的中间件绑定注册到了服务容器中。因此,这个 pipes 数组中,就是我们所有的中间件信息。

接下来第二个参数是调用的一个 carry() 函数,它在 array_reduce() 方法中代表的是 callback 那个回调函数。

protected function carry()

    return function ($stack, $pipe) 
        return function ($passable) use ($stack, $pipe) 
            try 
                if (is_callable($pipe)) 
                    return $pipe($passable, $stack);
                 elseif (! is_object($pipe)) 
                    [$name, $parameters] = $this->parsePipeString($pipe);

                    $pipe = $this->getContainer()->make($name);

                    $parameters = array_merge([$passable, $stack], $parameters);
                 else 
                    $parameters = [$passable, $stack];
                

                $carry = method_exists($pipe, $this->method)
                                ? $pipe->$this->method(...$parameters)
                                : $pipe(...$parameters);

                return $this->handleCarry($carry);
             catch (Throwable $e) 
                return $this->handleException($passable, $e);
            
        ;
    ;

这个方法就复杂许多了。我们一步步的来看。

参数不用多说了吧,stack 是上一次的返回值,pipe 是当前我们要处理的值,也就是当前的中间件对象。在这个回调函数中又调用了一层回调函数,并将这两个值通过 use 传递进去。而在里面的这个回调函数中,我们的参数是 passable 这个变量。这个 passable 又是哪里来的?别急,我们先看这个函数内部的实现,最后会再说到 passable 这个问题。

进入函数内部的 try 代码段中,第一个判断,如果 pipe 是一个回调函数,直接调用它并返回;第二个判断,如果 pipe 不是一个对象而是一个 string 的话,解构 pipe 信息,服务容器 make 它,并且准备好参数;最后一个 else 也就是 pipe 是一个对象,那么将 passable 和 stack 作为它的参数。最后,如果对象都有了,就会统一调用对象的 handle 方法,这个方法名也就是 $this->method 属性定义的方法名。在最底下 $carry 调用对象或者回调函数的执行方法。handle 熟悉不?我们自定义中间件时,要实现的就是这个方法。参考:【Laravel系列3.4】中间件在路由与控制器中的应用 https://mp.weixin.qq.com/s/9340q7F_hKrrxgf4o1LNMw

最终返回的就是这个 $carry 变量,它是啥?中间件中 return next() 的东西呀,管道中的下一个回调函数。

上面的代码我们是嵌套了两层的回调函数,通过之间的学习,我们知道回调函数是有延迟加载的特性的,也就说,这一堆代码是在我们最终调用这个回调函数的时候才会触发的,那么它是在什么时候调用的呢?

public function then(Closure $destination)

    $pipeline = array_reduce(
        array_reverse($this->pipes()), $this->carry(), $this->prepareDestination($destination)
    );

    return $pipeline($this->passable);

没错,then() 方法最后的这个 return 这里,现在知道 passable 是从哪里传递进去的了吧。注意,这个 passable 和最后那个默认 initial 参数,都是我们当前的请求 Request 对象和路由 Route 对象。也就是说,在整个 Laravel 框架中,我们管道中流动的,正是我们的 Request 对象,而最后返回的,则是各个中间件以及控制器处理完成之后的 Response 对象。中间件、控制器甚至路由,其实都是我们管道中的一个个的过滤器,根据我们的条件情况以及业务情况,可以随时中断或者对请求进行处理,这下也就理解了什么我们可以在中间件返回,也可以在路由直接返回页面结果了吧。

好吧,学习一个管道,其实我们又把整个请求响应流程梳理了一遍。收获满满吧!

直接写一个管道应用来测试

直接调试管道可能比较复杂,因为 Laravel 框架加载的内容非常多,不过我们可以自己写一个管道应用来测试,并且可以设置断点来方便地调试。

首先,我们需要定义几个过滤器,也就是我们的中间件啦,不过我们不需要去实现 Laravel 规范的,只需要有 handle() 方法就可以了。

class AddDollar

    public function handle($text, $next)
        return $next("$".$text."$");
    


class AddTime

    public function handle($text, $next)
        $t = $next($text);
        return $t . time();
    


class EmailChange

    public function handle($text, $next)
        return $next(str_replace("@", "#", $text));
    

没有什么特殊的功能,我们过滤掉 Email 中的 @ 符号变成 # 号,这个很多网站有会这样的功能,避免被爬取 Email 地址。另外两个就是增加符号和时间戳。在 AddTime 的处理中,我们使用的是 后置 中间件的功能,也就是在中间件完成处理后再添加内容。这个在中间件相关的课程中我们也已经讲过了。

接下来,就是使用管道来进行处理。

Route::get('pipeline/test1', function()
    $pipes = [
        \\App\\PipelineTest\\EmailChange::class,
        \\App\\PipelineTest\\AddTime::class,
        new \\App\\PipelineTest\\AddDollar(),
        function($text, $next)
            return $next("【".$text."】");
        ,
    ];

    return app(\\Illuminate\\Pipeline\\Pipeline::class)
        ->send("测试内容看看替换Email:zyblog@zyblog.ddd")
        ->through($pipes)
        ->then(function ($text) 
            return $text . "end";
        );
    // $【测试内容看看替换Email:zyblog#zyblog.ddd】$end1630978948

);

在这段测试代码中,我们对 pipes 数组使用了类字符串、实例对象、回调函数三种方式来实现中间件过滤器,可以看到最后的输出结果正是我们想要的内容。

大家可以在这里设置断点然后进入到 Pipeline 中查看这些中间件是如何调用运行的,为什么要使用 array_reverse() 反转中间件的顺序,为什么后置中间件会在最后才去添加数据内容。这一块的调试就留给大家自己来吧!

总结

服务容器、管道(中间件)可以说是 Laravel 框架中最最核心的内容,也可以说整个框架就是建立在这两个模式之下的。对于服务容器的理解,就是要解决类的依赖问题,而对于管道的理解,则是要解决请求和响应的数据流问题。本身我们做 Web 开发,实际上就是在做对请求和响应这两条数据流的各种操作而已。

理解了最核心的两部分内容之后,下篇文章的课程中我们再来看看在 Laravel 中非常常用的 门面 功能是怎样实现的。

参考文档:

Laravel 中的 Pipeline — 管道设计范式 :https://learnku.com/laravel/t/7543/pipeline-pipeline-design-paradigm-in-laravel

Laravel 管道流原理 :https://learnku.com/articles/5206/the-use-of-php-built-in-function-array-reduce-in-laravel

以上是关于Laravel系列6.4管道过滤器的主要内容,如果未能解决你的问题,请参考以下文章

[Linux Shell学习系列十二]管道和过滤器-2.过滤器

[Linux Shell学习系列十二]管道和过滤器-2.过滤器

asp.net core系列 68 Filter管道过滤器

算法系列排序算法下篇--如何超越排序算法下界

Laravel中间件,管道之面向切面编程

Laravel中间件,管道之面向切面编程