1.概述

发布订阅模式又叫观察者模式（Observer Pattern），它是指对象之间一对多的依赖关系，每当那个特定对象改变状态时，所有依赖于它的对象都会得到通知并被自动更新，它是行为型模式的一种。观察者模式内部有一个“主题”对象和若干个“观察者”对象，“主题对象”和“观察者”对象是一对多的依赖关系，当“主题”的状态发生变化时，所有“观察者”都得到通知。本文将详述观察者模式的原理及使用方式。

2.原理及使用

2.1 原理

观察者模式UML类图如下：
在这里插入图片描述

类图中包含的核心角色有：Subject（抽象被观察者）、ConcreteSubject（具体被观察者）、Observer（抽象观察者）、ObserverA、ObserverB、ObserverC（具体观察者），详细解释如下：

Subject（抽象被观察者）：它定义了一个集合，存储所有的观察者，且对外提供添加和删除观察者的接口；
ConcreteSubject（具体被观察者）：具体角色将有关状态存入具体观察者对象，当具体主题的内部状态发生改变时，会给所有注册过的观察者发送通知；
Observer（抽象观察者）：观察者抽象类，它定义了一个更新接口，使得在得到主题更改时，更新自身数据；
ObserverA（具体观察者）：具体观察者，实现抽象观察者定义的更新接口，以便在主题更新时更新自身的状态。

2.2 案例

小王喜欢炒股，但他是个工薪族，白天还需要上班，他又不能辞职全职炒股（因为还有老婆孩子要养），因此他想到一个好办法，找一个股神帮助自己炒股，股神会根据行情告诉你什么时候买入、什么时候卖出，股神每年会收一定费用。

分析：上述案例中，股神就是典型的被观察者，小王就是典型的观察者，一旦观察到股神给他发的信息，就执行买入卖出动作，股神负责通知小王这种观察者。编码如下：

public abstract class Observer {public String name;public StockManager stockManager;public abstract void buy(Stock stock);public abstract void sale(Stock stock);}@Data
public class Stock {/*** 股票名称*/private String name;/*** 买入或卖出数量*/private Integer num;/*** 买入或卖出价格*/private Double price;
}@Data
@NoArgsConstructor
@AllArgsConstructor
public class StockManager {private List<Observer> lists = new ArrayList<>();public StockManager(String name) {this.name = name;}private String name;private Stock stock;public void notifyAllObserversBuy() {lists.forEach(list -> {System.out.println("通知：" + list.name);list.buy(stock);});}public void notifyAllObserversSale() {lists.forEach(list -> {System.out.println("通知：" + list.name);list.sale(stock);});}public void add(Observer observer) {lists.add(observer);System.out.println("添加新的投资客户：" + observer.name);}public void remove(Observer observer) {lists.remove(observer);System.out.println("删除老的投资客户：" + observer.name);}}public class WangObserver extends Observer {public WangObserver(StockManager stockManager, String name) {this.stockManager = stockManager;this.name = name;}@Overridepublic void buy(Stock stock) {System.out.println(name + "购买股票：" + stock.getName() + ",成交价格：" + stock.getPrice() + ",成交数量：" + stock.getNum());}@Overridepublic void sale(Stock stock) {System.out.println(name + "卖出股票：" + stock.getName() + ",成交价格：" + stock.getPrice() + ",成交数量：" + stock.getNum());}
}public class ZhangObserver extends Observer {public ZhangObserver(StockManager stockManager, String name) {this.stockManager = stockManager;this.name = name;}@Overridepublic void buy(Stock stock) {System.out.println(name + "购买股票：" + stock.getName() + ",成交价格：" + stock.getPrice() + ",成交数量：" + stock.getNum());}@Overridepublic void sale(Stock stock) {System.out.println(name + "卖出股票：" + stock.getName() + ",成交价格：" + stock.getPrice() + ",成交数量：" + stock.getNum());}
}public class Client {public static void main(String[] args) {StockManager stockManager = new StockManager("巴菲特");ZhangObserver zhangObserver = new ZhangObserver(stockManager, "小张");WangObserver wangObserver = new WangObserver(stockManager, "小王");stockManager.add(zhangObserver);stockManager.add(wangObserver);Stock stock = new Stock();stock.setName("贵州茅台");stock.setNum(1000);stock.setPrice(1589.0);stockManager.setStock(stock);stockManager.notifyAllObserversBuy();System.out.println("-------------------------");stock.setPrice(1899.0);stockManager.notifyAllObserversSale();}
}