在Java中通过Observable类和Observer接口实现了观察者模式。一个Observer对象监视着一个Observable对象的变化,当Observable对象发生变化时,Observer得到通知,就可以进行相应的工作。例如在文档/视图结构中,文档被修改了,视图就会得到通知。java.util.Observable中有两个方法对Observer特别重要,一个是setChange()方法用来设置一个内部标志位注明数据发生了变化;一个是notifyObservers()方法会去调用一个列表中所有的Observer的update()方法,通知它们数据发生了变化。Observer通过Observable的addObserver()方法把自己添加到这个列表中。这个列表虽然由Observable拥有,但Observable并不知道到底有哪些Observer正在观察等待通知。Observable只提供一个方法让Observer能把自己添加进列表,并保证会去通知Observer发生了变化。通过这种机制,可以有任意多个Observer对Observable进行观察,而不影响Observable的实现。
一个简单例子:
-
importjava.util.Observable;
-
-
publicclassSimpleObservableextendsObservable
-
{
-
privateintdata=0;
-
-
publicintgetData(){
-
returndata;
-
}
-
-
publicvoidsetData(inti){
-
if(this.data!=i){this.data=i;setChange();}
-
notifyObservers();
-
-
}
-
}
-
}
-
-
importjava.util.Observable;
-
importjava.util.Observer;
-
-
publicclassSimpleObserverimplementsObserver
-
{
-
publicSimpleObserver(SimpleObservableso){
-
so.addObserver(this);
-
}
-
-
publicvoidupdate(Observableo,Objectarg){
-
System.out.println(“Datahaschangedto”+(SimpleObservable)o.getData());
-
}
-
}
-
-
publicclassSimpleTest
-
{
-
publicstaticvoidmain(String[]args){
-
SimpleObservabledoc=newSimpleObservable();
-
SimpleObserverview=newSimpleObserver(doc);
-
doc.setData(1);
-
doc.setData(2);
-
doc.setData(2);
-
doc.setData(3);
-
}
-
}
Data has changed to 1Data has changed to 2//第二次setData(2)时由于没有setChange,所以update没被调用Data has changed to 3Observable类有两个私有变量。一个boolean型的标志位,setChange()将它设为真,只有它为真时,notifyObservers方法才会调用Observer的update方法,clearChange()设标志位为假,hasChange返回当前标志位的值。另一个是一个Vector,保存着一个所有要通知的Observer列表,addObserver添加Observer到列表,deleteObserver从列表中删除指定Observer,deleteObservers清空列表,countObservers返回列表中Observer的数目,在Observer对象销毁前一定要用deleteObserver将其从列表中删除,不然因为还存在对象引用的关系,Observer对象不会被垃圾收集,造成内存泄漏,并且已死的Observer仍会被通知到,有可能造成意料外的错误,而且随着列表越来越大,notifyObservers操作也会越来越慢。Observable的所有方法都是同步的,保证了在一个线程对其标志位、列表进行操作时,不会有其它线程也在操作它。Observable的notifyObservers(Object obj)形式可以再调用update时将参数传进去。通知顺序通常时越晚加入列表的越先通知。update会被依次调用,由于一个update返回后下一个update才被调用,这样当update中有大量操作时,最好将其中的工作拿到另一个线程或者Observer本身同时也是一个Thread类,Observer先挂起,在update中被唤醒,这样会有一个隐患,Observer线程还没来得及挂起,update就被调用了,通知消息就这样被错过了,一种解决办法是在Observer中实现一个同步的队列结构,并有一个类来封装参数,update实现一个参数类的对象把接收到的通知消息的参数封装在里面,然后把其加进队列,run方法从队列中移除参数对象,并进行处理,这保证了没有通知信息被丢失。
在多线程时,只有Observer会与单线程不同,Observable不需任何改变来支持多线程,因为它又很多作为单独线程运作的Observer。
一个多线程例子:
-
importjava.util.*;
-
-
publicclassSimpleObserverExextendsThreadimplementsObserver
-
{
-
Queuequeue;
-
-
publicvoidrun(){
-
while(true){
-
ArgPacka=(ArgPack)queue.dequeue();
-
Observableo=a.o;
-
Objectobj=a.arg;
-
-
}
-
}
-
-
publicvoidupdate(Observableo,Objectarg){
-
ArgPacka=newArgPack(o,arg);
-
queue.queue(a);
-
}
-
}
-
-
importjava.util.*;
-
-
publicclassQueueextendsLinkedList{
-
publicsynchronizedvoidqueue(Objecto){
-
addLast(o);
-
notify();
-
}
-
-
publicsynchronizedvoiddequeue(){
-
while(this.isEmpty()){
-
try{
-
wait();
-
}
-
catch(InterruptedExceptionel){
-
}
-
}
-
Objecto;
-
try{
-
o=this.removeFirst();
-
}
-
catch(NoSuchElementException){
-
o=null;
-
}
-
returno;
-
}
-
}
-
-
publicclassArgPack
-
{
-
publicObservableo;
-
publicObjectobj;
-
publicArgPack(Observableo,Objectobj){
-
this.o=o;this.obj=obj;
-
}
-
}
Observable是一个类而不是一个接口这限制了它的使用,一个解决的办法是在一个Observable类中把我们的类包装进去(把我们的类实例当作Observable的域),因为Observable中的setChange是一个protected方法,我们没法在外面调用它。所以没法在我们的类中包装一个Observable,但是如果我们的类中同样也有protected方法,那这个办法就无法使用.
ContentObserver类详解:
http://blog.csdn.net/qinjuning/article/details/7047607
下面2个工程是Observable与Observer的经典运用,是android实现的单指拖动放大图片的操作
两个例子:
http://dl.iteye.com/topics/download/4ba47648-c754-303f-8fa0-49d4086a8784
http://dl.iteye.com/topics/download/1a09cda1-3b22-3e2e-bd90-01d11a420316
分享到:
相关推荐
Java内置的Observable类和Observer接口提供了基本的观察者模式功能,你可以通过继承Observable类和实现Observer接口来使用
这样一来 当一个对象改变状态时 依赖它的对象都会收到通知并自动跟新 Java已经提供了对观察者Observer模式的默认实现 Java对观察者模式的支持主要体现在Observable类和Observer接口 ">观察者 Observer 模式定义:在...
JDK里提供的observer设计模式的实现由java.util.Observable类和 java.util.Observer接口组成。从名字上可以清楚的看出两者在Observer 设计模式中分别扮演的角色:Observer是观察者角色,Observable是被观察目标...
主要介绍了 Java观察者设计模式(Observable和Observer)的相关资料,需要的朋友可以参考下
观察者设计模式,java语言实现,完全自己代码实现,未使用observable和observer
android 观察者模式示例代码 android studio kotlin代码 基于java.uitl.*
Java实现一个模型、两个视图和两个控制器的功能软件,即采用MVC模式或者说是观察者模式,本程序通过输入球体半径,显示球体形状,面积体积等 Sphere.java package Model; import java.util.Observable; public class...
手工实现一个Observer也不是多复杂的一件事,只是因为这个设计模式实在太常用了,Java就把它放到了JDK里面:Observable和Observer,从JDK 1.0里,它们就一直在那里。从某种程度上说,它简化了Observer模式的开发,...
使用Java内建的观察者模式 java.util.Observable的黑暗面 设计箱内的工具 习题解答 …… 3 装饰者模式:装饰对象 4 工厂模式:烘烤OO的精华 5 单件模式:独一无二的对象 6 命令模式:封装调用 7 ...
观察者模式定义了对象之间一对多的依赖, 这样一来, 当一个对象改变状态 所有依赖都会收到通知, 自动更新 :beer_mug:设计原则1: 为了交互对象之间的松耦合设计而努力 :star:实现细节 自己设计的Observer/Subject: 见 ...
观察者模式(Observer Pattern) 出版者 + 订阅者 = 观察者模式 subject + Observer 观察者模式定义了一系列对象之间的一对多关系,当一个对象改变状态,其他依赖者都会收到通知。 push/pull 设计原则 交互对象之间...
Dublin_Travel_Observer设计对于这项任务,我将观察者模式应用于我的最后一年项目的一个方面。 该项目的目标是生成实时数据可视化和旅程规划 Android 应用程序。 此作业侧重于都柏林巴士、爱尔兰巴士、Luas 和爱尔兰...
的Observable和Observer接口的简单实现。 接口的实现允许: 异步代码来创建项目。 观察员捕获事件并将其转变为项目。 Java的Stream框架非常有用,但是这些类通过实现缺少的生产者/消费者功能使它变得更好。 ...
SimpleWebServer原型验证模块间通信同步模式下用synchronized同步块,Lock接口,Object自带的wait/yield/sleep/notify...观察者模式也是callback,在原来上下级直接耦合中间插入一层Observable和Observer,隔离性更好,
接收继电器 中继是类型,既是Observable也是Consumer 。 基本上是:一个Subject但不能调用onComplete或onError... 向每个订阅的Observer发出它观察到的最新项目以及所有后续观察到的项目的Relay。 // observer will r