观察者模式通过Subject和Observer接口实现事件驱动，Go中可用接口与切片维护订阅关系，配合sync.RWMutex保证并发安全，示例中EventBus注册、注销并通知观察者，Logger与Notifier响应事件，主函数演示注册、触发与移除流程。
在Go语言中，观察者模式常用于实现事件处理系统，让多个对象（观察者）监听某个主体（被观察者）的状态变化或事件发生。这种模式在解耦事件发布者和订阅者方面非常有效，适合构建灵活的事件驱动程序。
定义事件主体和观察者接口
观察者模式的核心是被观察者维护一个观察者列表，并在状态变化时通知它们。先定义两个基本接口：
- Subject（被观察者）：管理观察者并负责通知。- Observer（观察者）：定义接收通知的方法。
示例代码：
type Event stringtype Observer interface { OnEvent(event Event) }
type Subject interface { Register(obs Observer) Unregister(obs Observer) Notify(event Event) }
实现具体的被观察者
创建一个结构体来实现 Subject 接口。它使用切片保存观察者列表，注意并发安全时可使用 sync.RWMutex。
立即学习“go语言免费学习笔记（深入）”；
动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包
type EventBus struct {
observers []Observer
mu sync.RWMutex
}
func (bus *EventBus) Register(obs Observer) {
bus.mu.Lock()
defer bus.mu.Unlock()
bus.observers = append(bus.observers, obs)
}
func (bus *EventBus) Unregister(obs Observer) {
bus.mu.Lock()
defer bus.mu.Unlock()
for i, o := range bus.observers {
if o == obs {
bus.observers = append(bus.observers[:i], bus.observers[i+1:]...)
break
}
}
}
func (bus *EventBus) Notify(event Event) {
bus.mu.RLock()
defer bus.mu.RUnlock()
for _, obs := range bus.observers {
obs.OnEvent(event)
}
}
编写具体的观察者
每个观察者实现 OnEvent 方法，定义自己对事件的响应逻辑。
type Logger struct{}
func (l *Logger) OnEvent(event Event) {
log.Printf("日志记录: %s", event)
}
type Notifier struct{}
func (n *Notifier) OnEvent(event Event) {
fmt.Printf("发送通知: %s\n", event)
}
使用示例
将观察者注册到事件总线，触发事件后自动广播给所有订阅者。
func main() {
bus := &EventBus{}
logger := &Logger{}
notifier := &Notifier{}
bus.Register(logger)
bus.Register(notifier)
bus.Notify("user.login") // 两个观察者都会收到通知
bus.Unregister(notifier)
bus.Notify("system.shutdown") // 只有 logger 收到}
基本上就这些。通过接口和组合，Go能简洁地实现观察者模式。如果项目更复杂，可扩展支持事件类型过滤、异步通知或基于 channel 的轻量机制。关键是保持订阅与通知逻辑清晰，避免内存泄漏（及时注销观察者）。
