1. 概念

    管道(pipeline)设计模式流水线模式就是将数据传递到一个任务序列中,管道扮演着流水线的角色,数据在这里被处理然后传递到下一个步骤

  2. 释义

    • 管道,顾名思义,就是一个长长的流水管道,只不过加了许多阀门。所以管道模式大致需要三个角色:管道、阀门、载荷(流水)。

    • 目的是在管道中对载荷进行一系列的处理。因为可以对过滤器进行动态的添加,所以对载荷的处理可以变得更加灵活。但同时带来的问题是,在过滤器过多时,很难把握整体的处理逻辑。而且在某一个过滤器对载荷处理后,因为载荷改变,会造成下一个过滤器中的逻辑出错。

<?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();