流水線設(shè)計(jì)模式

流水線設(shè)計(jì)模式對(duì)于順序處理業(yè)務(wù)數(shù)據(jù)非常有用，可以以一致的方式直觀的定義對(duì)數(shù)據(jù)的處理流程。

到目前為止，我已經(jīng)將 Golang 整合到項(xiàng)目中有一段時(shí)間了，Golang 是一種非常強(qiáng)大的語(yǔ)言，我渴望在其生態(tài)系統(tǒng)中進(jìn)一步磨練技能。

基于項(xiàng)目的特定需求，我需要實(shí)現(xiàn)流水線模式(Pipeline Pattern)，數(shù)據(jù)需要通過(guò)多個(gè)過(guò)濾器，以順序的方式進(jìn)行處理。讓我解釋一下:

假設(shè)我們有一個(gè)很長(zhǎng)的字符串。第一步是根據(jù)特定標(biāo)準(zhǔn)對(duì)其進(jìn)行解析。接下來(lái)，需要對(duì)解析后的數(shù)據(jù)進(jìn)行一些調(diào)整。隨后，將解析后的數(shù)據(jù)保存到數(shù)據(jù)庫(kù)中。正如你所見，有多個(gè)任務(wù)需要處理，而每個(gè)任務(wù)都是相互關(guān)聯(lián)的。

基礎(chǔ)流水線

在軟件開發(fā)中，可以用流水線設(shè)計(jì)模式(pipeline design pattern) 來(lái)管理這種場(chǎng)景，該模式是為順序處理對(duì)象修改而設(shè)計(jì)的。想象有一條裝配流水線，每個(gè)工位都是一段"管道(pipe)"，當(dāng)某個(gè)物體通過(guò)整個(gè)流水線后，就發(fā)生了變化。從本質(zhì)上講，流水線負(fù)責(zé)將值通過(guò)一系列可調(diào)用的"管道(pipe)"(無(wú)論是中間件、過(guò)濾器還是處理器)進(jìn)行順序傳遞。在將該值傳遞給序列中的后續(xù)管道之前，每個(gè)管道段都有可能改變?cè)撝怠Ｔ撃Ｊ皆谥T如請(qǐng)求處理、數(shù)據(jù)處理或轉(zhuǎn)換等場(chǎng)景中特別有用，提供了一種干凈、可維護(hù)和可測(cè)試的方法。

作為解決方案，我準(zhǔn)備了一個(gè)簡(jiǎn)單的 Golang 包，可以在處理流程中使用流水線模式，它建立在責(zé)任鏈(chain of responsibility, CoR) 設(shè)計(jì)模式之上，可以將其安裝到項(xiàng)目中并使用:

go get github.com/izniburak/pipeline-go

包安裝之后，可以做一個(gè)簡(jiǎn)單演示。首先需要一些新的結(jié)構(gòu)體，這些結(jié)構(gòu)體具有從PipeInterface實(shí)現(xiàn)的Handle方法。因?yàn)?pipeline 包需要多個(gè)流水線，所以我們用Handle方法來(lái)運(yùn)行每個(gè)流水線:

package main
import (
 "strings"
 "github.com/izniburak/pipeline-go"
)
type UpperCasePipe struct{}
func (u *UpperCasePipe) Handle(value pipeline.PipeValue, next pipeline.PipeNext) pipeline.PipeValue {
  // get value
  text := value.(string)
  capitalized := strings.ToUpper(text)
  return next(capitalized)
}
type TrimSpacePipe struct{}
func (t *TrimSpacePipe) Handle(value pipeline.PipeValue, next pipeline.PipeNext) pipeline.PipeValue {
  // get value
  text := value.(string)
  trimmed := strings.Trim(text, " ")
  return next(trimmed)
}

使用流水線

package main
import (
 "fmt"
 "strings"
 "github.com/izniburak/pipeline-go"
)
type UpperCasePipe struct{}
func (u *UpperCasePipe) Handle(value pipeline.PipeValue, next pipeline.PipeNext) pipeline.PipeValue {
  // get value
  text := value.(string)
  capitalized := strings.ToUpper(text)
  return next(capitalized)
}
type TrimSpacePipe struct{}
func (t *TrimSpacePipe) Handle(value pipeline.PipeValue, next pipeline.PipeNext) pipeline.PipeValue {
  // get value
  text := value.(string)
  trimmed := strings.Trim(text, " ")
  return next(trimmed)
}
func main() {
  text := "   buki.dev   "
  pipes := []pipeline.PipeInterface{
    new(UpperCasePipe),
    new(TrimSpacePipe),
  }
  result := pipeline.Send(text).Through(pipes).ThenReturn()
  fmt.Println(result) // BUKI.DEV
}

如你所見，我們使用了兩個(gè)不同的管道，分別是UpperCasePipe和TrimSpacePipe。輸入是 buki.dev ，兩邊都有空格，輸出是BUKI.DEV。

就是這樣。流水線非常有用，是吧？

可以在 GitHub 上查看 pipeline包

以上就是Golang 流水線設(shè)計(jì)模式實(shí)踐示例詳解的詳細(xì)內(nèi)容，更多關(guān)于Golang 流水線設(shè)計(jì)模式的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論