到目前為止,我已經(jīng)將Golang整合到項目中有一段時間了,Golang是一種非常強(qiáng)大的語言,我渴望在其生態(tài)系統(tǒng)中進(jìn)一步磨練技能。
基于項目的特定需求,我需要實現(xiàn)流水線模式(Pipeline Pattern),數(shù)據(jù)需要通過多個過濾器,以順序的方式進(jìn)行處理。讓我解釋一下:
假設(shè)我們有一個很長的字符串。第一步是根據(jù)特定標(biāo)準(zhǔn)對其進(jìn)行解析。接下來,需要對解析后的數(shù)據(jù)進(jìn)行一些調(diào)整。隨后,將解析后的數(shù)據(jù)保存到數(shù)據(jù)庫中。正如你所見,有多個任務(wù)需要處理,而每個任務(wù)都是相互關(guān)聯(lián)的。
基礎(chǔ)流水線
在軟件開發(fā)中,可以用流水線設(shè)計模式(pipeline design pattern) 來管理這種場景,該模式是為順序處理對象修改而設(shè)計的。想象有一條裝配流水線,每個工位都是一段"管道(pipe)",當(dāng)某個物體通過整個流水線后,就發(fā)生了變化。從本質(zhì)上講,流水線負(fù)責(zé)將值通過一系列可調(diào)用的"管道(pipe)"(無論是中間件、過濾器還是處理器)進(jìn)行順序傳遞。在將該值傳遞給序列中的后續(xù)管道之前,每個管道段都有可能改變該值。該模式在諸如請求處理、數(shù)據(jù)處理或轉(zhuǎn)換等場景中特別有用,提供了一種干凈、可維護(hù)和可測試的方法。
作為解決方案,我準(zhǔn)備了一個簡單的Golang包,可以在處理流程中使用流水線模式,它建立在責(zé)任鏈(chain of responsibility, CoR) 設(shè)計模式之上,可以將其安裝到項目中并使用:
go get github.com/izniburak/pipeline-go
包安裝之后,可以做一個簡單演示。首先需要一些新的結(jié)構(gòu)體,這些結(jié)構(gòu)體具有從PipeInterface實現(xiàn)的Handle方法。因為pipeline包需要多個流水線,所以我們用Handle方法來運(yùn)行每個流水線:
package mainimport ( "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 mainimport ( "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}
如你所見,我們使用了兩個不同的管道,分別是UpperCasePipe和TrimSpacePipe。輸入是 buki.dev ,兩邊都有空格,輸出是BUKI.DEV。
就是這樣。流水線非常有用,是吧?
可以在GitHub上查看pipeline包[2]。
參考資料:
本文鏈接:http://www.www897cc.com/showinfo-26-57888-0.htmlGolang流水線設(shè)計模式實踐
聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。郵件:2376512515@qq.com
上一篇: 什么是Helm?它是如何提升云原生應(yīng)用私有化部署效率的
下一篇: 十個Java編程中記錄日志的小技巧