实践GoF的23种设计模式:命令模式

实践,gof,设计模式,命令,模式 · 浏览次数 : 125

小编点评

**Go 命令模式** Go 标准库中的 exec.Cmd、http.Client 都属于该类型,将请求封装成命令来执行。 **优点** * 命令模式下,每个命令都是职责单一、松耦合的。 * 可以很方便地实现操作的延迟执行、回滚、重做等。 **缺点** * 命令模式下,调用往往是异步的,而异步会导致系统变得复杂,问题出现时不好定位解决。 * 命令模式下,代码会变得更难维护。 **与其他模式的关联** * 命令模式 也常常和观察者模式 一起出现,比如在 CQRS 架构中,当命令端更新数据库后,写数据库就会通过事件将数据同步到读数据库上,这里就用到了观察者模式。

正文

摘要:命令模式可将请求转换为一个包含与请求相关的所有信息的对象, 它能将请求参数化、延迟执行、实现 Undo / Redo 操作等。

本文分享自华为云社区《【Go实现】实践GoF的23种设计模式:命令模式》,作者:元闰子。

简介

现在的软件系统往往是分层设计。在业务层执行一次请求时,我们很清楚请求的上下文,包括,请求是做什么的、参数有哪些、请求的接收者是谁、返回值是怎样的。相反,基础设施层并不需要完全清楚业务上下文,它只需知道请求的接收者是谁即可,否则就耦合过深了。

因此,我们需要对请求进行抽象,将上下文信息封装到请求对象里,这其实就是命令模式,而该请求对象就是 Command。

GoF 对命令模式(Command Pattern)的定义如下:

Encapsulate a request as an object, thereby letting you parameterize clients with different requests, queue or log requests, and support undoable operations.

也即,命令模式可将请求转换为一个包含与请求相关的所有信息的对象, 它能将请求参数化、延迟执行、实现 Undo / Redo 操作等。

上述的请求是广义上的概念,可以是网络请求,也可以是函数调用,更通用地,指一个动作。

命令模式主要包含 3 种角色:

  1. Command,命令,是对请求的抽象。具体的命令实现时,通常会引用 Receiver。
  2. Invoker,请求的发起发起方,它并不清楚 Command 和 Receiver 的实现细节,只管调用命令的接口。
  3. Receiver,请求的接收方。

命令模式,一方面,能够使得 Invoker 与 Receiver 消除彼此之间的耦合,让对象之间的调用关系更加灵活;另一方面,能够很方便地实现延迟执行、Undo、Redo 等操作,因此被广泛应用在软件设计中。

UML 结构

场景上下文

在 简单的分布式应用系统(示例代码工程)中,db 模块用来存储服务注册信息和系统监控数据。其中,服务注册信息拆成了 profiles 和 regions 两个表,在服务发现的业务逻辑中,通常需要同时操作两个表,为了避免两个表数据不一致的问题,db 模块需要提供事务功能:

事务的核心功能之一是,当其中某个语句执行失败时,之前已执行成功的语句能够回滚,而使用命令模式能够很方便地实现该功能。

代码实现

