Laravel 中间件
代码展示
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()); // $this->dispatchToRouter(),后期继续
}
new \Illuminate\Routing\Pipeline($this->app):
public function __construct(Container $container = null)
{
$this->container = $container;
}
public function send($passable)
{
$this->passable = $passable;
return $this;
}
public function through($pipes)
{
####################################################################################
# $this->middleware = [ #
# \Illuminate\Foundation\Http\Middleware\CheckForMaintenanceMode::class, #
# \Illuminate\Foundation\Http\Middleware\ValidatePostSize::class, #
# \App\Http\Middleware\TrimStrings::class, #
# \Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull::class, #
# ]; #
####################################################################################
$this->pipes = is_array($pipes) ? $pipes : func_get_args();
return $this;
}
// 中间件的本质
public function then(Closure $destination)
{
$pipeline = array_reduce(
array_reverse($this->pipes), $this->carry(), $this->prepareDestination($destination)
);
// 上面操作完之后返回一个匿名函数,接受一个参数
return $pipeline($this->passable);
}
// 注意这个是子类里面会调用的父carry,区别在于子类加入了异常处理
protected function carry()
{
// 接受匿名函数$stack参数和$pipe参数,返回匿名函数,再将此匿名函数作为第一个参数$stack迭代传入。
return function ($stack, $pipe) {
return function ($passable) use ($stack, $pipe) {
if ($pipe instanceof Closure) {
return $pipe($passable, $stack);
} elseif (! is_object($pipe)) {
list($name, $parameters) = $this->parsePipeString($pipe);
$pipe = $this->getContainer()->make($name);
$parameters = array_merge([$passable, $stack], $parameters);
} else {
$parameters = [$passable, $stack];
}
// 中间件作用是提供了一种方便的机制来过滤进入应用的 HTTP 请求
// $this->method默认为handle,可通过via方法进行设置
return $pipe->{$this->method}(...$parameters);
};
};
}
protected function parsePipeString($pipe)
{
// 不带参数的pipe(class)或带参数(参数以,分割)的pipe(class:param1,param2,param3...)
list($name, $parameters) = array_pad(explode(':', $pipe, 2), 2, []);
if (is_string($parameters)) {
$parameters = explode(',', $parameters);
}
// $parameters为[]数组或[param1,param2,param3...]
return [$name, $parameters];
}
protected function prepareDestination(Closure $destination)
{
return function ($passable) use ($destination) {
return $destination($passable);
};
}
前置条件
array_reduce接受三个参数,第一个参数接收数组,第二个参数函数名(也可以是匿名函数,函数有两个参数,分别代表$result和$item),第三个参数(可选),该参数将被当成是数组中的第一个值来处理,或者如果数组为空的话就作为最终返回值。
匿名函数也叫闭包函数(closures),允许临时创建一个没有指定名称的函数,通过 Closure 类来实现的。
当对闭包函数进行赋值时,PHP 便会自动将此种表达式转换成内置类 Closure 的对象对象在进行赋值。
当闭包函数使用到 use 使用外部数据时,会在 Closure 对象生成一个 static 属性数组进行存放。
当闭包函数使用到参数时,会在 Closure 对象生成一个 parameter 属性数组进行存放。
public function then(Closure $destination)
{
$pipeline = array_reduce(
array_reverse($this->pipes), $this->carry(), $this->prepareDestination($destination)
);
return $pipeline($this->passable);
}
生成最终匿名函数的过程:
array_reduce执行第一次时得到如下简化的匿名函数返回,将会继续作为第一个参数进行迭代:
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#1 (0) { // $this->prepareDestination($destination)
}
["pipe"]=>
string(15) "Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull"
}
}
第二次:
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#1 (0) { // $this->prepareDestination($destination)
}
["pipe"]=>
string(15) "Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull"
}
}
["pipe"]=>
string(15) "App\Http\Middleware\TrimStrings"
}
}
第三次:
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#id (1) {
["static"]=>
array(2) {
["stack"]=>
object(Closure)#1 (0) { // $this->prepareDestination($destination)
}
["pipe"]=>
string(15) "Illuminate\Foundation\Http\Middleware\ConvertEmptyStringsToNull"
}
}
["pipe"]=>
string(15) "App\Http\Middleware\TrimStrings"
}
}
["pipe"]=>
string(15) "Illuminate\Foundation\Http\Middleware\ValidatePostSize"
}
}
依次类推,最终得到一个匿名函数如下(接受一个参数,此匿名函数内部使用上面递归形式的$pipe和$stack)。
function ($passable) {
if ($pipe instanceof Closure) {
return $pipe($passable, $stack);
} elseif (! is_object($pipe)) {
list($name, $parameters) = $this->parsePipeString($pipe);
$pipe = $this->getContainer()->make($name); // 实例化middleware
$parameters = array_merge([$passable, $stack], $parameters);
} else {
$parameters = [$passable, $stack];
}
return $pipe->{$this->method}(...$parameters); // 语法糖模式,因为middleware参数可有可无
};
最终匿名函数的调用过程(从最外层开始,这就是前面为什么要array_reverse,一层一层往里拨,整体上的处理是:$pipe若是匿名函数,直接调用。若是字符串,则解析成对应的类和参数,make类,再组成参数数组。最后调用$pipe->handle)
最外层($pipe=Illuminate\Foundation\Http\Middleware\CheckForMaintenanceMode):
(new \Illuminate\Foundation\Http\Middleware\CheckForMaintenanceMode)->handle($passable, $stack)
执行完前置操作后,调用$stack($passable),继续进行下一层
下一层($pipe=Illuminate\Foundation\Http\Middleware\ValidatePostSize):
(new \Illuminate\Foundation\Http\Middleware\ValidatePostSize)->handle($passable, $stack)
执行完前置操作后,调用$stack($passable),继续进行下一层
**以此类推,当每层中间件的前置任务全部完成,即递归执行到最里面一层(路由分发,解析请求,返回响
应),再由最内层一层一层往回走,执行每层中间件的后置任务。至此,返回本次请求的响应。**
最内层(即路由分发,解析请求,返回响应)的操作代码展示,后续分析:即执行$destination($passable)匿名函数,位于下面方法中。
protected function prepareDestination(Closure $destination)
{
return function ($passable) use ($destination) {
return $destination($passable);
};
}
$destination:
protected function dispatchToRouter()
{
return function ($request) {
$this->app->instance('request', $request);
return $this->router->dispatch($request);
};
}
说明:
所有的后置操作,都是执行到最内层,递归往回走时才会执行逐层执行。