设计模式--观察者模式

07-21 1000阅读

观察者模式详解与示例

一、什么是观察者模式？

观察者模式（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 observers = new ArrayList();
    private String news;
    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }
    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }
    @Override
    public 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;
    }
    @Override
    public 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!