手撸golang 行为型设计模式 委派模式

.container .card .information strong · · 156 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

手撸golang 行为型设计模式 委派模式

缘起

最近复习设计模式
拜读谭勇德的<<设计模式就该这样学>>
本系列笔记拟采用golang练习之

委派模式

委派模式(Delegate Pattern)又叫作委托模式,基本作用就是负责任务的调用和分配,是一种特殊的静态代理模式,可以理解为全权代理模式,但是代理模式注重过程,而委派模式注重结果。
委派模式有3个参与角色。
(1)抽象任务角色(ITask):定义一个抽象接口,它有若干实现类。
(2)委派者角色(Delegate):负责在各个具体角色实例之间做出决策,判断并调用具体实现的方法。
(3)具体任务角色(Concrete):真正执行任务的角色。
_

场景

  • 某消息处理系统, 需要处理客户端请求的各种消息
  • 为方便后续扩展统一的消息日志/审计/权限/安全等功能, 根据委派模式, 所有消息由全局调度器统一调度
  • 调度器根据消息的类型, 委派给具体的消息处理器

设计

  • IMsg: 定义消息接口
  • BaseMsg: 消息的基类, 实现IMsg接口
  • EchoMsg: 表示原样返回的消息, 用于PING/PONG心跳. 继承自BaseMsg
  • TimeMsg: 表示获取服务器时间的消息. 继承自BaseMsg
  • IMsgHandler: 消息处理器接口. 调度器和具体消息处理器, 均需要实现此接口.
  • tMsgDispatchDelegate: 全局消息调度器, 是所有客户端消息的统一入口. 用于注册消息处理器, 按类型分发消息.
  • tEchoMsgHandler: 专门处理EchoMsg消息的处理器. 实现IMsgHandler接口.
  • tTimeMsgHandler: 专门处理TimeMsg消息的处理器, 实现IMsgHandler接口.

单元测试

delegate_pattern_test.go

package behavioral_patterns_test

import (
    "fmt"
    "learning/gooop/behavioral_patterns/delegate"
    "testing"
)

func Test_DelegatePattern(t *testing.T) {
    dispatcher := delegate.GlobalMsgDispatcher
    vEchoMsg := delegate.NewEchoMsg("msg-1", "this is an echo msg")
    response := dispatcher.Handle(vEchoMsg)
    fmt.Printf("  echo response: id=%v, cls=%v, content=%v\n", response.ID(), response.Class(), response.Content())

    vTimeMsg := delegate.NewTimeMsg("msg-2")
    response = dispatcher.Handle(vTimeMsg)
    fmt.Printf("  time response: id=%v, cls=%v, content=%v\n", response.ID(), response.Class(), response.Content())
}

测试输出

$ go test -v delegate_pattern_test.go 
=== RUN   Test_DelegatePattern
tMsgDispatchDelegate.Handle, handler=*delegate.tEchoMsgHandler, id=msg-1, cls=EchoMsg
  tEchoMsgHandler.Handle, id=msg-1, cls=EchoMsg
  echo response: id=msg-1, cls=EchoMsg, content=this is an echo msg
tMsgDispatchDelegate.Handle, handler=*delegate.tTimeMsgHandler, id=msg-2, cls=TimeMsg
  tTimeMsgHandler.Handle, id=msg-2, cls=TimeMsg
  time response: id=msg-2, cls=TimeMsg, content=2021-02-05T09:18:45
--- PASS: Test_DelegatePattern (0.00s)
PASS
ok      command-line-arguments  0.002s

IMsg.go

定义消息接口

package delegate

type IMsg interface {
    ID() string
    Class() string
    Content() string
}

BaseMsg.go

消息的基类, 实现IMsg接口

package delegate

type BaseMsg struct {
    sID string
    sClass string
    sContent string
}

func NewBaseMsg(id string, cls string, content string) *BaseMsg {
    return &BaseMsg{
        id, cls, content,
    }
}

func (me *BaseMsg) ID() string {
    return me.sID
}

func (me *BaseMsg) Class() string {
    return me.sClass
}

func (me *BaseMsg) Content() string {
    return me.sContent
}

