建议使用以下浏览器,以获得最佳体验。 IE 9.0+以上版本 Chrome 31+ 谷歌浏览器 Firefox 30+ 火狐浏览器
请选择 进入手机版 | 继续访问电脑版
设置昵称

在此一键设置昵称,即可参与社区互动!

确定
我再想想
选择版块

vxbugu318

发帖: 1粉丝: 1

级别 : 新手上路

Rank: 1

发消息 + 关注

发表于2018-12-21 16:20:58 1711 3 楼主 显示全部楼层
[建站交流] 一对一直播源码,Java 部分的案例剖析


 

 

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

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

Observable内部方法如下所示:

     0.0.0 (2).png 
一对一直播源码,Java观察者模式案例简析
观察者模式的内在原理:观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时,会通知所有观察者对象,使它们能够自动更新自己。

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

被观察者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;

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).update(this, arg);
17 }
加同步锁synchronized可避免线程并发问题,设置changed状态可监听更新。for循环遍历执行观察者Observer内部的方法update()。
                                                                                                                                    0.0.0 (1).png 
被观察者继承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;

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接口,支持扩展。如:
                                                                                                                              0.0.0 (3).png 
复制代码

1 /**
2 * 观察者类
3 *
4 * @author jinzifu
5 * @create 2018/2/22 15:14
6 */
7 public class ObserverClass implements Observer {
8 private String name;

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 }
复制代码

外部测试如

  0.0.0 (4).png 
复制代码

1 /**
2 * @author jinzifu
3 */
4 public class Main {

6 public static void main(String[] args) {

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 }                           

 

 

 

 

 

 

 

 


回复 举报
分享

分享文章到朋友圈

分享文章到微博

高晓云

发帖: 33粉丝: 20

级别 : 管理员

Rank: 9Rank: 9Rank: 9

发消息 + 关注

发表于2018-12-22 22:00:24 沙发 显示全部楼层

谢谢分享!!

点赞 回复 举报

vxbugu318

发帖: 1粉丝: 1

级别 : 新手上路

Rank: 1

发消息 + 关注

发表于2018-12-28 16:03:26 板凳 显示全部楼层

不客气

点赞 回复 举报

龙少

发帖: 0粉丝: 0

级别 : 新手上路

Rank: 1

发消息 + 关注

发表于2019-1-10 21:11:38 地板 显示全部楼层

哇谢谢搂住人漂亮又大方虽然我啥也看不懂谢谢分享

点赞 回复 举报

游客

您需要登录后才可以回帖 登录 | 立即注册