// demo/db/transaction.go
package db
// Command 执行数据库操作的命令接口
// 关键点1: 定义命令抽象接口
type Command interface {
 // 关键点2: 命令抽象接口中声明执行命令的方法
 Exec() error // Exec 执行insert、update、delete命令
 // 关键点3: 如果有撤销功能,则需要定义Undo方法
 Undo() // Undo 回滚命令
 setDb(db Db) // SetDb 设置关联的数据库
}
// Transaction Db事务实现,事务接口的调用顺序为begin -> exec -> exec > ... -> commit
// 关键点4: 定义Invoker对象
type Transaction struct {
    name string
 db   Db
 // 关键点5: Invoker对象持有Command的引用
 cmds []Command
}
// Begin 开启一个事务
func (t *Transaction) Begin() {
 t.cmds = make([]Command, 0)
}
// Exec 在事务中执行命令,先缓存到cmds队列中,等commit时再执行
func (t *Transaction) Exec(cmd Command) error {
 if t.cmds == nil {
 return ErrTransactionNotBegin
 }
 cmd.setDb(t.db)
 t.cmds = append(t.cmds, cmd)
 return nil
}
// Commit 提交事务,执行队列中的命令,如果有命令失败,则回滚后返回错误
// 关键点6: 为Invoker对象定义Call方法,在方法内调用Command的执行方法Exec
func (t *Transaction) Commit() error {
 history := &cmdHistory{history: make([]Command, 0, len(t.cmds))}
 for _, cmd := range t.cmds {
 if err := cmd.Exec(); err != nil {
 history.rollback()
 return err
 }
 history.add(cmd)
 }
 return nil
}
// cmdHistory 命令执行历史
type cmdHistory struct {
    history []Command
}
func (c *cmdHistory) add(cmd Command) {
 c.history = append(c.history, cmd)
}
// 关键点7: 在回滚方法中,调用已执行命令的Undo方法
func (c *cmdHistory) rollback() {
 for i := len(c.history) - 1; i >= 0; i-- {
 c.history[i].Undo()
 }
}
// InsertCmd 插入命令
// 关键点8: 定义具体的命令类,实现Command接口
type InsertCmd struct {
 // 关键点9: 命令通常持有接收者的引用,以便在执行方法中与接收者交互
 db         Db
 tableName string
 primaryKey interface{}
 newRecord interface{}
}
// 关键点10: 命令对象执行方法中,调用Receiver的Action方法,这里的Receiver为db对象,Action方法为Insert方法
func (i *InsertCmd) Exec() error {
 return i.db.Insert(i.tableName, i.primaryKey, i.newRecord)
}
func (i *InsertCmd) Undo() {
 i.db.Delete(i.tableName, i.primaryKey)
}
func (i *InsertCmd) setDb(db Db) {
 i.db = db
}
// UpdateCmd 更新命令
type UpdateCmd struct {...}
// DeleteCmd 删除命令
type DeleteCmd struct {...}

客户端可以这么使用:

func client() {
 transaction := db.CreateTransaction("register" + profile.Id)
 transaction.Begin()
 rcmd := db.NewUpdateCmd(regionTable).WithPrimaryKey(profile.Region.Id).WithRecord(profile.Region)
 transaction.Exec(rcmd)
 pcmd := db.NewUpdateCmd(profileTable).WithPrimaryKey(profile.Id).WithRecord(profile.ToTableRecord())
 transaction.Exec(pcmd)
 if err := transaction.Commit(); err != nil {
 return ... 
 }
 return ...
}

总结实现命令模式的几个关键点:

  1. 定义命令抽象接口,本例子中为 Command 接口。
  2. 在命令抽象接口中声明执行命令的方法,本例子中为 Exec 方法。
  3. 如果要实现撤销功能,还需要为命令对象定义 Undo 方法,在操作回滚时调用。
  4. 定义 Invoker 对象,本例子中为 Transaction 对象。
  5. 在 Invoker 对象持有 Command 的引用,本例子为 Command 的切片 cmds。
  6. 为 Invoker 对象定义 Call 方法,用于执行具体的命令,在方法内调用 Command 的执行方法 ,本例子中为 Transaction.Commit 方法。
  7. 如果要实现撤销功能,还要在回滚方法中,调用已执行命令的 Undo 方法,本例子中为 cmdHistory.rollback 方法。
  8. 定义具体的命令类,实现 Command 接口,本例子中为 InsertCmd、UpdateCmd、DeleteCmd。
  9. 命令通常持有接收者的引用,以便在执行方法中与接收者交互。本例子中,Receiver 为 Db 对象。
  10. 最后,在命令对象执行方法中,调用 Receiver 的 Action 方法,本例子中, Receiver 的 Action 方法为 db.Insert 方法。

