java observer模式代码怎么写

下面给你一个Java 中 Observer（观察者）模式的完整示例，包括 JDK 自带方式 和 手写实现方式，方便理解。

一、使用 JDK 自带的 Observer（不推荐，已过时）

⚠️ java.util.Observer 和 Observable 在 Java 9 已被标记过时，但适合学习。

1. 被观察者（主题）

import java.util.Observable;

public class NewsPublisher extends Observable {
    private String news;

    public void publishNews(String news) {
        this.news = news;
        setChanged();      // 标记状态改变
        notifyObservers(news);
    }
}

2. 观察者

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 发布了！");
    }
}

二、手写 Observer 模式（推荐 ✅）

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 observer) {
        observers.add(observer);
    }

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

    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("系统升级维护中");
    }
}

三、实际开发推荐方式

✅ Java 8+ 用函数式接口更简单

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

public class EventBus {
    private List<Consumer<String>> listeners = new ArrayList<>();

    public void register(Consumer<String> listener) {
        listeners.add(listener);
    }

    public void publish(String msg) {
        listeners.forEach(l -> l.accept(msg));
    }
}

EventBus bus = new EventBus();
bus.register(msg -> System.out.println("收到: " + msg));
bus.publish("Hello Observer");

如果你愿意，我也可以帮你写：

• ✅ Spring 中的 @EventListener
• ✅ 消息推送系统示例
• ✅ 多线程安全的 Observer

你是学习设计模式还是实际项目使用？