管道模式

发表于 更新于

  1. 概念

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

  2. 释义

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

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
<?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();