设计模式--观察者模式

观察者模式详解与示例

一、什么是观察者模式？

观察者模式（Observer Pattern）是一种行为型设计模式。它定义了对象之间的一种一对多依赖关系，使得当一个对象的状态发生变化时，所有依赖于它的对象都能得到通知并自动更新。这种模式常用于实现分布式事件处理系统。

二、观察者模式的组成

观察者模式主要由以下角色组成：

主题（Subject）：被观察的对象。它持有对观察者的引用，并在自身状态改变时通知观察者。
观察者（Observer）：对主题对象进行观察的对象。它在主题状态改变时接收通知并更新自身状态。
具体主题（Concrete Subject）：实现主题接口的类，负责存储状态以及通知观察者。
具体观察者（Concrete Observer）：实现观察者接口的类，负责响应主题的通知并更新自身状态。

三、观察者模式的优点与缺点

优点：

解耦：观察者和主题之间的耦合度低。观察者不需要了解具体的主题实现，只需关注如何处理通知。
扩展性：增加新的观察者不需要修改主题类的代码。
灵活性：允许动态注册和取消观察者。

缺点：

可能引发过多通知：如果观察者过多，主题可能会发送大量的通知，影响性能。
依赖管理复杂：观察者和主题之间的依赖关系管理可能会变得复杂，特别是在系统庞大的情况下。

四、观察者模式的实现

下面通过一个简单的 Java 示例来演示观察者模式的实现。假设我们有一个新闻发布系统，当有新新闻发布时，所有订阅者（观察者）都会收到通知。

1. 定义观察者接口

观察者接口声明了一个更新方法，该方法在主题状态变化时被调用：

public interface Observer {void update(String news);
}

2. 定义主题接口

主题接口声明了用于注册、注销观察者的方法，并定义了一个通知所有观察者的方法：

import java.util.ArrayList;
import java.util.List;public interface Subject {void registerObserver(Observer observer);void removeObserver(Observer observer);void notifyObservers();
}

3. 实现具体主题

具体主题实现了主题接口，并在状态改变时通知所有观察者：

public class NewsPublisher implements Subject {private List<Observer> observers = new ArrayList<>();private String news;@Overridepublic void registerObserver(Observer observer) {observers.add(observer);}@Overridepublic void removeObserver(Observer observer) {observers.remove(observer);}@Overridepublic void notifyObservers() {for (Observer observer : observers) {observer.update(news);}}public void setNews(String news) {this.news = news;notifyObservers();}
}

4. 实现具体观察者

具体观察者实现了观察者接口，并在收到通知时更新自身状态：

public class NewsSubscriber implements Observer {private String name;public NewsSubscriber(String name) {this.name = name;}@Overridepublic void update(String news) {System.out.println(name + " received news: " + news);}
}

5. 测试观察者模式

下面的代码演示了如何使用观察者模式：

public class Main {public static void main(String[] args) {NewsPublisher publisher = new NewsPublisher();Observer subscriber1 = new NewsSubscriber("Subscriber 1");Observer subscriber2 = new NewsSubscriber("Subscriber 2");publisher.registerObserver(subscriber1);publisher.registerObserver(subscriber2);publisher.setNews("Breaking News: Observer Pattern Implemented!");// 移除一个观察者publisher.removeObserver(subscriber1);publisher.setNews("Update: Subscriber 1 Removed!");}
}

输出：

Subscriber 1 received news: Breaking News: Observer Pattern Implemented!
Subscriber 2 received news: Breaking News: Observer Pattern Implemented!
Subscriber 2 received news: Update: Subscriber 1 Removed!