行为型设计模式—职责链模式

news/2024/12/22 13:09:08/

职责链模式:从名字可以拆分为 职责 和 链。即能为请求创建一条由多个处理器组成的链路,每个处理器各自负责自己的职责,相互之间没有耦合,完成自己任务后请求对象即传递到链路的下一个处理器进行处理。

如果在写好的执行函数里加上部分步骤,导致需要增加若干个if-else,因为整个流程耦合在一起,修改了以后我们就得把整个流程全测一遍。。 而职责链就是把步骤解耦为执行链条,从而消除牵一发而动全身的后果。(链表插入优点是遍历到前节点插入即可,不需要像顺序表一样移动之后所有元素)

在一些核心的业务中,应用职责链模式能够让我们无痛地扩展业务流程的步骤

实现责任链模式的对象最起码需要包含如下特性:

  • 成员属性

    • nextHandler: 下一个等待被调用的对象实例
  • 成员方法

    • SetNext: 把下一个对象的实例绑定到当前对象的nextHandler属性上;
    • Do: 当前对象业务逻辑入口,他是每个处理对象实现自己逻辑的地方;
    • Execute: 负责职责链上请求的处理和传递;它会调用当前对象的DonextHandler不为空则调用nextHandler.Do

SetNextExecute 这两个行为是每个 ConcreteHandler 都一样的,所以这两个可以交给抽象处理类型来实现,每个具体处理对象再继承抽象类型,即可减少重复操作。

以病人去医院看病这个处理流程为例提供一个具体示例。看病的具体流程如下:

挂号—>诊室看病—>收费处缴费—>药房拿药

利用责任链模式,实现这个流程中的每个步骤,且相互间不耦合,还支持向流程中增加步骤。

先实现职责链模式里的公共部分—即模式的接口和抽象类

type PatientHandler interface {Execute(*patient) errorSetNext(PatientHandler) PatientHandlerDo(*patient) error
}
// 充当抽象类型,实现公共方法,抽象方法不实现留给实现类自己实现
type Next struct {nextHandler PatientHandler
}func (n *Next) SetNext(handler PatientHandler) PatientHandler {n.nextHandler = handlerreturn handler
}func (n *Next) Execute(patient *patient) (err error) {// 调用不到外部类型的 Do 方法,所以 Next 不能实现 Do 方法if n.nextHandler != nil {if err = n.nextHandler.Do(patient); err != nil {return}return n.nextHandler.Execute(patient)}return
}

即使Next实现了Do方法,go语言中语法也不能达到在父类方法中调用子类方法的效果—即在例子里面用Next 类型的Execute方法调用不到外部实现类型的Do方法。

定义职责链要处理的请求,实现处理逻辑和请求传递的DoExecute方法的参数都是流程中要处理的请求。这里是医院接诊的流程,所以定义一个患者类作为流程的请求。

//流程中的请求类--患者
type patient struct {Name              stringRegistrationDone  boolDoctorCheckUpDone boolMedicineDone      boolPaymentDone       bool
}

按照挂号—>诊室看病—>收费处缴费—>药房拿药这个流程定义四个步骤的处理类,来分别实现每个环节的逻辑。

// Reception 挂号处处理器
type Reception struct {Next
}func (r *Reception) Do(p *patient) (err error) {if p.RegistrationDone {fmt.Println("Patient registration already done")return}fmt.Println("Reception registering patient")p.RegistrationDone = truereturn
}// Clinic 诊室处理器--用于医生给病人看病
type Clinic struct {Next
}func (d *Clinic) Do(p *patient) (err error) {if p.DoctorCheckUpDone {fmt.Println("Doctor checkup already done")return}fmt.Println("Doctor checking patient")p.DoctorCheckUpDone = truereturn
}// Cashier 收费处处理器
type Cashier struct {Next
}func (c *Cashier) Do(p *patient) (err error) {if p.PaymentDone {fmt.Println("Payment Done")return}fmt.Println("Cashier getting money from patient patient")p.PaymentDone = truereturn
}// Pharmacy 药房处理器
type Pharmacy struct {Next
}func (m *Pharmacy) Do (p *patient) (err error) {if p.MedicineDone {fmt.Println("Medicine already given to patient")return}fmt.Println("Pharmacy giving medicine to patient")p.MedicineDone = truereturn
}

Recepiton接诊挂号这个步骤提供的逻辑没有调用到,再定义StartHandler 类型,它不提供处理实现只是作为第一个Handler向下转发请求