EchoMsg.go

表示原样返回的消息, 用于PING/PONG心跳. 继承自BaseMsg

package delegate

type EchoMsg struct {
    BaseMsg
}

func NewEchoMsg(id string, content string) *EchoMsg {
    return &EchoMsg{
        *NewBaseMsg(id, "EchoMsg", content),
    }
}

TimeMsg.go

表示获取服务器时间的消息. 继承自BaseMsg

package delegate

import "time"

type TimeMsg struct {
    BaseMsg
}

func NewTimeMsg(id string) *TimeMsg {
    return &TimeMsg{
        *NewBaseMsg(id, "TimeMsg", time.Now().Format("2006-01-02T15:04:05")),
    }
}

IMsgHandler.go

消息处理器接口. 调度器和具体消息处理器, 均需要实现此接口.

package delegate

type IMsgHandler interface {
    Handle(request IMsg) IMsg
}

tMsgDispatchDelegate.go

全局消息调度器, 是所有客户端消息的统一入口. 用于注册消息处理器, 按类型分发消息. 实现IMsgHandler接口.

package delegate

import (
    "fmt"
    "reflect"
)

type tMsgDispatchDelegate struct {
    mSubHandlers map[string]IMsgHandler
}

func (me *tMsgDispatchDelegate) Register(cls string, handler IMsgHandler) {
    me.mSubHandlers[cls] = handler
}

func newMsgDispatchDelegate() IMsgHandler {
    it := &tMsgDispatchDelegate{
        mSubHandlers: make(map[string]IMsgHandler, 16),
    }

    it.Register("EchoMsg", newEchoMsgHandler())
    it.Register("TimeMsg", newTimeMsgHandler())

    return it
}


func (me *tMsgDispatchDelegate) Handle(request IMsg) IMsg {
    if request == nil {
        return nil
    }

    handler, ok := me.mSubHandlers[request.Class()]
    if !ok {
        fmt.Printf("tMsgDispatchDelegate.Handle, handler not found: id=%v, cls=%v\n", request.ID(), request.Class())
        return nil
    }

    fmt.Printf("tMsgDispatchDelegate.Handle, handler=%v, id=%v, cls=%v\n", reflect.TypeOf(handler).String(), request.ID(), request.Class())
    return handler.Handle(request)
}

var GlobalMsgDispatcher = newMsgDispatchDelegate()

tEchoMsgHandler.go

专门处理EchoMsg消息的处理器. 实现IMsgHandler接口.

package delegate

import "fmt"

type tEchoMsgHandler struct {
}

func newEchoMsgHandler() IMsgHandler {
    return &tEchoMsgHandler{}
}

func (me *tEchoMsgHandler) Handle(request IMsg) IMsg {
    fmt.Printf("  tEchoMsgHandler.Handle, id=%v, cls=%v\n", request.ID(), request.Class())
    return request
}

tTimeMsgHandler.go

专门处理TimeMsg消息的处理器, 实现IMsgHandler接口.

package delegate

import (
    "fmt"
    "time"
)

type tTimeMsgHandler struct {
}

func newTimeMsgHandler() IMsgHandler {
    return &tTimeMsgHandler{}
}

func (me *tTimeMsgHandler) Handle(request IMsg) IMsg {
    fmt.Printf("  tTimeMsgHandler.Handle, id=%v, cls=%v\n", request.ID(), request.Class())

    timeMsg := request.(*TimeMsg)
    timeMsg.sContent = time.Now().Format("2006-01-02T15:04:05")
    return timeMsg
}

委派模式小结

委派模式的优点
通过任务委派能够将一个大型任务细化,然后通过统一管理这些子任务的完成情况实现任务的跟进,加快任务执行的效率。
委派模式的缺点
任务委派方式需要根据任务的复杂程度进行不同的改变,在任务比较复杂的情况下,可能需要进行多重委派,容易造成紊乱。
_
(end)


有疑问加站长微信联系(非本文作者)

本文来自:Segmentfault

感谢作者:.container .card .information strong

查看原文:手撸golang 行为型设计模式 委派模式

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

156 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传