[设计模式] - 观察者模式 “三年二班周杰伦，马上到训导处来”

观察者模式（Observer Pattern）定义了对象之间的一对多依赖，让多个观察者对象同时监听一个主体对象，当主体对象发生变化时，它的所有依赖者（观察者）都会收到通知并更新，属于行为型模式。观察者模式有时也叫发布订阅模式。

观察者模式适用场景

主要用于在关联行为之间建立一套出发机制的场景，如朋友圈动态通知，邮件通知等等。

在观察者模式中有如下角色：

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

装饰者模式的应用场景

在生活中有很多观察者的例子，比如你的老师就在关心着你，你提的每个问题他都会收到。

使用JDK提供API实现

首先创建一个学生类，由他继承Observable类。

ublic class Student extends Observable {private String name = "三年二班";private static Student student = null;public Student(){}public static Student getInstance(){if (student ==null){return new Student();}return student;}public String getName() {return name;}public void publish(Question question){System.out.println(question.getUsername()+" "+this.name+"提问");setChanged();notifyObservers(question);}
}

其中publish()方法中会触发setChanged()方法，将question通过notifyObservers(question)发送给观察者。
其中用到的问题类如下，其中只定义了提问人和提问内容。

public class Question {private String username;private String content;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}
}

接下来定义教师类，他继承了Observer的接口，同时实现了updata方法，当触发被改变后，就会执行updata方法。

public class Teacher implements Observer {private String name;public Teacher(String name) {this.name = name;}@Overridepublic void update(Observable o, Object arg) {Student student = (Student) o;Question question = (Question) arg;System.out.println("------------------------");System.out.println(name+"老师你好！您收到了一个来自"+student.getName()+"的提问，希望你可以回答，" +question.getContent()+"\n" +"提问人："+question.getUsername());}
}

最后我们进行一下测试，创建学生类和老师类，其中为学生添加观察的老师，可同时添加多个。当学生类使用publish方法的时候就会触发老师的行为。

public class Test {public static void main(String[] args) {Student student = Student.getInstance();Question question = new Question();question.setContent("为什么女生不喜欢太胖？");question.setUsername("周杰伦");Teacher teacher = new Teacher("jay");student.addObserver(teacher);student.publish(question);}
}

基于 Guava API轻松实现观察者模式

使用guava实现起来就比刚才要简单一些，首先需要导入guava包。

<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>27.0-jre</version>
</dependency>

首先实现教师类

public class Teacher {private String name;public Teacher(String name) {this.name = name;}@Subscribepublic void recivedQuestion( Student student){System.out.println("------------------------");System.out.println(name+"老师你好！您收到了一个来自"+student.getName()+"的提问，希望你可以回答，" +student.getQuestion().getContent()+"\n" +"提问人："+student.getQuestion().getUsername());}
}

在teacher类中定义收到问题的方法recivedQuestion，传入一个学生类，在学生类中包含了问题question基本和上面相同，只是学生拥有这个问题。
使用注解@Subscribe可以自定义监听器的监听方法，可以同时实现多个事件的监听。
下面我们就可以直接测试了！相对于jdk中提供的观察者方法，guava中不需要继承接口，没有代码侵入性。干净且利于理解。

public class Test {public static void main(String[] args) {EventBus bus = new EventBus();Teacher teacher = new Teacher("jay");Question question = new Question();question.setContent("为什么女生不喜欢太胖？");question.setUsername("周杰伦");Student student = new Student("三年二班",question);bus.register(teacher);bus.post(student);}
}

观察者模式的优缺点

优点：

1. 观察者和被观察者之间建立了抽象的耦合。
2. 观察者模式支持广播通信
   缺点：
3. 观察者之间有过多的细节依赖，提高时间消耗及程序的复杂度
4. 使用要小心，避免循环调用