原理

观察者模式属于行为模式，行为模式主要解决类和对象之间交互问题。
含义：在对象之间定义一个一对多的依赖，当一个对象状态改变时，所有依赖的对象会自动通知。

被依赖的对象被观察者(Observable) ，依赖的对象观察者(Observer)，当然也可以叫发布-订阅等。

一个case

比如我们维护的用户中心，当用户进行注册的时候，就进行通知发送短信、WA、邮件等。

1.第一步，先定义被观察者接口，主要就是注册、删除、已经通知观察者。

/**
 * @author qxlx
 * @date 2024/4/13 22:25
 */
public interface Subject {

    /**
     * 注册
     * @param observer
     */
    void registerObserver(Observer observer);

    /**
     * 删除
     * @param observer
     */
    void deleteObserver(Observer observer);

    /**
     * 发送事件
     * @param message
     */
    void notifyObservers(String message);
}

2.定义贯彻者具体的行为

public interface Observer {

    void notify(String message);

}

3.被观察者的具体实现，可以发送通过接口注册或删除观察者，当被观察者执行用户注册的方法时，就会触发通知观察者进行处理。
这里需要明确下，可以采用同步的方式 或者异步方式。因为对于注册接口来说响应时间还是比较重要的，采用线程的方式 可以提高接口性能。

/**
 * @author qxlx
 * @date 2024/4/13 22:27
 */
public class ConcreteSubject implements Subject {

    private List<Observer> observerList = new CopyOnWriteArrayList<>();

    @Override
    public void registerObserver(Observer observer) {
        observerList.add(observer);
    }

    @Override
    public void deleteObserver(Observer observer) {
        observerList.remove(observer);
    }

    @Override
    public void notifyObservers(String message) {
        // 1.同步调用
        // 2.异步非阻塞
        observerList.forEach(o -> o.notify(message));

        // new Thread()
        new Thread(() -> {
            observerList.forEach(o -> o.notify(message));
        }).start();

        // 线程池
        ThreadPoolUtil.getThreadPool(10).
                execute(() -> observerList.forEach(o -> o.notify(message)));

    }
}

4.定义具体的观察者实现类，发送邮件 或者发送wa

public class UserSendEmailObserver implements Observer{

    @Override
    public void notify(String message) {
        System.out.println("用户注册成功,发送邮件通知!");
    }

}

public class UserWaSendObserver implements Observer{

    @Override
    public void notify(String message) {
        System.out.println("用户注册成功,发送了wa通知");
    }
}

最终的Demo 其实就是这样，将观察者添加到被观察者上，观察者一旦执行了用户注册，就会触发对应动作，比如说新增新的动作，那么就可以直接添加一个发优惠卷的观察者。可以很好的进行拓展。

    public static void main(String[] args) {
        UserSendEmailObserver userSendEmailObserver = new UserSendEmailObserver();
        UserWaSendObserver userWaSendObserver = new UserWaSendObserver();
        ConcreteSubject concreteSubject = new ConcreteSubject();

        concreteSubject.registerObserver(userSendEmailObserver);
        concreteSubject.registerObserver(userWaSendObserver);

        concreteSubject.notifyObservers("register");
    }

Spring 中如何应用观察者模式

在spring源码中，IOC容器进行初始化的过程中，refresh() 方法中就包含观察者模式。而Spring进行了抽象，也就是将观察者和被观察者 进行调整成多播器和监听器，通过事件来驱动监听器的执行。

可以看到，整体的流程就是，初始化多播器对象，SimpleApplicationEventMulticaster，将监听器添加到多播器中。然后发布事件，调用监听器进行处理。可以发现其实设计模式在实际的应用中，思想相同的，但是落地的时候都有自己的调整。本质上还是当多个对象所依赖的对象有对应的事件时，需要做对应的动作。解耦合观察者和被观察者。

	//初始化事件多播功能（事件派发） Initialize event multicaster for this context.
	//初始化多播器 SimpleApplicationEventMulticaster 注册到IOC容器中
	initApplicationEventMulticaster();

	//注册监听器，从容器中获取所有的ApplicationListener；
	// Check for listener beans and register them.
	registerListeners();

	//发布事件 Last step: publish corresponding event.
	finishRefresh();