Hello everyone, today I will introduce to you the Pipeline of the Laravel framework.
It is a very easy-to-use component that can make the structure of the code very clear. Laravel's middleware mechanism is implemented based on it.
Through Pipeline, APO programming can be easily implemented.
Official GIT address
https://github.com/illuminate/pipeline
The following code is a simplified version of my implementation:
class Pipeline
{
/**
* The method to call on each pipe
* @var string
*/
protected $method = 'handle';
/**
* The object being passed throw the pipeline
* @var mixed
*/
protected $passable;
/**
* The array of class pipes
* @var array
*/
protected $pipes = [];
/**
* Set the object being sent through the pipeline
*
* @param $passable
* @return $this
*/
public function send($passable)
{
$this->passable = $passable;
return $this;
}
/**
* Set the method to call on the pipes
* @param array $pipes
* @return $this
*/
public function through($pipes)
{
$this->pipes = $pipes;
return $this;
}
/**
* @param \Closure $destination
* @return mixed
*/
public function then(\Closure $destination)
{
$pipeline = array_reduce(array_reverse($this->pipes), $this->getSlice(), $destination);
return $pipeline($this->passable);
}
/**
* Get a Closure that represents a slice of the application onion
* @return \Closure
*/
protected function getSlice()
{
return function($stack, $pipe){
return function ($request) use ($stack, $pipe) {
return $pipe::{$this->method}($request, $stack);
};
};
}
}
The main logic of this type lies in the then and getSlice methods. Through array_reduce, generate an anonymous function that accepts one parameter, and then execute the call.
Simple usage example
class ALogic
{
public static function handle($data, \Clourse $next)
{
print "开始 A 逻辑";
$ret = $next($data);
print "结束 A 逻辑";
return $ret;
}
}
class BLogic
{
public static function handle($data, \Clourse $next)
{
print "开始 B 逻辑";
$ret = $next($data);
print "结束 B 逻辑";
return $ret;
}
}
class CLogic
{
public static function handle($data, \Clourse $next)
{
print "开始 C 逻辑";
$ret = $next($data);
print "结束 C 逻辑";
return $ret;
}
}
$pipes = [
ALogic::class,
BLogic::class,
CLogic::class
];
$data = "any things";
(new Pipeline())->send($data)->through($pipes)->then(function($data){ print $data;});
Running result:
"开始 A 逻辑" "开始 B 逻辑" "开始 C 逻辑" "any things" "结束 C 逻辑" "结束 B 逻辑" "结束 A 逻辑"
AOP example
The advantage of AOP is that it can dynamically add functions without affecting other layers. , you can add or delete functions very conveniently.
class IpCheck
{
public static function handle($data, \Clourse $next)
{
if ("IP invalid") { // IP 不合法
throw Exception("ip invalid");
}
return $next($data);
}
}
class StatusManage
{
public static function handle($data, \Clourse $next)
{
// exec 可以执行初始化状态的操作
$ret = $next($data)
// exec 可以执行保存状态信息的操作
return $ret;
}
}
$pipes = [
IpCheck::class,
StatusManage::class,
];
(new Pipeline())->send($data)->through($pipes)->then(function($data){ "执行其它逻辑";});
