阿里P6+面试：介绍下观察者模式？

消息队列(MQ)，一种能实现生产者到消费者单向通信的通信模型，这也是现在常用的主流中间件。

常见有 RabbitMQ、ActiveMQ、Kafka等他们的特点也有很多比如解偶、异步、广播、削峰等等多种优势特点。

在设计模式中也有一种模式能有效的达到解偶、异步的特点，那就是观察者模式又称为发布订阅模式。

今天阿丙就分享一下实际开发中比较常见的这种模式

大纲

定义

什么是观察者模式?他的目的是什么?

当一个对象的状态发生改变时，已经登记的其他对象能够观察到这一改变从而作出自己相对应的改变。通过这种方式来达到减少依赖关系，解耦合的作用。

举一个例子，就好比微信朋友圈，以当前个人作为订阅者，好友作为主题。一个人发一条动态朋友圈出去，他的好友都能看到这个朋友圈，并且可以在自主选择点赞或者评论。

感觉有点抽象，还是看看他有哪些主要角色：

Subject(主题): 主要由类实现的可观察的接口，通知观察者使用attach方法，以及取消观察的detach方法。
ConcreteSubject(具体主题): 是一个实现主题接口的类，处理观察者的变化
Observe(观察者): 观察者是一个由对象水岸的接口，根据主题中的更改而进行更新。

这么看角色也不多，但是感觉还是有点抽象，我们还是用具体实例代码来走一遍吧，我们还是以上面的朋友圈为例看看代码实现

publicinterfaceSubject{
//添加订阅关系
voidattach(Observerobserver);
//移除订阅关系
voiddetach(Observerobserver);
//通知订阅者
voidnotifyObservers(Stringmessage);
}

先创建一个主题定义，定义添加删除关系以及通知订阅者

publicclassConcreteSubjectimplementsSubject{
//订阅者容器
privateList<Observer>observers=newArrayList<Observer>();
@Override
publicvoidattach(Observerobserver){
//添加订阅关系
observers.add(observer);
}
@Override
publicvoiddetach(Observerobserver){
//移除订阅关系
observers.remove(observer);
}
@Override
publicvoidnotifyObservers(Stringmessage){
//通知订阅者们
for(Observerobserver:observers){
observer.update(message);
}
}
}

其次再创建的具体主题，并且构建一个容器来维护订阅关系，支持添加删除关系，以及通知订阅者

publicinterfaceObserver{
//处理业务逻辑
voidupdate(Stringmessage);
}

创建一个观察者接口，方便我们管理

publicclassFriendOneObserverimplementsObserver{
@Override
publicvoidupdate(Stringmessage){
//模拟处理业务逻辑
System.out.println("FriendOne知道了你发动态了"+message);
}
}

最后就是创建具体的观察者类，实现观察者接口的update方法，处理本身的业务逻辑

publicclasstest{
publicstaticvoidmain(String[]args){
ConcreteSubjectsubject=newConcreteSubject();
//这里假设是添加好友
subject.attach(newFriendOneObserver());
FriendTwoObservertwoObserver=newFriendTwoObserver();
subject.attach(twoObserver);
//发送朋友圈动态
subject.notifyObservers("第一个朋友圈消息");
//输出结果：FriendOne知道了你发动态了第一个朋友圈消息
//FriendTwo知道了你发动态了第一个朋友圈消息
//这里发现twoObserver是个推荐卖茶叶的，删除好友
subject.detach(twoObserver);
subject.notifyObservers("第二个朋友圈消息");
//输出结果：FriendOne知道了你发动态了第二个朋友圈消息
}
}

最后就是看测试结果了，通过ConcreteSubject 维护了一个订阅关系，在通过notifyObservers 方法通知订阅者之后，观察者都获取到消息从而处理自己的业务逻辑。

这里细心的朋友已经达到了解耦合的效果，同时也减少了依赖关系，每个观察者根本不要知道发布者处理了什么业务逻辑，也不用依赖发布者任何业务模型，只关心自己本身需要处理的逻辑就可以了。

如果有新的业务添加进来，我们也只需要创建一个新的订阅者，并且维护到observers 容器中即可，也符合我们的开闭原则。

这里只是一种同步的实现方式，我们还可以扩展更多其他的异步实现方式，或者采用多线程等实现方式。

框架应用

观察者模式在框架的中的应用也是应该很多

第一种熟悉JDK的人应该知道在java.util 包下除了常用的集合和map之外还有一个Observable类，他的实现方式其实就是观察者模式。里面也有添加、删除、通知等方法。

这里需要注意是的他是用Vector 作为订阅关系的容器，同时在他的定义方法中都添加synchronized关键字修饰类，以达到线程安全的目的

这里我贴出了关键源码，感兴趣的同学可以自己打开并且观看每个方法的注释。

第二种在Spring中有一个ApplicationListener，也是采用观察者模式来处理的，ApplicationEventMulticaster作为主题，里面有添加，删除，通知等。

spring有一些内置的事件，当完成某种操作时会发出某些事件动作，他的处理方式也就上面的这种模式，当然这里面还有很多，我没有细讲，有兴趣的同学可以仔细了解下Spring的启动过程。

import java.util.EventListener;/** * Interface to be implemented by application event listeners. * Based on the standard {@code java.util.EventListener} interface * for the Observer design pattern. // 这里也已经说明是采用观察者模式 * *

importjava.util.EventListener;
/**
*Interfacetobeimplementedbyapplicationeventlisteners.
*Basedonthestandard{@codejava.util.EventListener}interface
*fortheObserverdesignpattern.//这里也已经说明是采用观察者模式
*
*<p>AsofSpring3.0,anApplicationListenercangenericallydeclaretheeventtype
*thatitisinterestedin.WhenregisteredwithaSpringApplicationContext,events
*willbefilteredaccordingly,withthelistenergettinginvokedformatchingevent
*objectsonly.
*
*@authorRodJohnson
*@authorJuergenHoeller
*@param<E>thespecificApplicationEventsubclasstolistento
*@seeorg.springframework.context.event.ApplicationEventMulticaster//主题
*/
@FunctionalInterface
publicinterfaceApplicationListener<EextendsApplicationEvent>extendsEventListener{
/**
*Handleanapplicationevent.
*@parameventtheeventtorespondto
*/
voidonApplicationEvent(Eevent);
}