（九）观察者模式

2019-11-08 18:50:45

字体：大中小

来源：转载

供稿：网友

观察者模式（又被称为发布-订阅（Publish/Subscribe）模式，属于行为型模式的一种，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时，会通知所有的观察者对象，使他们能够自动更新自己。

这里写图片描述

Subject：抽象主题（抽象被观察者），抽象主题角色把所有观察者对象保存在一个集合里，每个主题都可以有任意数量的观察者，抽象主题提供一个接口，可以增加和删除观察者对象。ConcreteSubject：具体主题（具体被观察者），该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。Observer：抽象观察者，是观察者者的抽象类，它定义了一个更新接口，使得在得到主题更改通知时更新自己。ConcrereObserver：具体观察者，是实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

举个例子，比如某个品牌的车由于某种故障需要召回，这时4S电发出通知，所有符合召回条件的车，接收到通知去4S点，把故障修复掉。

首先要有个抽象的观察者，负责观察这件事

public interface Observer { public void updateCar(String message);}

所有的车主，都是观察者

public class Owner implements Observer { PRivate String ownerName; public Owner(String ownerName) { this.ownerName = ownerName; } @Override public void updateCar(String message) { System.out.println(ownerName + "-" + message); }}

要有个4s店的抽象类，类里面方法有添加车主，删除车主，和发通知

public interface Stores_4s { /** * 增加订阅者 * @param observer */ public void attach(Observer observer); /** * 删除订阅者 * @param observer */ public void detach(Observer observer); /** * 通知订阅者更新消息 */ public void notify(String message);}

创建一个东风4S店

public class DFStores implements Stores_4s { private List<Observer> ownerList = new ArrayList<Observer>(); @Override public void attach(Observer observer) { ownerList.add(observer); } @Override public void detach(Observer observer) { ownerList.remove(observer); } @Override public void notify(String message) { for (Observer observer: ownerList) { observer.updateCar(message); } } public static void main(String[] args) { Stores_4s stores = new DFStores(); Owner owner = new Owner("张三"); Owner owner1 = new Owner("李四"); Owner owner2 = new Owner("王五"); stores.attach(owner); stores.attach(owner1); stores.attach(owner2); stores.notify("发动机故障，需要召回换发动机。"); }}

优点当然就是解耦了，让耦合的双方都依赖于抽象，从而使得各自的变换都不会影响另一边的变换。

如果观察者比较多，或者其中一个观察者执行时间比较长，就会导致整个程序比较慢，现在大多数情况下，都是采用MQ的异步消息通知机制。常用的MQ有，RabbitMq、ActiveMq、ZeroMq、kafka。还有阿里的RocketMQ，已经捐献给了apache，还在孵化阶段。

上一篇：自己动手安装交叉编译工具链

下一篇：myeclipse中复制的web项目在部署到tomcat中时会部署之前的项目