Golang 流水线设计模式实践

作者：俞凡

2023-11-26
上海
本文字数：1663 字
阅读完需：约 5 分钟

流水线设计模式对于顺序处理业务数据非常有用，可以以一致的方式直观的定义对数据的处理流程。原文: Using a Pipeline Pattern in Golang

到目前为止，我已经将 Golang 整合到项目中有一段时间了，Golang 是一种非常强大的语言，我渴望在其生态系统中进一步磨练技能。

基于项目的特定需求，我需要实现流水线模式(Pipeline Pattern)，数据需要通过多个过滤器，以顺序的方式进行处理。让我解释一下:

假设我们有一个很长的字符串。第一步是根据特定标准对其进行解析。接下来，需要对解析后的数据进行一些调整。随后，将解析后的数据保存到数据库中。正如你所见，有多个任务需要处理，而每个任务都是相互关联的。

基础流水线

在软件开发中，可以用流水线设计模式(pipeline design pattern) 来管理这种场景，该模式是为顺序处理对象修改而设计的。想象有一条装配流水线，每个工位都是一段"管道(pipe)"，当某个物体通过整个流水线后，就发生了变化。从本质上讲，流水线负责将值通过一系列可调用的"管道(pipe)"(无论是中间件、过滤器还是处理器)进行顺序传递。在将该值传递给序列中的后续管道之前，每个管道段都有可能改变该值。该模式在诸如请求处理、数据处理或转换等场景中特别有用，提供了一种干净、可维护和可测试的方法。

作为解决方案，我准备了一个简单的 Golang 包，可以在处理流程中使用流水线模式，它建立在责任链(chain of responsibility, CoR) 设计模式之上，可以将其安装到项目中并使用:

go get github.com/izniburak/pipeline-go

复制代码

包安装之后，可以做一个简单演示。首先需要一些新的结构体，这些结构体具有从PipeInterface实现的Handle方法。因为 pipeline 包需要多个流水线，所以我们用Handle方法来运行每个流水线:

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}

复制代码

如你所见，我们使用了两个不同的管道，分别是UpperCasePipe和TrimSpacePipe。输入是 buki.dev ，两边都有空格，输出是BUKI.DEV。

就是这样。流水线非常有用，是吧？

可以在 GitHub 上查看pipeline包。

你好，我是俞凡，在 Motorola 做过研发，现在在 Mavenir 做技术工作，对通信、网络、后端架构、云原生、DevOps、CICD、区块链、AI 等技术始终保持着浓厚的兴趣，平时喜欢阅读、思考，相信持续学习、终身成长，欢迎一起交流学习。为了方便大家以后能第一时间看到文章，请朋友们关注公众号"DeepNoMind"，并设个星标吧，如果能一键三连(转发、点赞、在看)，则能给我带来更多的支持和动力，激励我持续写下去，和大家共同成长进步！

发布于: 刚刚阅读数: 3

原文链接:【http://xie.infoq.cn/article/b06275a046776540087c5ed2c】。

俞凡

关注

公众号：DeepNoMind 2017-10-18 加入

俞凡，Mavenir Systems研发总监，关注高可用架构、高性能服务、5G、人工智能、区块链、DevOps、Agile等。公众号：DeepNoMind

发布

暂无评论

创作场景

Golang 流水线设计模式实践

俞凡

评论