首页 > Golang > Go教程

Golang观察者模式实现全解析

时间：2025-11-05 10:57:45 323浏览收藏

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Golang观察者模式实现方法详解》，聊聊，希望可以帮助到正在努力赚钱的你。

Go语言中实现观察者模式有四种常见方式：1. 基于接口的标准模式，通过Subject和Observer接口实现松耦合；2. 使用channel实现异步通知，利用goroutine和channel进行非阻塞消息广播；3. 利用闭包简化观察者，以函数类型封装更新逻辑；4. 泛型支持的通用模式（Go 1.18+），可传递任意类型数据。选择方式需根据场景：标准接口适合结构清晰的系统，channel适合高并发，闭包适合轻量逻辑，泛型适合多类型数据传递。关键在于解耦主题与观察者，并注意并发安全与注销时的切片操作安全。

如何在Golang中实现观察者模式_Golang观察者模式实现方法汇总

在Go语言中实现观察者模式，核心是定义一个主题（Subject）和多个观察者（Observer），当主题状态发生变化时，自动通知所有注册的观察者。这种设计模式常用于事件处理系统、消息订阅等场景。以下是几种常见的Golang实现方式。

1. 基于接口的标准观察者模式

通过接口定义主题和观察者的行为，实现松耦合结构。

定义观察者和主题接口：

type Observer interface {
    Update(message string)
}
<p>type Subject interface {
Register(observer Observer)
Deregister(observer Observer)
Notify(message string)
}</p>

实现具体主题：

type ConcreteSubject struct {
    observers []Observer
}
<p>func (s *ConcreteSubject) Register(observer Observer) {
s.observers = append(s.observers, observer)
}</p><p>func (s *ConcreteSubject) Deregister(observer Observer) {
for i, obs := range s.observers {
if obs == observer {
s.observers = append(s.observers[:i], s.observers[i+1:]...)
break
}
}
}</p><p>func (s *ConcreteSubject) Notify(message string) {
for _, observer := range s.observers {
observer.Update(message)
}
}</p>

实现具体观察者：

type ConcreteObserver struct {
    name string
}
<p>func (o *ConcreteObserver) Update(message string) {
fmt.Printf("[%s] 收到消息: %s\n", o.name, message)
}</p>

使用示例：

subject := &ConcreteSubject{}
observerA := &ConcreteObserver{name: "A"}
observerB := &ConcreteObserver{name: "B"}
<p>subject.Register(observerA)
subject.Register(observerB)</p><p>subject.Notify("系统更新了")
// 输出：
// [A] 收到消息: 系统更新了
// [B] 收到消息: 系统更新了</p>

2. 使用channel实现异步通知

利用Go的并发特性，通过channel实现非阻塞的消息广播，适合高并发场景。

type AsyncSubject struct {
    register   chan Observer
    deregister chan Observer
    message    chan string
    observers  map[Observer]bool
}
<p>func NewAsyncSubject() *AsyncSubject {
subject := &AsyncSubject{
register:   make(chan Observer),
deregister: make(chan Observer),
message:    make(chan string),
observers:  make(map[Observer]bool),
}
go subject.start()
return subject
}</p><p>func (s *AsyncSubject) start() {
for {
select {
case observer := <-s.register:
s.observers[observer] = true
case observer := <-s.deregister:
delete(s.observers, observer)
case msg := <-s.message:
for observer := range s.observers {
go observer.Update(msg) // 异步通知
}
}
}
}</p><p>func (s *AsyncSubject) Register(observer Observer) {
s.register <- observer
}</p><p>func (s *AsyncSubject) Deregister(observer Observer) {
s.deregister <- observer
}</p><p>func (s *AsyncSubject) Notify(message string) {
s.message <- message
}</p>

这种方式将注册、注销和通知操作放入goroutine中处理，避免主线程阻塞。

3. 利用闭包简化观察者定义

如果不需要复杂的结构体，可以用函数类型和闭包快速实现轻量级观察者。

type Callback func(message string)
<p>type FuncObserver struct {
callback Callback
}</p><p>func (f *FuncObserver) Update(message string) {
f.callback(message)
}</p><p>// 使用示例
observer := &FuncObserver{
callback: func(msg string) {
fmt.Println("闭包收到:", msg)
},
}</p>

这种方式适合逻辑简单的监听场景，代码更简洁。

4. 泛型支持的通用观察者模式（Go 1.18+）

使用泛型可以让观察者模式支持不同类型的数据传递。

type GenericObserver[T any] interface {
    OnEvent(data T)
}
<p>type GenericSubject[T any] struct {
observers []GenericObserver[T]
}</p><p>func (s *GenericSubject[T]) Attach(obs GenericObserver[T]) {
s.observers = append(s.observers, obs)
}</p><p>func (s *GenericSubject[T]) Notify(data T) {
for _, obs := range s.observers {
obs.OnEvent(data)
}
}</p>

可以用于传递结构体、数字等任意类型数据。

基本上就这些常见实现方式。选择哪种取决于你的需求：标准接口适合清晰结构，channel适合高并发，闭包适合轻量逻辑，泛型适合类型多样的场景。关键是理解主题与观察者之间的解耦关系。不复杂但容易忽略细节，比如注销时的切片操作安全性和并发访问控制。实际项目中建议结合sync.Mutex保护共享状态。

终于介绍完啦！小伙伴们，这篇关于《Golang观察者模式实现全解析》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！