「设计模式」观察者模式（观察者系统重复）

前言

观察者模式归属于行为型设计模式，而行为型设计模式主要解决的是“类或对象之间的交互问题”。

观察者模式也被称为发布订阅者模式。

在 GoF 的《设计模式》一书中，它的定义是这样的：

Define a one-to-many dependency between objects so that when one object changes state, all its dependents are notified and updated automatically.

翻译成中文即为：在对象间定义了一个一对多的依赖，但这个对象改变状态的时候，所有它的依赖者都会收到通知，并自动更新。

一般情况下，被依赖的对象叫作被观察者（Observable），依赖的对象叫作观察者（Observer）。但也有其他的叫法，比如：Subject-Observer、Publisher-Subscriber、Producer-Consumer、EventEmitter-EventListener、Dispatcher-Listener。

根据应用场景的不同，观察者模式会有不同的代码实现方式：

同步阻塞的、异步非阻塞的
进程内的实现方式、跨进程的实现方式
....

同步阻塞的观察者模式被观察者

被观察者，或者可以称为事件的发送者。

根据定义，可以比较容易得出被观察者要做的事情：

注册/添加观察者
当事件发生时，通知观察者
有添加就有删除，所以还应该有一个删除观察者

interface Subject{ void registerObserver(Observer observer); void notifyObserver(Data data); void removeObserver(Observer observer); } class SubjectImpl implements Subject{ private List<Observer> observers=new ArrayList<>(); @Override public void registerObserver(Observer observer) { observers.add(observer); } @Override public void notifyObserver(Data data) { for(Observer observer:observers){ observer.update(data); } } @Override public void removeObserver(Observer observer) { observers.remove(observer); } }观察者

观察者，或者可以称为事件的接收者。

当对应事件变更的时候，会收到通知并进行自动更新

interface Observer{ void update(Data data); } class ObserverImpl_1 implements Observer{ @Override public void update(Data data) { System.out.println("ObserverImpl_1,收到***" data.getData()); } } class ObserverImpl_2 implements Observer{ @Override public void update(Data data) { System.out.println("ObserverImpl_2,收到***" data.getData()); } }传递的数据/信息

class Data{ private String data; Data(){ } Data(String str){ this.data=str; } public String getData() { return data; } public void setData(String data) { this.data = data; } }测试/示例

public class Demo { public static void main(String[] args) { Observer observer_1 = new ObserverImpl_1(); // 观察者1号 Observer observer_2 = new ObserverImpl_2(); // 观察者2号 Subject subject = new SubjectImpl(); // 被观察者 subject.registerObserver(observer_1); subject.registerObserver(observer_2); subject.notifyObserver(new Data("数据已发送变更")); } }异步非阻塞的观察者模式

如果只是做一个简单的实现，不考虑通用性、扩展性什么的，那么只需要在上述同步阻塞的观察者模式下，做些许的改动即可。有两种方案可以实现。