1. 观察者模式概述观察者模式Observer Pattern是23种经典设计模式中行为型模式的一种它定义了对象之间的一对多依赖关系当一个对象的状态发生改变时所有依赖于它的对象都会得到通知并自动更新。这种模式在事件驱动系统、消息队列、GUI组件交互等场景中应用广泛。我在实际项目中最常遇到观察者模式的场景是用户通知系统。比如当某个商品价格变动时所有关注该商品的用户都需要收到通知。如果不用观察者模式我们可能需要写大量硬编码的条件判断和手动调用而观察者模式让这种一对多的通知变得优雅而高效。2. 观察者模式的核心结构2.1 角色划分观察者模式主要包含四个核心角色Subject主题被观察的对象维护一个观察者列表提供添加、删除观察者的方法以及通知观察者的机制。在Java中通常是一个接口或抽象类。ConcreteSubject具体主题Subject的具体实现维护自身状态当状态改变时通知所有注册的观察者。Observer观察者定义更新接口在接到主题通知时更新自己。通常是一个接口。ConcreteObserver具体观察者Observer的具体实现维护一个指向ConcreteSubject的引用实现更新逻辑。2.2 UML类图解析[Subject] - [ConcreteSubject] [Subject] - [Observer] [Observer] - [ConcreteObserver]这种结构体现了松耦合的设计思想 - 主题只知道观察者实现了某个接口但不知道具体观察者是谁同样观察者也只知道主题的接口。这种松耦合让系统更灵活更容易扩展新的观察者或主题。3. 观察者模式的实现方式3.1 推模型 vs 拉模型观察者模式有两种主要的实现方式推模型Push Model主题将详细的变更信息推送给观察者。这种方式效率高但不够灵活观察者可能收到不需要的数据。拉模型Pull Model主题只通知观察者状态已改变观察者根据需要从主题拉取数据。这种方式更灵活但可能增加系统开销。在实际项目中我通常根据以下原则选择如果观察者总是需要全部数据 → 推模型如果观察者需要选择性获取数据 → 拉模型如果网络带宽是瓶颈 → 拉模型3.2 Java内置观察者实现Java在java.util包中提供了Observable类和Observer接口这是观察者模式的经典实现。不过从Java 9开始它被标记为Deprecated主要是因为不是接口而是类限制了复用性方法是同步的可能影响性能没有提供丰富的功能如过滤特定事件尽管如此对于简单的场景它仍然是一个不错的选择。下面是一个使用Java内置观察者的示例// 被观察者 class WeatherData extends Observable { private float temperature; public void setTemperature(float temp) { this.temperature temp; setChanged(); // 标记状态已改变 notifyObservers(temp); // 通知观察者 } } // 观察者 class Display implements Observer { Override public void update(Observable o, Object arg) { System.out.println(温度更新为: arg); } } // 使用 WeatherData weatherData new WeatherData(); Display display new Display(); weatherData.addObserver(display); weatherData.setTemperature(25.5f);3.3 自定义观察者实现对于更复杂的场景我通常会自定义观察者模式。以下是一个更灵活的实现// 主题接口 interface SubjectT { void registerObserver(ObserverT o); void removeObserver(ObserverT o); void notifyObservers(T data); } // 观察者接口 interface ObserverT { void update(T data); } // 具体主题 class NewsPublisher implements SubjectString { private ListObserverString observers new ArrayList(); Override public void registerObserver(ObserverString o) { observers.add(o); } Override public void notifyObservers(String news) { for (ObserverString o : observers) { o.update(news); } } public void publishNews(String news) { System.out.println(发布新闻: news); notifyObservers(news); } } // 具体观察者 class NewsSubscriber implements ObserverString { private String name; public NewsSubscriber(String name) { this.name name; } Override public void update(String news) { System.out.println(name 收到新闻: news); } }4. 观察者模式的高级应用4.1 事件总线实现在大型系统中直接使用观察者模式可能导致观察者列表过长影响性能。这时可以使用事件总线Event Bus作为中间层class EventBus { private MapClass?, ListConsumer? handlers new ConcurrentHashMap(); public T void subscribe(ClassT eventType, ConsumerT handler) { handlers.computeIfAbsent(eventType, k - new ArrayList()).add(handler); } SuppressWarnings(unchecked) public T void publish(T event) { ListConsumer? consumers handlers.get(event.getClass()); if (consumers ! null) { consumers.forEach(c - ((ConsumerT)c).accept(event)); } } } // 使用示例 EventBus bus new EventBus(); bus.subscribe(String.class, msg - System.out.println(处理字符串: msg)); bus.publish(测试消息);4.2 响应式编程中的观察者现代响应式编程库如RxJava、Reactor都基于观察者模式的变体。以RxJava为例ObservableString observable Observable.create(emitter - { emitter.onNext(消息1); emitter.onNext(消息2); emitter.onComplete(); }); ObserverString observer new ObserverString() { Override public void onNext(String s) { System.out.println(收到: s); } Override public void onComplete() { System.out.println(完成); } }; observable.subscribe(observer);响应式编程扩展了传统观察者模式增加了背压处理、错误处理、线程调度等高级特性。5. 观察者模式的优缺点与适用场景5.1 优点分析松耦合主题和观察者之间抽象耦合彼此不知道对方的具体实现。动态关系可以在运行时动态添加或删除观察者。广播通信一个主题变更可以通知多个观察者无需显式指定。符合开闭原则新增观察者无需修改主题代码。5.2 缺点与注意事项通知顺序不确定观察者被通知的顺序通常是不确定的不应依赖特定顺序。性能问题如果观察者过多或处理耗时可能导致系统性能下降。内存泄漏观察者忘记注销可能导致内存泄漏特别是在长生命周期的主题中。循环依赖观察者之间相互通知可能导致无限循环。5.3 最佳实践场景根据我的经验观察者模式特别适合以下场景事件驱动系统如GUI事件处理、异步消息处理。监控系统如系统状态监控、性能指标收集。发布-订阅模型如新闻推送、社交媒体更新。分布式系统如服务状态变更通知。6. 观察者模式与其他模式的关系6.1 与发布-订阅模式的区别很多人容易混淆观察者模式和发布-订阅模式它们确实相似但有重要区别耦合度观察者模式中主题知道观察者发布-订阅模式中发布者和订阅者通过中间件通信彼此不知道对方。同步性观察者模式通常是同步的发布-订阅模式通常是异步的。实现复杂度发布-订阅模式通常需要消息代理实现更复杂。6.2 与中介者模式的对比中介者模式也处理对象间通信但目的不同观察者模式一个对象通知多个依赖对象中介者模式集中管理多个对象间的复杂交互7. 实际项目中的经验分享7.1 性能优化技巧在大规模使用观察者模式时我总结了一些性能优化经验批量通知对于高频变更的主题可以实现批量通知机制积累一定量变更后统一通知。异步通知使用线程池异步通知观察者避免阻塞主题线程。观察者分级根据观察者的重要性分级关键观察者同步通知非关键观察者异步通知。懒加载观察者对于资源密集型观察者可以实现懒加载机制。7.2 常见问题排查通知丢失确保在主题状态变更后调用通知方法最好在setter方法中自动触发。内存泄漏使用WeakReference存储观察者引用或确保在适当时候注销观察者。线程安全问题如果主题和观察者可能在不同线程访问需要同步观察者列表操作。过度通知实现状态变更检测只有真正改变时才通知。7.3 测试策略测试观察者模式时我通常采用以下策略模拟观察者使用Mock对象验证是否收到正确通知。通知顺序测试如果业务依赖通知顺序需要专门测试。并发测试模拟多线程环境下的通知行为。性能测试测量大量观察者时的通知延迟。8. 现代Java中的观察者模式8.1 Java 9的替代方案由于java.util.Observable被废弃现代Java项目可以考虑PropertyChangeListenerJavaBeans的标准属性变更通知机制。Flow APIJava 9引入的响应式流API。第三方库如Guava的EventBus、Spring的事件机制。8.2 Spring框架中的观察者Spring框架内置了强大的观察者模式实现// 定义事件 class MyEvent extends ApplicationEvent { public MyEvent(Object source) { super(source); } } // 发布事件 Component class EventPublisher { Autowired private ApplicationEventPublisher publisher; public void publish() { publisher.publishEvent(new MyEvent(this)); } } // 监听事件 Component class EventListener { EventListener public void handle(MyEvent event) { System.out.println(收到事件: event); } }Spring的实现支持异步事件、条件监听、事务绑定等高级特性。9. 观察者模式的演进与未来随着响应式编程的流行观察者模式也在不断发展响应式流提供背压支持防止生产者压垮消费者。函数式风格使用Lambda表达式简化观察者实现。跨语言支持如Web的WebSocket、gRPC的流式调用。分布式观察者如使用消息队列实现跨服务的观察者模式。观察者模式作为解耦组件的重要工具在未来系统设计中仍将扮演关键角色。掌握其核心思想并能根据具体场景灵活变通是每个开发者必备的技能。