源码论坛公告:有很多假冒锦尚中国的网站出现,还有声称是跟我们合作网站,请擦亮眼睛避免被骗,源码论坛唯一域名为52jscn.com 【点击此处将锦尚放在桌面

源码论坛,商业源码下载,尽在锦尚中国商业源码论坛

 找回密码
 会员注册

QQ登录

只需一步,快速开始

新版大型房产门户源码下载
知名广告联盟 精准不扣量
企业免备案主机仅需80元
亿恩免费建网站 服务器特价
锦尚中国源码论坛
百度站长平台 精确提升SEO
旅游网解决方案 大型旅游门户
大型装修门户助您抢占商机
【稳定】ios苹果签名 网站封装微信营销项目诚招代理
安乐业房产网全新来袭
 
查看: 706|回复: 0

[交流] 1对1直播源码,Java模式分析案例

[复制链接]

6

主题

6

帖子

3

金币

初级会员

Rank: 1

积分
10
QQ
发表于 2019-2-11 15:55:12 | 显示全部楼层 |阅读模式
一对一直播源码,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 }
                                                                                                   


加同步锁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 }
复制代码
外部测试如下:
复制代码
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:收到通知,完成更新。



山东布谷鸟网络科技有限公司主开发一对一直播源码、一对一视频源码、交友源码、社交源码、一对一源码、短视频源码、有视频源码、抖音源码等开发。
您需要登录后才可以回帖 登录 | 会员注册

本版积分规则

锦尚中国源码论坛 锦尚中国源码

锦尚中国,为中国网站设计添动力 ( 鲁ICP备09033200号 )

GMT+8, 2019-8-23 06:10 , Processed in 0.141070 second(s), 23 queries .

带宽由 锦尚数据 提供 专业的数据中心

© 锦尚中国源码论坛 52jscn Inc. 非法入侵必将受到法律制裁 法律顾问:IT法律网 锦尚爱心