目录
- 概念示例
- subject.go: 主体
- item.go: 具体主体
- observer.go: 观察者
- customer.go: 具体观察者
- main.go: 客户端代码
- output.txt: 执行结果
概念示例
在电商网站中, 商品时不时地会出现缺货情况。 可能会有客户对于缺货的特定商品表现出兴趣。 这一问题有三种解决方案:
- 客户以一定的频率查看商品的可用性。
- 电商网站向客户发送有库存的所有新商品。
- 客户只订阅其感兴趣的特定商品, 商品可用时便会收到通知。 同时, 多名客户也可订阅同一款产品。
选项 3 是最具可行性的, 这其实javascript就是观察者模式的思想。 观察者模式的主要组成部分有:
- 会在有任何事发生时发布事件的主体。
- 订阅了主体事件并会在事件发生时收到通知的观察者。
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 // 多个观察者 name string inStock bool // 有库存 } func newItem(name string) *Item { return &Item{ name: name, inStock: false, } } // 编程更新状态 func (i *Item) updateAvailability() { fmt.Printf("Item %s is nandroidow in stock \n", i.name) i.inStock = true // 更新状态,有库存 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 Observerphp) []Observer { observer编程ListLength := 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: 执行结果
Item Nick Shirt is now in stock
Sendint email to customer abc@gmail.com for item Nick ShirtSendint email to customer def@gmail.com for item Nick Shirt
到此这篇关于Go设计模式之观察者模式讲解和代码示例的文章就介绍到这了,更多相关Go观察者模式内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)!
精彩评论