值得注意的是,本例子中 Transaction 对象在 Transaction.Exec 方法中只是将 Command 保存在队列中,只有当调用 Transaction.Commit 方法时才延迟执行相应的命令。

扩展

os/exec 中的命令模式

Go 标准库的 os/exec 包也用到了命令模式。

package main
import (
 "os/exec"
)
// 对应命令模式中的Invoker
func main() {
 cmd := exec.Command("sleep", "1")
 err := cmd.Run()
}

在上述例子中,我们通过 exec.Command 方法将一个 shell 命令转换成一个命令对象 exec.Cmd,其中的 Cmd.Run() 方法即是命令执行方法;而 main() 函数,对应到命令模式中的 Invoker;Receiver 则是操作系统执行 shell 命令的具体进程,从 exec.Cmd 的源码中可以看到:

// src/os/exec/exec.go
package exec
// 对应命令模式中的Command
type Cmd struct {
 ...
 // 对应命令模式中的Receiver
    Process *os.Process
 ...
}
// 对应命令模式中Command的执行方法
func (c *Cmd) Run() error {
 if err := c.Start(); err != nil {
 return err
 }
 return c.Wait()
}
func (c *Cmd) Start() error {
 ...
 // Command与Receiver的交互
 c.Process, err = os.StartProcess(c.Path, c.argv(), &os.ProcAttr{...})
 ...
}

CQRS 架构

CQRS 架构,全称为 Command Query Responsibility Segregation,命令查询职责隔离架构。CQRS 架构是微服务架构模式中的一种,它利用事件(命令)来维护从多个服务复制数据的只读视图,通过读写分离思想,提升微服务架构下查询的性能。

CQRS 架构可分为 命令端 和 查询端,其中命令端负责数据的更新;查询端负责数据的查询。命令端的写数据库在数据更新时,会向查询端的只读数据库发送一个同步数据的事件,保证数据的最终一致性。

其中的命令端,就使用到了命令模式的思想,将数据更新请求封装成命令,异步更新到写数据库中。

典型应用场景

  • 事务模式。事务模式下往往需要 Undo 操作,使用命令模式实现起来很方便。
  • 远程执行。Go 标准库下的 exec.Cmd、http.Client 都属于该类型,将请求封装成命令来执行。
  • CQRS 架构。微服务架构模式中的一种,通过命令模式来实现数据的异步更新。
  • 延迟执行。当你希望一个操作能够延迟执行时,通常会将它封装成命令,然后放到一个队列中。

优缺点

优点

  1. 符合单一职责原则。在命令模式下,每个命令都是职责单一、松耦合的;当然也可以通过组合的方式,将多个简单的命令组合成一个负责的命令。
  2. 可以很方便地实现操作的延迟执行、回滚、重做等。
  3. 在分布式架构下,命令模式能够方便地实现异步的数据更新、方法调用等,提升性能。

缺点

  1. 命令模式下,调用往往是异步的,而异步会导致系统变得复杂,问题出现时不好定位解决。
  2. 随着业务越来越复杂,命令对象也会增多,代码会变得更难维护。

与其他模式的关联

在实现 Undo/Redo 操作时,你通常需要同时使用 命令模式 和 备忘录模式。

另外,命令模式 也常常和观察者模式 一起出现,比如在 CQRS 架构中,当命令端更新数据库后,写数据库就会通过事件将数据同步到读数据库上,这里就用到了观察者模式。

文章配图

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

参考

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

[2] 【Go实现】实践GoF的23种设计模式:观察者模式, 元闰子

[3] Design Patterns, Chapter 5. Behavioral Patterns, GoF

[4] 命令模式refactoringguru.cn

[5] The command pattern in Go, rolandjitsu

[6] CQRS 模式, microsoft azure

