管道模式

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