上一篇:【Go實現(xiàn)】實踐GoF的23種設計模式:原型模式
簡單的分布式應用系統(tǒng)(示例代碼工程):https://github.com/ruanrunxue/Practice-Design-Pattern--Go-Implementation
簡介
我們經(jīng)常會遇到“給現(xiàn)有對象/模塊新增功能”的場景,比如 http router 的開發(fā)場景下,除了最基礎的路由功能之外,我們常常還會加上如日志、鑒權(quán)、流控等 middleware。如果你查看框架的源碼,就會發(fā)現(xiàn) middleware 功能的實現(xiàn)用的就是裝飾者模式(Decorator Pattern)。
GoF給裝飾者模式的定義如下:
Decorators provide a flexible alternative to subclassing for extending functionality. Attach additional responsibilities to an object dynamically.
簡單來說,裝飾者模式通過組合的方式,提供了能夠動態(tài)地給對象/模塊擴展新功能的能力。理論上,只要沒有限制,它可以一直把功能疊加下去,具有很高的靈活性。
如果寫過 Java,那么一定對 I/O Stream 體系不陌生,它是裝飾者模式的經(jīng)典用法,客戶端程序可以動態(tài)地為原始的輸入輸出流添加功能,比如按字符串輸入輸出,加入緩沖等,使得整個 I/O Stream 體系具有很高的可擴展性和靈活性。
UML 結(jié)構(gòu)

場景上下文
在簡單的分布式應用系統(tǒng)(示例代碼工程)中,我們設計了 Sidecar 邊車模塊,它的用處主要是為了 1)方便擴展network.Socket的功能,如增加日志、流控等非業(yè)務功能;2)讓這些附加功能對業(yè)務程序隱藏起來,也即業(yè)務程序只須關(guān)心看到network.Socket接口即可。

