在 go 语言中实现观察者模式的核心是构建“发布-订阅”机制，通过接口和结构体组合模拟 subject 和 observer 角色；1. 定义 observer 和 subject 接口，其中 observer 包含 update 方法，subject 包含 register、unregister 和 notify 方法；2. 实现 concretesubject 结构体，维护观察者列表并实现注册、注销与通知逻辑；3. 创建具体观察者如 emailnotifier 和 smsnotifier，分别实现 update 方法以响应通知；4. 可通过引入 goroutine 实现异步通知，提升性能的同时需注意并发控制；5. 细节上应避免重复注册、空指针注册及切片删除错误，增强程序健壮性。
在 Go 语言中实现观察者模式，核心在于“发布-订阅”机制的构建。观察者模式适用于当一个对象的状态发生变化时，需要通知多个依赖对象做出响应的场景。Golang虽然没有传统的类和继承机制，但借助接口和结构体组合，可以很自然地实现这种设计模式。
基本结构：定义主题与观察者接口
观察者模式通常包含两个主要角色：Subject（主题） 和 Observer（观察者）。
在 Golang 中，可以通过接口来抽象这两个角色：
立即学习“go语言免费学习笔记（深入）”；
type Observer interface {
Update(message string)
}
type Subject interface {
Register(observer Observer)
Unregister(observer Observer)
Notify(message string)
}然后我们实现具体的 Subject 结构体，比如一个简单的事件广播器：
type ConcreteSubject struct {
observers []Observer
}
func (s *ConcreteSubject) Register(o Observer) {
s.observers = append(s.observers, o)
}
func (s *ConcreteSubject) Unregister(o Observer) {
for i, observer := range s.observers {
if observer == o {
s.observers = append(s.observers[:i], s.observers[i+1:]...)
break
}
}
}
func (s *ConcreteSubject) Notify(message string) {
for _, observer := range s.observers {
observer.Update(message)
}
}这样就完成了基本框架的搭建，接下来只需要实现具体的观察者即可。
实现具体观察者：灵活响应通知
每个观察者只要实现 Update 方法就能接收通知。例如我们可以定义两个观察者：
type EmailNotifier struct{}
func (e *EmailNotifier) Update(message string) {
fmt.Println("发送邮件通知：", message)
}
type SMSNotifier struct{}
func (s *SMSNotifier) Update(message string) {
fmt.Println("发送短信通知：", message)
}当某个事件发生时，调用 Notify() 方法，所有注册过的观察者都会收到消息：
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
subject := &ConcreteSubject{}
email := &EmailNotifier{}
sms := &SMSNotifier{}
subject.Register(email)
subject.Register(sms)
subject.Notify("系统即将维护")输出结果：
发送邮件通知：系统即将维护 发送短信通知：系统即将维护
这说明观察者已经成功接收到通知并执行了各自逻辑。
进阶技巧：使用 channel 支持异步通知
上面的例子是同步通知，即所有观察者的 Update 方法会在主线程中依次执行。如果某些操作比较耗时，可能会阻塞整个流程。
为了提升性能，可以将通知过程改为异步：
func (s *ConcreteSubject) NotifyAsync(message string) {
for _, observer := range s.observers {
go func(o Observer) {
o.Update(message)
}(observer)
}
}这样每个观察者的更新操作都会在独立的 goroutine 中运行，互不干扰。
注意：异步通知可能导致并发问题，比如多个 goroutine 同时修改共享资源。建议观察者的 Update 方法本身是线程安全的，或者通过加锁、通道等方式控制并发。
小细节提醒：避免重复注册与空指针
在实际使用中，有几个小细节容易被忽略：
- 避免重复注册同一个观察者
- 防止注册 nil 指针导致 panic
- 在 unregister 时注意切片操作是否正确删除
你可以做如下改进：
func (s *ConcreteSubject) Register(o Observer) {
if o == nil {
return
}
for _, existing := range s.observers {
if existing == o {
return // 已存在则不再注册
}
}
s.observers = append(s.observers, o)
}这样能有效防止一些潜在的 bug。
基本上就这些。Go 语言虽然没有内置的观察者支持，但凭借其简洁的语法和强大的并发能力，实现起来既直观又高效。只要把接口设计清楚，再结合结构体和 goroutine，就可以轻松构建出功能完善的观察者系统。
