模式定義

定義了對象之間的一對多依賴，讓多個觀察者對象同時監(jiān)聽某一個主題對象，當主題對象發(fā)生變化時，它的所有依賴者都會收到通知并更新

類圖

應(yīng)用場景

當更改一個對象的狀態(tài)可能需要更改其他對象，并且實際的對象事先未知或動態(tài)更改時，使用觀察者模式

優(yōu)點

1.符合開閉原則

2.可以在運行時建立對象之間的關(guān)系

要點總結(jié)

• 使用面向?qū)ο蟮某橄?#xff0c;Observe模式使得我們可以獨立地改變目標與觀察者，從而使二者之間的依賴關(guān)系達到松耦合
• 目標發(fā)送通知時，無需指定觀察者，通知（可以攜帶通知信息作為參數(shù)）會自動傳播
• 觀察者自己解決是否需要訂閱通知，目標對象對此一無所知
• Observer模式是基于事件的UI框架中非常常用的設(shè)計模式，也是MVC模式的一個重要組成部分

Go語言代碼實現(xiàn)

工程目錄

observe.go

package Observerimport ("fmt""sync""time" )type Event struct {Data int }type Observer interface {NotifyCallback(event Event) }type Subject interface {AddListener(observer Observer)RemoveListener(observer Observer)Notify(event Event) }type eventObserver struct {ID intTime time.Time }type eventSubject struct {Observers sync.Map }func (e eventObserver) NotifyCallback(event Event) {fmt.Printf("Recieved:%d after %v\n", event.Data, time.Since(e.Time)) }func (e *eventSubject) AddListener(obs Observer) {e.Observers.Store(obs, struct{}{}) }func (e *eventSubject) RemoveListener(obs Observer) {e.Observers.Delete(obs) }func (e *eventSubject) Notify(event Event) {e.Observers.Range(func(key, value interface{}) bool {if key == nil {return false}key.(Observer).NotifyCallback(event)return true}) }func Fib(n int) chan int {out := make(chan int)go func() {defer close(out)for i, j := 0, 1; i < n; i, j = i+j, i {out <- i}}()return out }

observer_test.go

package Observerimport ("sync""testing""time" )func TestFib(t *testing.T) {//for x := range Fib(10) {// fmt.Println(x)//}n := eventSubject{Observers: sync.Map{}}obs1 := eventObserver{ID: 1, Time: time.Now()}obs2 := eventObserver{ID: 2, Time: time.Now()}n.AddListener(obs1)n.AddListener(obs2)for x := range Fib(10) {n.Notify(Event{Data: x})} }

總結(jié)

以上是生活随笔為你收集整理的设计模式--观察者(Observer)模式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。