设计模式（二）观察者模式和发布订阅模式（Observer）

发布 + 订阅 != 观察者模式!

发布 + 订阅 != 观察者模式!

发布 + 订阅 != 观察者模式!

重要的事情说三遍，这里必须说明一下，之前百度“观察者模式”，百度是这样定义的：



按照百度的意思，两者是相同的意思，而两者的结构设计还是有本质区别的，之后，我查找维基百科，定义如下：

维基百科定义

观察者模式

是软件设计模式的一种。在此种模式中，一个目标对象管理所有相依于它的观察者对象，并且在它本身的状态改变时主动发出通知。这通常透过呼叫各观察者所提供的方法来实现。此种模式通常被用来实时事件处理系统。

发布-订阅

是一种消息范式，消息的发送者（称为发布者）不会将消息直接发送给特定的接收者（称为订阅者）。而是将发布的消息分为不同的类别，无需了解哪些订阅者（如果有的话）可能存在。同样的，订阅者可以表达对一个或多个类别的兴趣，只接收感兴趣的消息，无需了解哪些发布者（如果有的话）存在。

由此可见，两者之间的根本区别在于：

观察者模式中“观察者”和“被观察者”之间是互相依赖的；

发布订阅中“发布者”和“订阅者”之间并无直接关系。

观察者分析

结构图：



例如：你和其他求职人员共同面试与一家公司的软件工程师岗位，此时，这里的“公司”就是Subject，用来维护Observers（和你一样的候选人），为某些event（比如职位空缺）来通知（notify）观察者。

代码如下：

public interface Interviewee{
//面试者通过这个接口可以接收到公司发过来的消息
void getMessage(String s);
}

public class A implements Interviewee {
private String name = "求职者A";
public A () {}
@Override
public void getMessage(String s) {
System.out.println(name + "接到了公司信息：" + s);
}
}
public class B implements Interviewee {
private String name = "你";
public B () {}
@Override
public void getMessage(String s) {
System.out.println(name + "接到了公司信息:" + s);
}
}

public class Company {
List < Interviewee > list = new ArrayList<Interviewee>();
public Company(){
}
public void addInterviewee(Interviewee interviewee){
list.add(interviewee);
}
//遍历list，把自己的通知发送给所有暗恋自己的人
public void notifyInterviewee() {
for(Interviewee interviewee:list){
interviewee.getMessage("恭喜你，已经通过本公司面试，目前薪资20000元!");
}
}
}

public class Test {
public static void main(String[] args) {
A a = new A();
B b = new B();
Company company = new Company();

//A和B在公司那里都注册了一下
company.addInterviewee(a);
company.addInterviewee(b);
//公司向求职者发送通知
company.notifyInterviewee();
}
}

发布-订阅模式

消息的发送方，叫做发布者（publishers），消息不会直接发送给特定的接收者（订阅者）。



例如：我在我的微信公众号平台发布一篇新的技术文章。我本身并不知道哪些同学关注了我的订阅号，但是我将我发布的文章发布到微信公众号平台，在微信公众号平台会对我的文章进行审核，审核通过后，会将文章推送给我的订阅者。这就是典型的发布-订阅模式。

两者比较如下：

观察者模式	发布-订阅模式
知道Subject，即公司，两者可以直接联系	无直接依赖关系，通过消息代理，即微信公众号平台进行通信
紧耦合	松耦合
大多数是同步的	大多数是异步的（使用消息队列）
在单个应用程序地址空间中实现	交叉应用模式

THE END