【Go实现】实践GoF的23种设计模式:桥接模式

2024-04-13 13:36

本文主要是介绍【Go实现】实践GoF的23种设计模式:桥接模式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

上一篇:【Go实现】实践GoF的23种设计模式:解释器模式

简单的分布式应用系统(示例代码工程):https://github.com/ruanrunxue/Practice-Design-Pattern–Go-Implementation

简介

GoF 对桥接模式(Bridge Pattern)的定义如下:

Decouple an abstraction from its implementation so that the two can vary independently.

也即,将抽象部分和实现部分进行解耦,使得它们能够各自往独立的方向变化

桥接模式解决了在模块有多种变化方向的情况下,用继承所导致的类爆炸问题。

举个例子,一个产品有形状和颜色两个特征(变化方向),其中形状分为方形和圆形,颜色分为红色和蓝色。如果采用继承的设计方案,那么就需要新增4个产品子类:方形红色、圆形红色、方形蓝色、圆形红色。如果形状总共有 m 种变化,颜色有 n 种变化,那么就需要新增 m * n 个产品子类!

现在我们使用桥接模式进行优化,将形状和颜色分别设计为抽象接口独立出来,这样需要新增 2 个形状子类:方形和圆形,以及 2 个颜色子类:红色和蓝色。同样,如果形状总共有 m 种变化,颜色有 n 种变化,总共只需要新增 m + n 个子类!

上述例子中,我们通过将形状和颜色抽象为一个接口,使产品不再依赖于具体的形状和颜色细节,从而达到了解耦的目的。桥接模式本质上就是面向接口编程,可以给系统带来很好的灵活性和可扩展性。如果一个对象存在多个变化的方向,而且每个变化方向都需要扩展,那么使用桥接模式进行设计那是再合适不过了。

当然,Go 语言从语言特性本身就把继承剔除,但桥接模式中分离变化、面向接口编程的思想仍然值得学习。

UML 结构

场景上下文

在 简单的分布式应用系统(示例代码工程)中,我们设计了一个 Monitor 监控系统模块,它可以看成是一个简单的 ETL 系统,负责对监控数据进行采集、处理、输出。监控数据来源于在线商场服务集群各个服务,当前通过消息队列模块 Mq 传递到监控系统,经处理后,存储到数据库模块 Db 上。

我们假设未来要上线一个不支持对接消息队列的服务、结果数据也需要存储到 ClickHouse 以供后续分析,为了应对未来多变的需求,我们有必要将监控系统设计得足够的可扩展。

于是,整个模块被设计为插件化风格的架构,Pipeline 是数据处理的流水线,其中包含了 InputFilterOutput 三类插件,Input 负责从各类数据源中获取监控数据,Filter 负责数据处理,Output 负责将处理后的数据输出。

上述设计中,我们抽象出 InputFilterOutput 三类插件,它们各种往独立的方向变化,最后在 Pipeline 上进行灵活组合,这使用桥接模式正合适。

代码实现

// 关键点1:明确产品的变化点,这里是input、filter和output三类插件,它们各自变化// demo/monitor/input/input_plugin.go
package input// 关键点2:将产品的变化点抽象成接口,这里是input.Plugin,filter.Plugin和output.Plugin
// Plugin 输入插件
type Plugin interface {plugin.PluginInput() (*plugin.Event, error)
}// 关键点3:实现产品变化点的接口,这里是SocketInput, AddTimestampFilter和MemoryDbOutput
// demo/monitor/input/socket_input.go
type SocketInput struct {socket      network.Socketendpoint    network.Endpointpackets     chan *network.PacketisUninstall uint32
}func (s *SocketInput) Input() (*plugin.Event, error) {packet, ok := <-s.packetsif !ok {return nil, plugin.ErrPluginUninstalled}event := plugin.NewEvent(packet.Payload())event.AddHeader("peer", packet.Src().String())return event, nil
}// demo/monitor/filter/filter_plugin.go
package filter// Plugin 过滤插件
type Plugin interface {plugin.PluginFilter(event *plugin.Event) *plugin.Event
}// demo/monitor/filter/add_timestamp_filter.go
// AddTimestampFilter 为MonitorRecord增加时间戳
type AddTimestampFilter struct {
}func (a *AddTimestampFilter) Filter(event *plugin.Event) *plugin.Event {re, ok := event.Payload().(*model.MonitorRecord)if !ok {return event}re.Timestamp = time.Now().Unix()return plugin.NewEvent(re)
}// demo/monitor/output/output_plugin.go
// Plugin 输出插件
type Plugin interface {plugin.PluginOutput(event *plugin.Event) error
}// demo/monitor/output/memory_db_output.go
type MemoryDbOutput struct {db        db.DbtableName string
}func (m *MemoryDbOutput) Output(event *plugin.Event) error {r, ok := event.Payload().(*model.MonitorRecord)if !ok {return fmt.Errorf("memory db output unknown event type %T", event.Payload())}return m.db.Insert(m.tableName, r.Id, r)
}// 关键点4:定义产品的接口或者实现,通过组合的方式把变化点桥接起来。
// demo/monitor/pipeline/pipeline_plugin.go
// Plugin pipeline由input、filter、output三种插件组成,定义了一个数据处理流程
// 数据流向为 input -> filter -> output
// 如果是接口,可以通过定义Setter方法达到聚合的目的。
type Plugin interface {plugin.PluginSetInput(input input.Plugin)SetFilter(filter filter.Plugin)SetOutput(output output.Plugin)
}// 如果是结构体,直接把变化点作为成员变量来达到聚合的目的。
type pipelineTemplate struct {input   input.Pluginfilter  filter.Pluginoutput  output.PluginisClose uint32run     func()
}func (p *pipelineTemplate) SetInput(input input.Plugin) {p.input = input
}func (p *pipelineTemplate) SetFilter(filter filter.Plugin) {p.filter = filter
}func (p *pipelineTemplate) SetOutput(output output.Plugin) {p.output = output
}// demo/monitor/pipeline/simple_pipeline.go
// SimplePipeline 简单Pipeline实现,每次运行时新启一个goroutine
type SimplePipeline struct {pipelineTemplate
}