// StartHandler 不做操作,作为第一个Handler向下转发请求
type StartHandler struct {Next
}// Do 空Handler的Do
func (h *StartHandler) Do(c *patient) (err error) {// 空Handler 这里什么也不做 只是载体 do nothing...return
}

这是Go 语法限制,公共方法Exeute并不能像面向对象那样先调用this.Do 再调用this.nextHandler.Do

把处理类串起来执行

func main() {patientHealthHandler := StartHandler{}//patient := &patient{Name: "abc"}// 设置病人看病的链路patientHealthHandler.SetNext(&Reception{}).// 挂号SetNext(&Clinic{}). // 诊室看病SetNext(&Cashier{}). // 收费处交钱SetNext(&Pharmacy{}) // 药房拿药//还可以扩展,比如中间加入化验科化验,图像科拍片等等// 执行上面设置好的业务流程if err := patientHealthHandler.Execute(patient); err != nil {// 异常fmt.Println("Fail | Error:" + err.Error())return}// 成功fmt.Println("Success")
}

职责链也可以设置中止条件,针对例子就是在Execute方法里加判断,一旦满足中止后就不再继续往链路的下级节点传递请求。

这也是职责链跟装饰器模式的一个区别,装饰器模式无法在增强实体的过程中停止,只能执行完整个装饰链路。

针对那些可能未来经常会变的核心业务流程,可以在设计初期就考虑使用职责链来实现,减轻未来流程不停迭代时不好扩展的痛点。

职责链模式与模板模式的区别在于,模板模式的业务流程通常是规定不变的,而职责链模式业务是可拓展的


http://www.ppmy.cn/news/1323291.html

相关文章

前端开发工程师面试总结

最新 1.webpack分包具体怎么配置的?分包有什么好处?https://www.webpackjs.com/plugins/split-chunks-plugin/ SplitChunksPlugin插件,设置optimization.splitChunks里面的各种属性,比如chunks: all或者async,minSize等&#xff…

C#/WPF 设置和启动Windows屏保程序

前言 我们平时电脑启动的屏保程序其本质也是应用程序,只是后缀名为.scr。所以我们只需要把应用程序后缀改为.scr,然后右键选择安装即可启动我们自己的屏保程序。 屏保注册表参数 设置电脑屏保参数,在个性化设置>锁屏界面>屏幕保护程序设…

ssl解码

https://www.kamailio.org/dokuwiki/doku.php/troubleshooting:tls 这篇文章说ssldump可以解码 但是实操起来往往不行 再请看这篇文章: https://osqa-ask.wireshark.org/questions/7886/ssl-decrypting-problem/ 还好我够机智, 改了下/etc/kamailio…

开源云真机平台-Sonic平台-python自定义脚本-config.json方式实现全局配置参数的读写操作

【主要功能】 config.json方式实现全局配置参数的读写操作 使用python实现以下功能: 1、使用将接口获取的变量值,写入到当前目录下的config文件中,如delayTime10; 2、读取当前目录下的config文件中,特定变量的值&…

10 STM32标准库函数 之 DMA控制器(DMA)所有函数的介绍及使用

10 STM32标准库函数 之 DMA控制器(DMA)所有函数的介绍及使用 1 DMA库函数预览1.1 函数 DMA_DeInit2.2 函数DMA_Init1.3 函数 DMA_StructInit1.4 函数DMA_Cmd1.5 函数DMA_ITConfig1.6 函 数 DMA_GetCurrDataCounte1.7 函数DMA_GetFlagStatus1.8 7.2.8函数…

数据结构(三)堆和哈希表

目录 哈希表和堆什么是哈希表 ?什么是堆 ?什么是图 ?案例一:使用python实现最小堆案例二 : 如何用Python通过哈希表的方式完成商品库存管理闯关题 (包含案例三:python实现哈希表) 本…

【JMeter】JMeter连OceanBase数据库

1、下载OB(OceanBase简称,下同),下载地址:https://www.oceanbase.com/softwarecenter-enterprise 2、将下载下来的jar包放到jmeter安装目录的 lib 目录下,或者打开JMeter客户端,在测试计划中引入…

使用python连接elasticsearch

有一个困惑了好久的问题,那就是从python里面连接elasticsearch总是报错。大致长这样 一开始我是看网上把es的安全功能关闭,也就是下面的内容,这个要进入到es的docker中去改config/elasticsearch.yml配置文件,但是这样改了以后kib…