2019一对一直播源码Java观察者部分剖析

七月的风 八月的雨 卑微的我喜欢遥远的你

你还未来怎敢老去  未来的我和你奉陪到底

站在2018年的末端,回望过去的一年,直播行业经历了“风口”时代的辉煌到如今的“落寞”行业的优化升级和国家的政策的管控密不可分,随着5G时代的到来,视频还将成为一门“语言”。现在人们已经拥有了简单制作视频的能力,受到了一定的视频技术教育。再过几年,视频的使用更普及,和语言、文字一样,不需再要对视频进行描述,就是人们沟通的一种途径、一种角色。

2019一对一直播源码Java观察者部分剖析

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 }

2019一对一直播源码Java观察者部分剖析

加同步锁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 @Override15 public void update(Observable o, Object arg) {16 System.out.println(name + ":" + arg);17 }18 }

2019一对一直播源码Java观察者部分剖析

复制代码

外部测试如下:

复制代码

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:收到通知,完成更新。

上述做了一下浅显的简述,目前5G时代已经悄然来临,5G时代的兴起必会造化万千,而自媒体会跟随着这股巨流,扬帆起航,放眼未来,把握机遇,你准备好了吗?


随意打赏

java基础一对一直播
提交建议
微信扫一扫,分享给好友吧。