Pipeline管道模式，也有人叫它装饰模式。应该说管道是装饰模式的一个变种，虽然思想都是一样的，但这个是闭包的版本，实现方式与传统装饰模式也不太一样。在laravel的源码中算是一个比较核心的设计模式了。
管道模式，或者说装饰模式的思想，就是在不改变原有程序的基础上，可以方便的在已有程序上添加新的功能。
在说管道模式之前让我们看一下array_reduce这个函数
mixed array_reduce ( array $array , callable $callback [, mixed $initial = NULL ] ) array_reduce() 将回调函数 callback 迭代地作用到 array 数组中的每一个单元中，从而将数组简化为单一的值。 array
输入的 array。 callback
mixed callback ( mixed $carry , mixed $item )
carry
携带上次迭代里的值； 如果本次迭代是第一次，那么这个值是 initial。 item
携带了本次迭代的值。 initial
如果指定了可选参数 initial，该参数将在处理开始前使用，或者当处理结束，数组为空时的最后一个结果。
以上是php官网对这个函数的解释，看的一头雾水对不对？没关系，我们先来一个demo
//首先我们有一个数组
$a = array(1, 2, 3, 4, 5);
$x = array(); //我们输出了array_reduce的结果为15，这个函数传递了两个参数，第一个就是上面的数组a,我们重点来看第二个闭包函数
var_dump(array_reduce($a, "sum")); // int(15) //array_reduce的第三个参数会在循环开始的时候当做闭包函数的第一个carry值传入
var_dump(array_reduce($a, "product", 10)); // int(1200), because: 10*1*2*3*4*5 //当array_reduce处理结束后，若结果为空，也会将第三个参数返回
var_dump(array_reduce($x, "sum", "No data to reduce")); // string(17) "No data to reduce" //这个闭包函数接收了两个参数
function sum($carry, $item)
{
echo 'before___carry:'.$carry.'<br><br>';
echo 'before___item:'.$item.'<br><br>'; //这个函数只是简单的对两个参数做了加法
$carry += $item; echo 'after___carry:'.$carry.'<br><br>';
echo '<br><br>';
return $carry;
} function product($carry, $item)
{
echo 'before___carry:'.$carry.'<br><br>';
echo 'before___item:'.$item.'<br><br>'; $carry *= $item; echo 'after___carry:'.$carry.'<br><br>';
echo '<br><br>';
return $carry;
}
大家在运行过这个demo之后，便会发现，array_reduce只是一个循环函数。但是，它和foreach不一样的地方在于，它的闭包处理函数所接收的两个参数。其中的$item参数会在每次循环的时候代入数组的各项值，而$carry就比较专一了，它只接收上一次循环中自己的返回值。不过专一也只是相对的，$carray还接收array_reduce传入的第三个参数作为闭包开始循环前$carray的默认值，或是循环结束后返回值为null时的默认值。我在代码中已经把变量各时期的值给打印出来了，相信大家一看就会明白。这个函数最典型的例子就是在做累计运算的时候，我们不需要向foreach循环那样创建一个变量了。（大家都知道给变量起名字是一件很麻烦的事情）
ok，函数介绍完了，可是这和管道模式又有什么关系呢？不知道大家注意到没有，在array_reduce的闭包函数进行循环的时候，array_reduce的第三个参数从闭包的$array进入，从return返回，紧接着再次从$array中进入，而每次循环的时候，都会从$item中获取到外部进行运算。这个过程是不是很像数据在一个螺旋管道中流通，同时不断的向其中添加新的操作，并且没有改变原先的程序代码，降低了程序间的耦合度。
接下来进行管道模式
请求处理管道的思维导图
思维导图看的还不够清晰？ok，接着举例子，看demo
从图中我们可以知道类Request都具有相同的接口，那么我们可以约定一个接口规范
interface RequestInterface
{
// 我们之前讲过装饰者模式，这里是通过闭包函数实现
// 通过之后实现类及调用就可以看出
public static function handle(Closure $next);
}
接口有了那么我们就遵循接口开始实现
class Request1 implements RequestInterface
{
public static function handle(Closure $next)
{
echo "Request1 Begin." . "<br />";
$next();
echo "Request1 End." . "<br />";
}
} class Request2 implements RequestInterface
{
public static function handle(Closure $next)
{
echo "Request2 Begin." . "<br />";
$next();
echo "Request2 End." . "<br />";
}
} class Request3 implements RequestInterface
{
public static function handle(Closure $next)
{
echo "Request3 Begin." . "<br />";
$next();
echo "Request3 End." . "<br />";
}
} class Request4 implements RequestInterface
{
public static function handle(Closure $next)
{
echo "Request4 Begin." . "<br />";
$next();
echo "Request4 End." . "<br />";
}
}
四种请求处理过程我们均已实现，为了简化都是打印一句话，可以在浏览器上直观显示流程；
我们还需要一个客户端来发出请求
class Client
{
// 这里包含了所有的请求
private $pipes = [
'Request1',
'Request2',
'Request3',
'Request4',
]; // 这里就是思维导图中默认返回的匿名回调函数
private function defaultClosure()
{
return function () {
echo '请求处理中...' . "<br />";
};
} // 这里就是整个请求处理管道的关键
private function getSlice()
{
return function ($stack, $pipe)
{
return function () use ($stack, $pipe)
{
return $pipe::handle($stack);
};
};
} // 这里是负责发起请求处理
public function then()
{
call_user_func(array_reduce($this->pipes, $this->getSlice(), $this->defaultClosure()));
}
}
当我们调用时：
$worker = new Client();
$worker->then();
浏览器就会显示：
那么我来解释一下整个流程吧，在代码注释说了getSlice是关键，那么我们来解读一下代码
解析代码
client的then方法，call_user_func是执行一个函数的api，它的参数是一个闭包函数。而这个参数则是我们文章一开始提到的array_reduce这个循环的最终返回值。
我们都还记得这个函数一共有三个参数：
第一个参数代表从外界加入到管道中的附加操作
第二个参数则是执行加工的工厂
第三个参数则是进入管道的程序数据源
先看第三个参数数据源
// 这里就是思维导图中默认返回的匿名回调函数
private function defaultClosure()
{
//这个return出去的闭包就是我们的数据源
return function () {
echo '请求处理中...' . "<br />";
};
}
然后对程序进行装饰的装饰品数组
// 这里包含了所有的请求
private $pipes = [
'Request1',
'Request2',
'Request3',
'Request4',
];
这里虽然只是个数组，但它在刚刚的循环闭包中被当做对象名来使用，通过名称调度不同的类
然后是循环闭包
// 这里就是整个请求处理管道的关键
private function getSlice()
{
//这个函数我们的闭包循环函数
return function ($stack, $pipe)
{
//而这里便是我们最开始例子中的return返回值，只不过刚开始的时候我们返回的是一个数字变量，这里变成了另一个闭包
return function () use ($stack, $pipe)
{
return $pipe::handle($stack);
};
};
}
这里的循环闭包返回值也是一个闭包，在不断的循环中，闭包函数就像洋葱一样，一层一层不断包裹。 如此类推，最终array_reduce返回一个匿名函数，这就像上面思维导图最终所描述的一样
function (){
return Request4::handle(function (){
return Request3::handle(function (){
return Request2::handle(function (){
return Reuqest1::handle(function (){
echo '请求处理中...' . "<br />";
});
});
});
});
}
所以当调用call_user_func时就是执行array_reduce返回的匿名函数，我们从各个请求处理类的handle方法也得知，会直接调用传入的匿名函数，注意顺序即可理解浏览器的输出。
与装饰者模式的关系
这里没有用到类来对实例对象进行包装，而是通过闭包函数完成，每一次处理在上一次处理之上进行包装，最后获得响应，就像流水线一样，一个请求进来通过一道道工序加工（包装）最后生成响应。
理解了这几个demo，那么laravel里中间件最重点的部分你就已经理解了。
最后，本文内容并非全部原创，部分图片与代码来源：http://blog.chenjunwu.cn/2017/05/02/Request-pipeline