快捷導(dǎo)航

Go設(shè)計(jì)模式之觀察者模式講解和代碼示例

更新時(shí)間：2023年07月17日 08:16:54 作者：demo007x

觀察者是一種行為設(shè)計(jì)模式，允許一個(gè)對(duì)象將其狀態(tài)的改變通知其他對(duì)象，觀察者模式提供了一種作用于任何實(shí)現(xiàn)了訂閱者接口的對(duì)象的機(jī)制，可對(duì)其事件進(jìn)行訂閱和取消訂閱，本文就通過(guò)代碼示例給大家詳細(xì)介紹一下Go的觀察者模式,需要的朋友可以參考下

概念示例

在電商網(wǎng)站中，商品時(shí)不時(shí)地會(huì)出現(xiàn)缺貨情況。可能會(huì)有客戶對(duì)于缺貨的特定商品表現(xiàn)出興趣。這一問(wèn)題有三種解決方案：

客戶以一定的頻率查看商品的可用性。
電商網(wǎng)站向客戶發(fā)送有庫(kù)存的所有新商品。
客戶只訂閱其感興趣的特定商品，商品可用時(shí)便會(huì)收到通知。同時(shí)，多名客戶也可訂閱同一款產(chǎn)品。

選項(xiàng) 3 是最具可行性的，這其實(shí)就是觀察者模式的思想。觀察者模式的主要組成部分有：

會(huì)在有任何事發(fā)生時(shí)發(fā)布事件的主體。
訂閱了主體事件并會(huì)在事件發(fā)生時(shí)收到通知的觀察者。

subject.go: 主體

package main
type Subject interface {
	register(observer Observer)
	deregister(obs Observer)
	notifyAll()
}

item.go: 具體主體

package main
import (
	"fmt"
)
type Item struct {
	observerList []Observer // 多個(gè)觀察者
	name         string
	inStock      bool // 有庫(kù)存
}
func newItem(name string) *Item {
	return &Item{
		name:    name,
		inStock: false,
	}
}
// 更新狀態(tài)
func (i *Item) updateAvailability() {
	fmt.Printf("Item %s is now in stock \n", i.name)
	i.inStock = true // 更新狀態(tài)，有庫(kù)存 s
	i.notifyAll()
}
func (i *Item) register(o Observer) {
	i.observerList = append(i.observerList, o)
}
func (i *Item) deregister(o Observer) {
	i.observerList = removeFromslice(i.observerList, o)
}
func (i *Item) notifyAll() {
	for _, v := range i.observerList {
		v.update(i.name)
	}
}
func removeFromslice(observerList []Observer, observerToRemove Observer) []Observer {
	observerListLength := len(observerList)
	for i, observer := range observerList {
		if observerToRemove.getID() == observer.getID() {
			observerList[observerListLength-1], observerList[i] = observerList[i], observerList[observerListLength-1]
			return observerList[:observerListLength-1]
		}
	}
	return observerList
}

observer.go: 觀察者

package main
type Observer interface {
	update(string)
	getID() string
}

customer.go: 具體觀察者

package main
import "fmt"
type Customer struct {
	id string
}
func (c *Customer) getID() string {
	return c.id
}
func (c *Customer) update(iteName string) {
	fmt.Printf("Sendint email to customer %s for item %s\n", c.id, iteName)
}

main.go: 客戶端代碼

package main
func main() {
	shirtItem := newItem("Nick Shirt")
	observerFirst := &Customer{
		id: "abc@gmail.com",
	}
	observerSecond := &Customer{
		id: "def@gmail.com",
	}
	shirtItem.register(observerFirst)
	shirtItem.register(observerSecond)
	shirtItem.updateAvailability()
}

output.txt: 執(zhí)行結(jié)果

Item Nick Shirt is now in stock
Sendint email to customer abc@gmail.com for item Nick Shirt
Sendint email to customer def@gmail.com for item Nick Shirt

到此這篇關(guān)于Go設(shè)計(jì)模式之觀察者模式講解和代碼示例的文章就介紹到這了,更多相關(guān)Go觀察者模式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: