前言
在一個(gè)比較復(fù)雜的大型系統(tǒng)中，假如存在某個(gè)對(duì)象或數(shù)據(jù)流需要被進(jìn)行繁雜的邏輯處理的話(huà)，我們可以選擇在一個(gè)大的組件中進(jìn)行這些繁雜的邏輯處理，這種方式確實(shí)達(dá)到了目的，但卻是簡(jiǎn)單粗暴的。或許在某些情況這種簡(jiǎn)單粗暴的方式將帶來(lái)一些麻煩，例如我要改動(dòng)其中某部分處理邏輯、我要添加一些處理邏輯到流程、我要在流程中減少一些處理邏輯時(shí)，這里有些看似簡(jiǎn)單的改動(dòng)都讓我們無(wú)從下手，除了對(duì)整個(gè)組件進(jìn)行改動(dòng)。整個(gè)系統(tǒng)看起來(lái)沒(méi)有任何可擴(kuò)展性和可重用性。
是否有一種模式可以將整個(gè)處理流程進(jìn)行詳細(xì)劃分，劃分出的每個(gè)小模塊互相獨(dú)立且各自負(fù)責(zé)一段邏輯處理，這些邏輯處理小模塊根據(jù)順序連起來(lái)，前以模塊的輸出作為后一模塊的輸入，最后一個(gè)模塊的輸出為最終的處理結(jié)果。如此一來(lái)修改邏輯時(shí)只針對(duì)某個(gè)模塊修改，添加或減少處理邏輯也可細(xì)化到某個(gè)模塊顆粒度，并且每個(gè)模塊可重復(fù)利用，可重用性大大增強(qiáng)。這種模式就是此章節(jié)要進(jìn)行討論的管道模式。
顧名思義，管道模式就像一條管道把多個(gè)對(duì)象連接起來(lái)，整體看起來(lái)就像若干個(gè)閥門(mén)嵌套在管道中，而處理邏輯就放在閥門(mén)上，如下圖，需要處理的對(duì)象進(jìn)入管道后，分別經(jīng)過(guò)閥門(mén)一、閥門(mén)二、閥門(mén)三、閥門(mén)四，每個(gè)閥門(mén)都會(huì)對(duì)進(jìn)入的對(duì)象進(jìn)行一些邏輯處理，經(jīng)過(guò)一層層的處理后從管道尾處理，此時(shí)的對(duì)象就是已完成處理的目標(biāo)對(duì)象。
既然管道模式這么有用，我們希望能在程序中適當(dāng)?shù)乜紤]使用，為了實(shí)現(xiàn)此模式需要多個(gè)對(duì)象協(xié)作，可參考如下類(lèi)圖，valve接口定義了閥門(mén)的調(diào)用方法，由于閥門(mén)與閥門(mén)使用單鏈表結(jié)構(gòu)連接所以需提供對(duì)next的操作，實(shí)現(xiàn)一個(gè)閥門(mén)對(duì)其進(jìn)行擴(kuò)展即可；pipeline接口定義了管道操作閥門(mén)的方法，包括獲取第一個(gè)閥門(mén)、獲取基礎(chǔ)閥門(mén)、添加閥門(mén)等方法，管道需對(duì)其擴(kuò)展。
往下看如何簡(jiǎn)單實(shí)現(xiàn)一個(gè)管道模式：
① 閥門(mén)接口
|
1
2
3
4
5
|
public interface valve { public valve getnext(); public void setnext(valve valve); public void invoke(string handling);} |
② 管道接口
|
1
2
3
4
5
6
|
public interface pipeline {public valve getfirst();public valve getbasic();public void setbasic(valve valve);public void addvalve(valve valve);} |
③ 基礎(chǔ)閥門(mén)，處理邏輯僅僅是簡(jiǎn)單的將傳入的字符串中”aa”替換成”bb”
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public class basicvalve implements valve {protected valve next = null; public valve getnext() {return next;}public void invoke(string handling) { handling=handling.replaceall("aa", "bb");system.out.println("基礎(chǔ)閥門(mén)處理完后：" + handling);}public void setnext(valve valve) {this.next = valve;}} |
④ 第二個(gè)閥門(mén)，將傳入的字符串中”11”替換成”22”
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
public class secondvalve implements valve {protected valve next = null; public valve getnext() {return next;}public void invoke(string handling) {handling = handling.replaceall("11", "22");system.out.println("second閥門(mén)處理完后：" + handling);getnext().invoke(handling);}public void setnext(valve valve) {this.next = valve;}} |
⑤ 第三個(gè)閥門(mén)，將傳入的字符串中”zz”替換成”yy”
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
public class thirdvalve implements valve {protected valve next = null; public valve getnext() {return next;}public void invoke(string handling) {handling = handling.replaceall("zz", "yy");system.out.println("third閥門(mén)處理完后：" + handling);getnext().invoke(handling);}public void setnext(valve valve) {this.next = valve;}} |
⑥ 管道，我們一般的操作是先通過(guò)setbasic設(shè)置基礎(chǔ)閥門(mén)，接著按順序添加其他閥門(mén)，執(zhí)行時(shí)的順序是：先添加進(jìn)來(lái)的先執(zhí)行，最后才執(zhí)行基礎(chǔ)閥門(mén)。
|
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
|
public class standardpipeline implements pipeline {protected valve first = null; protected valve basic = null; public void addvalve(valve valve) {if (first == null) {first = valve;valve.setnext(basic);} else {valve current = first;while (current != null) {if (current.getnext() == basic) {current.setnext(valve);valve.setnext(basic);break;}current = current.getnext();}}}public valve getbasic() {return basic;}public valve getfirst() {return first;}public void setbasic(valve valve) {this.basic = valve;}} |
⑦ 測(cè)試類(lèi)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public class main {public static void main(string[] args) {string handling="aabb1122zzyy";standardpipeline pipeline = new standardpipeline();basicvalve basicvalve = new basicvalve();secondvalve secondvalve = new secondvalve();thirdvalve thirdvalve = new thirdvalve();pipeline.setbasic(basicvalve);pipeline.addvalve(secondvalve);pipeline.addvalve(thirdvalve);pipeline.getfirst().invoke(handling);}} |
輸出的結(jié)果如下：
|
1
2
3
|
second閥門(mén)處理完后：aabb2222zzyythird閥門(mén)處理完后：aabb2222yyyy基礎(chǔ)閥門(mén)處理完后：bbbb2222yyyy |
這就是管道模式，在管道中連接一個(gè)或多個(gè)閥門(mén)，每個(gè)閥門(mén)負(fù)責(zé)一部分邏輯處理，數(shù)據(jù)按規(guī)定的順序往下流。此模式分解了邏輯處理任務(wù)，可方便對(duì)某任務(wù)單元進(jìn)行安裝拆卸，提高了流程的可擴(kuò)展性、可重用性、機(jī)動(dòng)性、靈活性。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/wangyangzhizhou/article/details/45441355
