Skip to main content
 首页 » 编程设计

使用go实现观察者模式

2022年07月19日131zhujiabin

观察者模式

定义

观察者模式(Observer Design Pattern)定义了一种一对多的依赖关系,让多个观察者对象同时监听一个主题对象。这个主题对象在状态发生变化的时,会通知所有的观察者对象,使他们能够更新自己。

定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。

适用场景

1、当一个对象状态的改变需要改变其他对象,或实际对象是事先未知的或动态变化的,可使用观察者模式;

2、当应用中的一些对象必须观察其他对象时,可使用该模式。但仅能在有限时间内或特定情况下使用。

优点

1、降低了目标与观察者之间的耦合关系,两者之间是抽象耦合关系。

2、目标与观察者之间建立了一套触发机制。

缺点

1、目标与观察者之间的依赖关系并没有完全解除,而且有可能出现循环引用。

2、当观察者对象很多时,通知的发布会花费很多时间,影响程序的效率。

代码实现

被观察者有信息更新的时候,通知到所有的观察者。

type Subject struct { 
	observers []Observer 
	context   string 
} 
 
func NewSubject() *Subject { 
	return &Subject{ 
		observers: make([]Observer, 0), 
	} 
} 
 
func (s *Subject) Attach(o Observer) { 
	s.observers = append(s.observers, o) 
} 
 
func (s *Subject) notify() { 
	for _, o := range s.observers { 
		o.Update(s) 
	} 
} 
 
func (s *Subject) UpdateContext(context string) { 
	s.context = context 
	s.notify() 
} 
 
type Observer interface { 
	Update(*Subject) 
} 
 
type Customer struct { 
	name string 
} 
 
func NewCustomer(name string) *Customer { 
	return &Customer{ 
		name: name, 
	} 
} 
 
func (r *Customer) Update(s *Subject) { 
	fmt.Printf("%s received %s\n", r.name, s.context) 
} 

测试代码

func TestObserver(t *testing.T) { 
	subject := NewSubject() 
	reader1 := NewCustomer("小明") 
	reader2 := NewCustomer("小红") 
	reader3 := NewCustomer("小李") 
	subject.Attach(reader1) 
	subject.Attach(reader2) 
	subject.Attach(reader3) 
 
	for i := 1; i <= 10; i++ { 
		subject.UpdateContext(fmt.Sprintf("更新了%d", i)) 
		fmt.Println("+++++++++++++++++++++++++++++++++") 
	} 
} 

结构图

observer

不同场景的实现方式

针对应用场景有下面四种实现方式

1、同步阻塞的实现方式;

2、异步非阻塞的实现方式;

3、进程内的实现方式;

4、跨进程的实现方式。

栗如:可以基于消息队列实现

观察模式和发布订阅模式

有的地方会讲观察者模式不是发布订阅模式

认为发布订阅模式相对于观察者模式多了一个 Broker 来协调信息的发送者和订阅者,而观察模式是直接通知观察者。

进而认为两者的藕合程度也是不同,观察者和被观察者,是松耦合的关系,发布者和订阅者,则完全不存在耦合。

不过感觉者没有明显的区别:

观察模式中有同步阻塞的实现方式,也有异步非阻塞的实现方式;有进程内的实现方式,也有跨进程的实现方式。

被观察者直接通知到观察者这种场景就是同步阻塞的实现方式。

在被观察者和观察者之间加入一个消息对列,这种方式使得两者能够更加的解耦,这是观察者模式中异步非阻塞的实现方式。

因此观察者模式可以认为就是发布订阅模式,当然掌握其中的精髓,然后运用到我们的业务中才是最重要的,至于是或不是其实也没那么重要了。

参考

【文中代码】https://github.com/boilingfrog/design-pattern-learning/tree/master/观察者模式
【大话设计模式】https://book.douban.com/subject/2334288/
【极客时间】https://time.geekbang.org/column/intro/100039001
【golang-design-pattern】https://github.com/senghoo/golang-design-pattern
【Observer vs Pub-Sub pattern】https://hackernoon.com/observer-vs-pub-sub-pattern-50d3b27f838c
【观察者模式】https://boilingfrog.github.io/2021/11/18/使用go实现观察者模式/


本文参考链接:https://www.cnblogs.com/ricklz/p/15573403.html
阅读延展