[7] CQRS Design Pattern in Microservices Architectures, Mehmet Ozkaya

 

点击关注,第一时间了解华为云新鲜技术~

与实践GoF的23种设计模式:命令模式相似的内容:

实践GoF的23种设计模式:命令模式

摘要:命令模式可将请求转换为一个包含与请求相关的所有信息的对象, 它能将请求参数化、延迟执行、实现 Undo / Redo 操作等。 本文分享自华为云社区《【Go实现】实践GoF的23种设计模式:命令模式》,作者:元闰子。 简介 现在的软件系统往往是分层设计。在业务层执行一次请求时,我们很清楚请求的

实践GoF的设计模式:代理模式

摘要: 代理模式为一个对象提供一种代理以控制对该对象的访问。 本文分享自华为云社区《【Go实现】实践GoF的23种设计模式:代理模式》,作者:元闰子 。 简介 GoF 对代理模式(Proxy Pattern)的定义如下: Provide a surrogate or placeholder for

实践探讨Python如何进行异常处理与日志记录

本文分享自华为云社区《Python异常处理与日志记录构建稳健可靠的应用》,作者:柠檬味拥抱。 异常处理和日志记录是编写可靠且易于维护的软件应用程序中至关重要的组成部分。Python提供了强大的异常处理机制和灵活的日志记录功能,使开发人员能够更轻松地管理代码中的错误和跟踪应用程序的执行过程。在本文中,

基于Traefik如何实现向后转发自动去掉前缀?

实践中, 往往会有这样的需求, 用户输入的url是ewhisper.cn/alert-manager/#/alerts, 但是转发到后端要变成/#/alerts, 如何基于 Traefik on K8S 实现?

实践丨GaussDB(DWS)资源管理排队原理与问题定位

摘要:GaussDB(DWS)提供了资源管理功能,用户可以根据自身业务情况对资源进行划分,将资源按需划分成不同的资源池,不同资源池之间资源互相隔离。 本文分享自华为云社区《GaussDB(DWS)资源管理排队原理与问题定位》,作者: 门前一棵葡萄树 。 一、内存管控原理 GaussDB(DWS)提供

实践篇(三):如何有效评审软件架构图?

设计意图的传达是架构可视化关注的重要维度,在技术方案评审过程中不可避免的会出现各种各样的架构图或设计图,这些图形化表述在设计意图传达效果层面表现不一,本文从图形化的视角为软件架构图的评审关注点提供了参考。

实践指南-前端性能提升 270%

当我们疲于开发一个接一个的需求时,很容易忘记去关注网站的性能,到了某一个节点,猛地发现,随着越来越多代码的堆积,网站变得越来越慢。本文就是从这样的一个背景出发,着手优化网站的前端性能,并总结出一套开发习惯,让我们在日常开发时,也保持高性能,而不是又一次回过头来优化性能。

【实践篇】DDD脚手架及编码规范

我们团队一直在持续推进业务系统的体系化治理工作,在这个过程中我们沉淀了自己的DDD脚手架项目。本文主要是梳理和总结了DDD脚手架使用中的编码规范以及遇到的问题。

实践案例丨CenterNet-Hourglass论文复现

摘要:本案例是CenterNet-Hourglass论文复现的体验案例,此模型是对Objects as Points 中提出的CenterNet进行结果复现。 本文分享自华为云社区《CenterNet-Hourglass (物体检测/Pytorch)》,作者:HWCloudAI。 目标检测常采用An

实践Pytorch中的模型剪枝方法

摘要:所谓模型剪枝,其实是一种从神经网络中移除"不必要"权重或偏差的模型压缩技术。 本文分享自华为云社区《模型压缩-pytorch 中的模型剪枝方法实践》,作者:嵌入式视觉。 一,剪枝分类 所谓模型剪枝,其实是一种从神经网络中移除"不必要"权重或偏差(weigths/bias)的模型压缩技术。关于什