观察者模式本质上就两个关键的操作，观察者关心自己订阅的主题，主题数据有变化需要通知所有的观察者。
举个🌰
在武侠甚至玄幻小说中，天人合一一直都是一个重要的，无法缺失的概念。天人合一一直以来都是天骄的专属名词。在我的理解中，天人合一是人的频率和自然的频率形成共振，从而达到人从自然中获得特殊频率的过程
从代码层面来解析
首先，需要定义主题，每个主题需要持有观察者列表的引用，用于在数据变更的时候通知各个观察者；其中天就是主题，在天人合一（订阅）的状态下，自热频率的每一刻的变动都需要同步到人
主题：天
public class SkySubject {private List<PersonObserver> observers = new ArrayList<PersonObserver>();private int state;public int getState() {return state;}public void setState(int state) {this.state = state;// 频率已变更，通知观察者们notifyAllObservers();}public void attach(PersonObserver observer){observers.add(observer); }// 通知观察者们public void notifyAllObservers(){for (PersonObserver observer : observers) {observer.update();}}
}
观察者：观察者则是人，能够进入天人合一的状态、退出天人合一的状态。同时在天人合一的状态写被动的接受自然的频率。人则是抽象的概念，每一个人都有机会进入天人合一的状态
public abstract class Observer {protected SkySubject subject;public abstract void update();
}
定义具体的观察者
//张三在天人合一下领悟混元大手印
public class ZhangSanObserver extends SkyObserver {// 在构造方法中进行订阅主题public ZhangSanObserver(SkySubject subject) {this.subject = subject;// 通常在构造方法中将 this 发布出去的操作一定要小心this.subject.attach(this);}// 该方法由主题类在数据变更的时候进行调用@Overridepublic void update() {System.out.println("领悟混元大手印");}
}//李四在天人合一领悟五行遁法
public class LiSiObserver extends Observer {public LiSiObserver(SkySubject subject) {this.subject = subject;this.subject.attach(this);}@Overridepublic void update() {System.out.println("领悟五行遁法");}
}
客户端使用
public static void main(String[] args) {// 先定义一个主题SkySubject subject1 = new SkySubject();// 定义观察者new ZhangSanObserver(subject1);new LiSiObserver(subject1);// 模拟自然频率变动，这个时候，观察者们的 update 方法将会被调用subject.setState(11);
}
实际生产过程中，观察者模式往往用消息中间件来实现，如果要实现单机观察者模式，笔者建议读者使用 Guava 中的 EventBus，它有同步实现也有异步实现
