-
概念
管道(pipeline)设计模式流水线模式就是将数据传递到一个任务序列中,管道扮演着流水线的角色,数据在这里被处理然后传递到下一个步骤
-
释义
-
管道,顾名思义,就是一个长长的流水管道,只不过加了许多阀门。所以管道模式大致需要三个角色:管道、阀门、载荷(流水)。
-
目的是在管道中对载荷进行一系列的处理。因为可以对过滤器进行动态的添加,所以对载荷的处理可以变得更加灵活。但同时带来的问题是,在过滤器过多时,很难把握整体的处理逻辑。而且在某一个过滤器对载荷处理后,因为载荷改变,会造成下一个过滤器中的逻辑出错。
-
<?php
//管道接口
interface PipelineBuilder
{
public function __construct($payload); //$payload载荷
public function pipe(StageBuilder $stage); //管道与阀门
public function process(); //过程
}
//实现管道接口
class Pipeline implements PipelineBuilder
{
protected $payload;
protected $pipes = [];
public function __construct($payload)
{
$this->payload = $payload;
}
public function pipe(StageBuilder $stage)
{
$this->pipes[] = $stage;
return $this;
}
public function process()
{
foreach ($this->pipes as $pipe) {
call_user_func([$pipe, 'handle'], $this->payload);
}
}
}
//阀门类
interface StageBuilder
{
public function handle($payload);
}
//实现
class StageOneBuilder implements StageBuilder
{
public function handle($payload)
{
echo 'one-';
}
}
class StageTwoBuilder implements StageBuilder
{
public function handle($payload)
{
echo 'two-';
}
}
//客户端使用
$pipeline = new PipeLine('step');
$pipeline->pipe(new StageOneBuilder())->pipe(new StageTwoBuilder())->process();