到目前为止，我已经将Golang整合到项目中有一段时间了，Golang是一种非常强大的语言，我渴望在其生态系统中进一步磨练技能。
基于项目的特定需求，我需要实现流水线模式(Pipeline Pattern)，数据需要通过多个过滤器，以顺序的方式进行处理。让我解释一下:
假设我们有一个很长的字符串。第一步是根据特定标准对其进行解析。接下来，需要对解析后的数据进行一些调整。随后，将解析后的数据保存到数据库中。正如你所见，有多个任务需要处理，而每个任务都是相互关联的。
基础流水线
在软件开发中，可以用流水线设计模式(pipeline design pattern) 来管理这种场景，该模式是为顺序处理对象修改而设计的。想象有一条装配流水线，每个工位都是一段"管道(pipe)"，当某个物体通过整个流水线后，就发生了变化。从本质上讲，流水线负责将值通过一系列可调用的"管道(pipe)"(无论是中间件、过滤器还是处理器)进行顺序传递。在将该值传递给序列中的后续管道之前，每个管道段都有可能改变该值。该模式在诸如请求处理、数据处理或转换等场景中特别有用，提供了一种干净、可维护和可测试的方法。
作为解决方案，我准备了一个简单的Golang包，可以在处理流程中使用流水线模式，它建立在责任链(chain of responsibility, CoR) 设计模式之上，可以将其安装到项目中并使用：
gogetgithub.com/izniburak/pipeline-go
包安装之后，可以做一个简单演示。首先需要一些新的结构体，这些结构体具有从PipeInterface实现的Handle方法。因为pipeline包需要多个流水线，所以我们用Handle方法来运行每个流水线:
packagemainimport("strings""github.com/izniburak/pipeline-go")type UpperCasePipe struct{}func(u*UpperCasePipe)Handle(value pipeline.PipeValue,next pipeline.PipeNext)pipeline.PipeValue{// get valuetext:=value.(string)capitalized:=strings.ToUpper(text)returnnext(capitalized)}type TrimSpacePipe struct{}func(t*TrimSpacePipe)Handle(value pipeline.PipeValue,next pipeline.PipeNext)pipeline.PipeValue{// get valuetext:=value.(string)trimmed:=strings.Trim(text," ")returnnext(trimmed)}
然后可以开始使用流水线:
packagemainimport("fmt""strings""github.com/izniburak/pipeline-go")type UpperCasePipe struct{}func(u*UpperCasePipe)Handle(value pipeline.PipeValue,next pipeline.PipeNext)pipeline.PipeValue{// get valuetext:=value.(string)capitalized:=strings.ToUpper(text)returnnext(capitalized)}type TrimSpacePipe struct{}func(t*TrimSpacePipe)Handle(value pipeline.PipeValue,next pipeline.PipeNext)pipeline.PipeValue{// get valuetext:=value.(string)trimmed:=strings.Trim(text," ")returnnext(trimmed)}funcmain(){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]。
参考资料：
[1]Using a Pipeline Pattern in Golang: https://tech.jotform.com/pipeline-go-pipeline-pattern-in-golang-5a51e5d811a
[2]pipeline-go: https://github.com/izniburak/pipeline-go