代碼實現(xiàn)
Sidecar 的這個功能場景,很適合使用裝飾者模式來實現(xiàn),代碼如下:
//demo/network/socket.go
packagenetwork
//關(guān)鍵點1:定義被裝飾的抽象接口
//Socket網(wǎng)絡通信Socket接口
typeSocketinterface{
//Listen在endpoint指向地址上起監(jiān)聽
Listen(endpointEndpoint)error
//Close關(guān)閉監(jiān)聽
Close(endpointEndpoint)
//Send發(fā)送網(wǎng)絡報文
Send(packet*Packet)error
//Receive接收網(wǎng)絡報文
Receive(packet*Packet)
//AddListener增加網(wǎng)絡報文監(jiān)聽者
AddListener(listenerSocketListener)
}
//關(guān)鍵點2:提供一個默認的基礎實現(xiàn)
typesocketImplstruct{
listenerSocketListener
}
funcDefaultSocket()*socketImpl{
return&socketImpl{}
}
func(s*socketImpl)Listen(endpointEndpoint)error{
returnInstance().Listen(endpoint,s)
}
...//socketImpl的其他Socket實現(xiàn)方法
//demo/sidecar/flowctrl_sidecar.go
packagesidecar
//關(guān)鍵點3:定義裝飾器,實現(xiàn)被裝飾的接口
//FlowCtrlSidecarHTTP接收端流控功能裝飾器,自動攔截Socket接收報文,實現(xiàn)流控功能
typeFlowCtrlSidecarstruct{
//關(guān)鍵點4:裝飾器持有被裝飾的抽象接口作為成員屬性
socketnetwork.Socket
ctx*flowctrl.Context
}
//關(guān)鍵點5:對于需要擴展功能的方法,新增擴展功能
func(f*FlowCtrlSidecar)Receive(packet*network.Packet){
httpReq,ok:=packet.Payload().(*http.Request)
//如果不是HTTP請求,則不做流控處理
if!ok{
f.socket.Receive(packet)
return
}
//流控后返回429TooManyRequest響應
if!f.ctx.TryAccept(){
httpResp:=http.ResponseOfId(httpReq.ReqId()).
AddStatusCode(http.StatusTooManyRequest).
AddProblemDetails("enterflowctrlstate")
f.socket.Send(network.NewPacket(packet.Dest(),packet.Src(),httpResp))
return
}
f.socket.Receive(packet)
}
//關(guān)鍵點6:不需要擴展功能的方法,直接調(diào)用被裝飾接口的原生方法即可
func(f*FlowCtrlSidecar)Close(endpointnetwork.Endpoint){
f.socket.Close(endpoint)
}
...//FlowCtrlSidecar的其他方法
//關(guān)鍵點7:定義裝飾器的工廠方法,入?yún)楸谎b飾接口
funcNewFlowCtrlSidecar(socketnetwork.Socket)*FlowCtrlSidecar{
return&FlowCtrlSidecar{
socket:socket,
ctx:flowctrl.NewContext(),
}
}
//demo/sidecar/all_in_one_sidecar_factory.go
//關(guān)鍵點8:使用時,通過裝飾器的工廠方法,把所有裝飾器和被裝飾者串聯(lián)起來
func(aAllInOneFactory)Create()network.Socket{
returnNewAccessLogSidecar(NewFlowCtrlSidecar(network.DefaultSocket()),a.producer)
}
總結(jié)實現(xiàn)裝飾者模式的幾個關(guān)鍵點:
- 定義需要被裝飾的抽象接口,后續(xù)的裝飾器都是基于該接口進行擴展。
- 為抽象接口提供一個基礎實現(xiàn)。
- 定義裝飾器,并實現(xiàn)被裝飾的抽象接口。
- 裝飾器持有被裝飾的抽象接口作為成員屬性。“裝飾”的意思是在原有功能的基礎上擴展新功能,因此必須持有原有功能的抽象接口。
- 在裝飾器中,對于需要擴展功能的方法,新增擴展功能。
- 不需要擴展功能的方法,直接調(diào)用被裝飾接口的原生方法即可。
- 為裝飾器定義一個工廠方法,入?yún)楸谎b飾接口。
- 使用時,通過裝飾器的工廠方法,把所有裝飾器和被裝飾者串聯(lián)起來。
擴展
Go 風格的實現(xiàn)
在 Sidecar 的場景上下文中,被裝飾的Socket是一個相對復雜的接口,裝飾器通過實現(xiàn)Socket接口來進行功能擴展,是典型的面向?qū)ο箫L格。
如果被裝飾者是一個簡單的接口/方法/函數(shù),我們可以用更具 Go 風格的實現(xiàn)方式,考慮前文提到的 http router 場景。如果你使用原生的net/http進行 http router 開發(fā),通常會這么實現(xiàn):
funcmain(){
//注冊/hello的router
http.HandleFunc("/hello",hello)
//啟動http服務器
http.ListenAndServe("localhost:8080",nil)
}
//具體的請求處理邏輯,類型是http.HandlerFunc
funchello(whttp.ResponseWriter,r*http.Request){
w.Write([]byte("hello,world"))
}
其中,我們通過http.HandleFunc來注冊具體的 router,hello是具體的請求處理方法?,F(xiàn)在,我們想為該 http 服務器增加日志、鑒權(quán)等通用功能,那么可以把func(w http.ResponseWriter, r *http.Request)作為被裝飾的抽象接口,通過新增日志、鑒權(quán)等裝飾器完成功能擴展。
//demo/network/http/http_handle_func_decorator.go
//關(guān)鍵點1:確定被裝飾接口,這里為原生的http.HandlerFunc
typeHandlerFuncfunc(ResponseWriter,*Request)
//關(guān)鍵點2:定義裝飾器類型,是一個函數(shù)類型,入?yún)⒑头祷刂刀际莌ttp.HandlerFunc函數(shù)
typeHttpHandlerFuncDecoratorfunc(http.HandlerFunc)http.HandlerFunc
//關(guān)鍵點3:定義裝飾函數(shù),入?yún)楸谎b飾的接口和裝飾器可變列表
funcDecorate(hhttp.HandlerFunc,decorators...HttpHandlerFuncDecorator)http.HandlerFunc{
//關(guān)鍵點4:通過for循環(huán)遍歷裝飾器,完成對被裝飾接口的裝飾
for_,decorator:=rangedecorators{
h=decorator(h)
}
returnh
}
//關(guān)鍵點5:實現(xiàn)具體的裝飾器
funcWithBasicAuth(hhttp.HandlerFunc)http.HandlerFunc{
returnfunc(whttp.ResponseWriter,r*http.Request){
cookie,err:=r.Cookie("Auth")
iferr!=nil||cookie.Value!="Pass"{
w.WriteHeader(http.StatusForbidden)
return
}
//關(guān)鍵點6:完成功能擴展之后,調(diào)用被裝飾的方法,才能將所有裝飾器和被裝飾者串起來
h(w,r)
}
}
funcWithLogger(hhttp.HandlerFunc)http.HandlerFunc{
returnfunc(whttp.ResponseWriter,r*http.Request){
log.Println(r.Form)
log.Printf("path%s",r.URL.Path)
h(w,r)
}
}
funchello(whttp.ResponseWriter,r*http.Request){
w.Write([]byte("hello,world"))
}
funcmain(){
//關(guān)鍵點7:通過Decorate函數(shù)完成對hello的裝飾
http.HandleFunc("/hello",Decorate(hello,WithLogger,WithBasicAuth))
//啟動http服務器
http.ListenAndServe("localhost:8080",nil)
}
上述的裝飾者模式的實現(xiàn),用到了類似于Functional Options的技巧,也是巧妙利用了 Go 的函數(shù)式編程的特點,總結(jié)下來有如下幾個關(guān)鍵點:
-
確定被裝飾的接口,上述例子為
http.HandlerFunc。 -
定義裝飾器類型,是一個函數(shù)類型,入?yún)⒑头祷刂刀际潜谎b飾接口,上述例子為
func(http.HandlerFunc) http.HandlerFunc。 -
定義裝飾函數(shù),入?yún)楸谎b飾的接口和裝飾器可變列表,上述例子為
Decorate方法。 - 在裝飾方法中,通過for循環(huán)遍歷裝飾器,完成對被裝飾接口的裝飾。這里是用來類似Functional Options的技巧,一定要注意裝飾器的順序!
-
實現(xiàn)具體的裝飾器,上述例子為
WithBasicAuth和WithLogger函數(shù)。 - 在裝飾器中,完成功能擴展之后,記得調(diào)用被裝飾者的接口,這樣才能將所有裝飾器和被裝飾者串起來。
-
在使用時,通過裝飾函數(shù)完成對被裝飾者的裝飾,上述例子為
Decorate(hello, WithLogger, WithBasicAuth)。
Go 標準庫中的裝飾者模式
在 Go 標準庫中,也有一個運用了裝飾者模式的模塊,就是context,其中關(guān)鍵的接口如下:
packagecontext
//被裝飾接口
typeContextinterface{
Deadline()(deadlinetime.Time,okbool)
Done()<-chanstruct{}
Err()error
Value(keyany)any
}
//cancel裝飾器
typecancelCtxstruct{
Context//被裝飾接口
musync.Mutex
doneatomic.Value
childrenmap[canceler]struct{}=
errerror
}
//cancel裝飾器的工廠方法
funcWithCancel(parentContext)(ctxContext,cancelCancelFunc){
//...
c:=newCancelCtx(parent)
propagateCancel(parent,&c)
return&c,func(){c.cancel(true,Canceled)}
}
//timer裝飾器
typetimerCtxstruct{
cancelCtx//被裝飾接口
timer*time.Timer
deadlinetime.Time
}
//timer裝飾器的工廠方法
funcWithDeadline(parentContext,dtime.Time)(Context,CancelFunc){
//...
c:=&timerCtx{
cancelCtx:newCancelCtx(parent),
deadline:d,
}
//...
returnc,func(){c.cancel(true,Canceled)}
}
//timer裝飾器的工廠方法
funcWithTimeout(parentContext,timeouttime.Duration)(Context,CancelFunc){
returnWithDeadline(parent,time.Now().Add(timeout))
}
//value裝飾器
typevalueCtxstruct{
Context//被裝飾接口
key,valany
}
//value裝飾器的工廠方法
funcWithValue(parentContext,key,valany)Context{
ifparent==nil{
panic("cannotcreatecontextfromnilparent")
}
//...
return&valueCtx{parent,key,val}
}

