java观察者模式怎么用

Java 的**观察者模式（Observer Pattern）**用于：一个对象状态变化时，自动通知依赖它的多个对象。

下面从 原生写法 和 JDK 自带实现 两种方式给你讲清楚。

一、JDK 自带的观察者模式（最简单）

Java 本身提供了：

• java.util.Observable（被观察者）
• java.util.Observer（观察者）

1️⃣ 被观察者（Subject）

import java.util.Observable;

public class NewsPublisher extends Observable {
    private String news;

    public void publishNews(String news) {
        this.news = news;
        setChanged();      // 标记状态已改变
        notifyObservers(news); // 通知观察者
    }

    public String getNews() {
        return news;
    }
}

2️⃣ 观察者（Observer）

import java.util.Observer;
import java.util.Observable;

public class User implements Observer {
    private String name;

    public User(String name) {
        this.name = name;
    }

    @Override
    public void update(Observable o, Object arg) {
        System.out.println(name + " 收到新闻: " + arg);
    }
}

3️⃣ 使用方式

public class Test {
    public static void main(String[] args) {
        NewsPublisher publisher = new NewsPublisher();

        User u1 = new User("张三");
        User u2 = new User("李四");

        publisher.addObserver(u1);
        publisher.addObserver(u2);

        publisher.publishNews("Java 21 发布了！");
    }
}

✅ 输出：

张三 收到新闻: Java 21 发布了！
李四 收到新闻: Java 21 发布了！

二、自己手写观察者模式（更常用 ⭐）

实际项目中更推荐自己写接口，因为：

• JDK 的 Observable 已被标记为过时
• 更灵活、可扩展

1️⃣ 定义观察者接口

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

2️⃣ 定义被观察者

import java.util.ArrayList;
import java.util.List;

public class Subject {
    private List<Observer> observers = new ArrayList<>();

    public void attach(Observer o) {
        observers.add(o);
    }

    public void detach(Observer o) {
        observers.remove(o);
    }

    public void notify(String message) {
        for (Observer o : observers) {
            o.update(message);
        }
    }
}

3️⃣ 具体观察者

public class ConcreteObserver implements Observer {
    private String name;

    public ConcreteObserver(String name) {
        this.name = name;
    }

    @Override
    public void update(String message) {
        System.out.println(name + " 收到消息: " + message);
    }
}

4️⃣ 使用

public class Test {
    public static void main(String[] args) {
        Subject subject = new Subject();

        Observer o1 = new ConcreteObserver("A");
        Observer o2 = new ConcreteObserver("B");

        subject.attach(o1);
        subject.attach(o2);

        subject.notify("系统更新了");
    }
}

三、常见使用场景

✅ GUI 事件（按钮点击）
✅ 消息推送
✅ 配置变更通知
✅ Spring 的 ApplicationEvent
✅ MQ / 发布订阅

四、总结一句话

观察者模式 = 一对多通知机制
被观察者负责“通知”，观察者负责“响应”。

如果你用的是 Spring / Android / 实际项目场景，我也可以给你对应版本的写法。