在本系统中,我们通过配置文件来灵活组合插件,利用反射来实现插件的实例化,实例化的实现使用了抽象工厂模式,详细的实现方法可参考【Go实现】实践GoF的23种设计模式:抽象工厂模式。

总结实现桥接模式的几个关键点:

  1. 明确产品的变化点,这里是 input、filter 和 output 三类插件,它们各自变化。
  2. 将产品的变化点抽象成接口,这里是 input.Pluginfilter.Pluginoutput.Plugin
  3. 实现产品变化点的接口,这里是 SocketInput, AddTimestampFilterMemoryDbOutput
  4. 定义产品的接口或者实现,通过组合的方式把变化点桥接起来。这里是 pipeline.Plugin 通过 Setter 方法将input.Pluginfilter.Pluginoutput.Plugin 三个抽象接口桥接了起来。后面即可实现各类 input、filter 和 output 的灵活组合了。

扩展

TiDB 中的桥接模式

TiDB 是一款出色的分布式关系型数据库,它对外提供了一套插件框架,方便用户进行功能扩展。TiDB 的插件框架的设计,也运用到了桥接模式的思想。

如上图所示,每个 Plugin 都包含 ValidateOnInitOnShutdownOnFlush 四个待用户实现的接口,它们可以按照各自的方向去变化,然后灵活组合在 Plugin 中。

// Plugin presents a TiDB plugin.
type Plugin struct {*Manifestlibrary  *gplugin.PluginPath     stringDisabled uint32State    State
}// Manifest describes plugin info and how it can do by plugin itself.
type Manifest struct {Name           stringDescription    stringRequireVersion map[string]uint16License        stringBuildTime      string// Validate defines the validate logic for plugin.// returns error will stop load plugin process and TiDB startup.Validate func(ctx context.Context, manifest *Manifest) error// OnInit defines the plugin init logic.// it will be called after domain init.// return error will stop load plugin process and TiDB startup.OnInit func(ctx context.Context, manifest *Manifest) error// OnShutDown defines the plugin cleanup logic.// return error will write log and continue shutdown.OnShutdown func(ctx context.Context, manifest *Manifest) error// OnFlush defines flush logic after executed `flush tidb plugins`.// it will be called after OnInit.// return error will write log and continue watch following flush.OnFlush      func(ctx context.Context, manifest *Manifest) errorflushWatcher *flushWatcherVersion uint16Kind    Kind
}

TiDB 在实现插件框架时,使用函数式编程的方式来定义 OnXXX 接口,更具有 Go 风格。

典型应用场景

  • 从多个维度上对系统/类/结构体进行扩展,如插件化架构。
  • 在运行时切换不同的实现,如插件化架构。
  • 用于构建与平台无关的程序适配层。

优缺点

优点

  • 可实现抽象不分与实现解耦,变化实现时,客户端无须修改代码,符合开闭原则。
  • 每个分离的变化点都可以专注于自身的演进,符合单一职责原则。

缺点

  • 过度的抽象(过度设计)会使得接口膨胀,导致系统复杂性变大,难以维护。

与其他模式的关联

桥接模式通常与抽象工厂模式搭配使用,比如,在本文例子中,可以通过抽象工厂模式对各个 Plugin 完成实例化,详情见【Go实现】实践GoF的23种设计模式:抽象工厂模式。

文章配图

可以在 用Keynote画出手绘风格的配图 中找到文章的绘图方法。

参考

[1] 【Go实现】实践GoF的23种设计模式:SOLID原则, 元闰子

[2] Design Patterns, Chapter 4. Structural Patterns, GoF

[3] 【Go实现】实践GoF的23种设计模式:抽象工厂模式, 元闰子

[4] 桥接模式, refactoringguru.cn

更多文章请关注微信公众号:元闰子的邀请

这篇关于【Go实现】实践GoF的23种设计模式:桥接模式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/900284

相关文章

c++ 类成员变量默认初始值的实现

《c++类成员变量默认初始值的实现》本文主要介绍了c++类成员变量默认初始值,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录C++类成员变量初始化c++类的变量的初始化在C++中,如果使用类成员变量时未给定其初始值,那么它将被

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表(即列表中包含列表)转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola

go中的时间处理过程

《go中的时间处理过程》:本文主要介绍go中的时间处理过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1 获取当前时间2 获取当前时间戳3 获取当前时间的字符串格式4 相互转化4.1 时间戳转时间字符串 (int64 > string)4.2 时间字符串转时间