专业吸猫20年！一对一直播源码，Java观察者模式案例简析

Posted 2021-01-23 cdnfast

在java内部已有内置的观察者模式，如类 java.util.Observable和类java.util.Observer，即是被观察者和观察者。

在 java.util.Observable 中，存储观察者对象的容器是Vector，此容器支持动态扩展和同步性，用法与ArrayList类似。

Observable内部方法如下所示：

 

 

观察者模式的内在原理：观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

 

即：通过将一组对象实例存储在一个数组容器中，在某一时刻遍历数组并调用数组内的对象方法完成更新。

被观察者Observable内部的核心方法：

 

 1 public void notifyObservers(Object arg) {
 2 /*
 3 * a temporary array buffer, used as a snapshot of the state of
 4 * current Observers.
 5 */
 6 Object[] arrLocal;
 7 
 8 synchronized (this) {
 9 if (!changed)
10 return;
11 arrLocal = obs.toArray();
12 clearChanged();
13 }
14 
15 for (int i = arrLocal.length-1; i>=0; i--)
16 ((Observer)arrLocal[i]).update(this, arg);
17 }

 

加同步锁synchronized可避免线程并发问题，设置changed状态可监听更新。for循环遍历执行观察者Observer内部的方法update()。

被观察者继承Observable类，动态发布消息通知观察者更新。如：

 

 1 /**
 2 * 被观察者类
 3 *
 4 * @author jinzifu
 5 * @create 2018/2/22 15:36
 6 */
 7 public class ObservableClass extends Observable {
 8 private String message;
 9 
10 public String getMessage() {
11 return message;
12 }
13 
14 public void setMessage(String message) {
15 this.message = message;
16 //被观察者数据发生变化时，通过以下两行代码通知所有的观察者
17 this.setChanged();
18 this.notifyObservers(message);
19 }
20 }

 

观察者实现了Observer接口，支持扩展。如：

 

 1 /**
 2 * 观察者类
 3 *
 4 * @author jinzifu
 5 * @create 2018/2/22 15:14
 6 */
 7 public class ObserverClass implements Observer {
 8 private String name;
 9 
10 public ObserverClass(String name) {
11 this.name = name;
12 }
13 
14 @Override
15 public void update(Observable o, Object arg) {
16 System.out.println(name + ":" + arg);
17 }
18 }

 

外部测试如下：

 

 1 /**
 2 * @author jinzifu
 3 */
 4 public class Main {
 5 
 6 public static void main(String[] args) {
 7 
 8 ObservableClass observableClass = new ObservableClass();
 9 ObserverClass observerClass1 = new ObserverClass("observerClass1");
10 ObserverClass observerClass2 = new ObserverClass("observerClass2");
11 ObserverClass observerClass3 = new ObserverClass("observerClass3");
12 ObserverClass observerClass4 = new ObserverClass("observerClass4");
13 
14 observableClass.addObserver(observerClass1);
15 observableClass.addObserver(observerClass2);
16 observableClass.addObserver(observerClass3);
17 observableClass.addObserver(observerClass4);
18 
19 observableClass.setMessage("收到通知，完成更新。");
20 }
21 }

 

打印如下：

 

observerClass4:收到通知，完成更新。
observerClass3:收到通知，完成更新。
observerClass2:收到通知，完成更新。
observerClass1:收到通知，完成更新。