标签：ret length int 技术 mes out create 一对一直播 动态
在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:收到通知，完成更新。
标签：ret length int 技术 mes out create 一对一直播 动态
原文地址：https://www.cnblogs.com/CDNfast/p/10040000.html