使用時,可以這樣:
//使用時,可以這樣
funcmain(){
ctx:=context.Background()
ctx=context.WithValue(ctx,"key1","value1")
ctx,_=context.WithTimeout(ctx,time.Duration(1))
ctx=context.WithValue(ctx,"key2","value2")
}
不管是 UML 結(jié)構(gòu),還是使用方法,context模塊都與傳統(tǒng)的裝飾者模式有一定出入,但也不妨礙context是裝飾者模式的典型運用。還是那句話,學習設計模式,不能只記住它的結(jié)構(gòu),而是學習其中的動機和原理。
典型使用場景
- I/O 流,比如為原始的 I/O 流增加緩沖、壓縮等功能。
- Http Router,比如為基礎的 Http Router 能力增加日志、鑒權(quán)、Cookie等功能。
- ......
優(yōu)缺點
優(yōu)點
- 遵循開閉原則,能夠在不修改老代碼的情況下擴展新功能。
- 可以用多個裝飾器把多個功能組合起來,理論上可以無限組合。
缺點
- 一定要注意裝飾器裝飾的順序,否則容易出現(xiàn)不在預期內(nèi)的行為。
- 當裝飾器越來越多之后,系統(tǒng)也會變得復雜。
與其他模式的關(guān)聯(lián)
裝飾者模式和代理模式具有很高的相似性,但是兩種所強調(diào)的點不一樣。前者強調(diào)的是為本體對象添加新的功能;后者強調(diào)的是對本體對象的訪問控制。
裝飾者模式和適配器模式的區(qū)別是,前者只會擴展功能而不會修改接口;后者則會修改接口。
文章配圖
可以在用Keynote畫出手繪風格的配圖中找到文章的繪圖方法。
審核編輯 :李倩
-
模塊
+關(guān)注
關(guān)注
7文章
2849瀏覽量
53458 -
UML
+關(guān)注
關(guān)注
0文章
123瀏覽量
31663
原文標題:【Go實現(xiàn)】實踐GoF的23種設計模式:裝飾者模式
文章出處:【微信號:yuanrunzi,微信公眾號:元閏子的邀請】歡迎添加關(guān)注!文章轉(zhuǎn)載請注明出處。
發(fā)布評論請先 登錄
[VirtualLab] Ince-Gaussian模式
VirtualLab:Ince高斯模式
VirtualLab:Ince高斯模式
KiCad 10 IPC API 開發(fā)者問答整理
嵌入式程序設計中4種常用模式
無圖形界面模式下自定義檢查工具的應用
浮點擴展指令集中定義的五種舍入模式
用LabVIEW開發(fā)的測試軟件,支持自定義測試內(nèi)容,分享給大家。
從入門到精通:基于開源代碼的BLE四種模式開發(fā)詳解
一文讀懂 RGB接口的 DE模式 和 行場(HV)模式 區(qū)別
CYPD3171自定義應用程序在接收模式下工作,但在源模式下不通告任何協(xié)議是怎么回事?
關(guān)于生命周期中的aboutToAppear和onPageShow的理解和應用
AG32 SDK:加入DSP例程及支持boot_mode模式和自定義 Linker腳本等(v1.7.5版本)
基于藍牙模組Beacon+觀察者模式實現(xiàn)資產(chǎn)管理和室內(nèi)定位
GoF給裝飾者模式的定義
評論