观察者模式-设计方式-笔记(一)

观察者模式-设计模式-笔记(一)

出版者+订阅者==观察者模式

 

报纸的订阅

 

出版者改称为”主题“(Subject),订阅者改称为”观察者“(Observer)

 

 

观察者模式定义了一系列对象之间的一对多关系。

 

当一个对象改变状态,其他依赖者都会收到通知。

 

主题:

这样或许不行,只是我必须因此门户大开,让你们全都可以进来取得你们需要的状态,这样太危险了。我不能让你们进来里面大肆挖掘我的各种数据

 

观察者:

为何由你主动送数据过来,而不是让我们主动去向你索取数据?

你 何不提供一些公开的getter方法,让我们”拉“走我们需要的状态?

 

 

 

 

观察者模式定义了对象间的一对多依赖关系,让一个或多个观察者对象观察一个主题对象。当主题对象的状态发生变化时,系统能通知所有的依赖于此对象的观察者对象,从而使得观察者对象能够自动更新。

在观察者模式中,被观察的对象常常也被称为目标或主题(Subject),依赖的对象被称为观察者(Observer)。

下面以一个简单的示例来示范观察者模式,程序先提供一个观察者接口:

程序清单:codes\09\9.3\Observer\Observer.java

public interface Observer
{
void update(Observable o , Object arg);
}

上面Observer接口是一个观察者接口,程序中所有观察者都应该实现该接口。在该接口的update()方法中包含了一个Observable类型的参数,该参数代表被观察对象,也就是前面介绍的目标或主题。此处的Observable是一个抽象基类,程序中被观察者应该继承该抽象基类。

Observable类的代码如下:

程序清单:codes\09\9.3\Observer\Observable.java

public abstract class Observable
{
//用一个List来保存该对象上所有绑定的事件监听器
List<Observer> observers = 
new ArrayList<Observer>();
//定义一个方法,用于从该主题上注册观察者
public void registObserver(Observer o)
{
observers.add(o);
}
//定义一个方法,用于从该主题中删除观察者
public void removeObserver(Observer o)
{
observers.add(o);
}
//通知该主题上注册的所有观察者
public void notifyObservers(Object value)
{
//遍历注册到该被观察者上的所有观察者
for (Iterator it = observers.iterator(); 
it.hasNext(); )
{
Observer o = (Observer)it.next();
//显示每个观察者的update方法
o.update(this , value);
}
}
}

该Observable抽象类是所有被观察者的基类,它主要提供了registObserver()方法用于注册一个新的观察者;并提供了一个removeObserver()方法用于删除一个已注册的观察者;当具体被观察对象的状态发生改变时,具体被观察对象会调用notifyObservers方法来通知所有观察者。

下面提供一个具体的被观察者类:Product,该产品有两个属性,它继承了Observable抽象基类。程序如下:

程序清单:codes\09\9.3\Observer\Product.java

public class Product extends Observable
{
//定义两个属性
private String name;
private double price;
//无参数的构造器
public Product(){}
public Product(String name , double price)
{
this.name = name;
this.price = price;
}
public String getName()
{
return name;
}
//当程序调用name的setter方法来修改Product的name属性时
//程序自然触发该对象上注册的所有观察者
public void setName(String name)
{
this.name = name;
notifyObservers(name);
}
public double getPrice()
{
return price;
}
//当程序调用price的setter方法来修改Product的price属性时
//程序自然触发该对象上注册的所有观察者
public void setPrice(double price)
{
this.price = price;
notifyObservers(price);
}
}

正如程序中两行粗体字代码所示,当程序调用Product对象的setName()、setPrice()方法来改变Product的name、price属性时,这两个方法将自动触发Observable基类的notifyObservers方法。

 

接下来程序提供两个观察者,一个用于观察Product对象的name属性,另一个用于观察Product对象的price属性。

程序清单:codes\09\9.3\Observer\NameObserver.java

public class NameObserver implements Observer
{
//实现观察者必须实现的update方法
public void update(Observable o , Object arg)
{
if (arg instanceof String )
{
//产品名称改变值在name中
String name = (String)arg;
//启动一个JFrame窗口来显示被观察对象的状态改变
JFrame f = new JFrame("观察者");
JLabel l = new JLabel("名称改变为:" + name);
f.add(l);
f.pack();
f.setVisible(true);
System.out.println("名称观察者:" +
o + "物品名称已经改变为: " + name);
}
}
}

程序清单:codes\09\9.3\Observer\PriceObserver.java

public class PriceObserver implements Observer
{
//实现观察者必须实现的update方法
public void update(Observable o , Object arg)
{ 
if(arg instanceof Double)
{
System.out.println("价格观察者:" +
o + "物品价格已经改变为: " + arg);
}
}
}

接着主程序创建一个Product对象(被观察的目标对象),然后向该被观察对象上注册两个观察者对象,当主程序调用Product对象的setter方法来改变该对象的状态时,注册在Product对象上的两个观察者将被触发。主程序代码如下:

程序清单:codes\09\9.3\Observer\Test.java

public class Test
{
public static void main(String[] args) 
{
//创建一个被观察者对象
Product p = new Product("电视机" , 176);
//创建两个观察者对象
NameObserver no = new NameObserver();
PriceObserver po = new PriceObserver();
//向被观察对象上注册两个观察者对象
p.registObserver(no);
p.registObserver(po);
//程序调用setter方法来改变Product的name和price属性
p.setName("书桌");
p.setPrice(345f);
}
}

运行上面程序,我们将可看到当Product的属性值发生改变时,注册在该Product上的NameObserver和PriceObserver将被触发。

纵观上面介绍的观察者模式,我们发现观察者模式通常包含如下4个角色:

被观察者的抽象基类:它通常会持有多个观察者对象的引用。Java提供了java.util.Observable基类来代表被观察者的抽象基类,所以实际开发中无须自己开发这个角色。

观察者接口:该接口是所有被观察对象应该实现的接口,通常它只包含一个抽象方法update()。Java同样提供了java.util.Observer接口来代表观察者接口,实际开发中也无须开发该角色。

被观察者实现类:该类继承Observable基类。

观察者实现类:实现Observer接口,实现update抽象方法。

理解了上面观察者模式的实现思路之后,可能有读者会感到疑惑:观察者模式的实现方式与Java事件机制的底层实现何其相似啊?实际上,我们完全可以把观察者接口理解成事件监听接口,而被观察者对象也可当成事件源来处理——换个角度来思考:监听,观察,这两个词语之间有本质的区别吗?Java事件机制的底层实现,本身就是通过观察者模式来实现的。

除此之外,观察者模式在Java EE应用中也有广泛应用,主题/订阅模式下的JMS(Java Message Service,Java消息服务)本身就是观察者模式的应用。图9.12显示了主题/订阅模式下JMS的示意图。

观察者模式-设计方式-笔记(一) 
图9.12  主题/订阅模式下JMS的示意图

从图9.12中可以看出,当Topic主题收到发布者(Publisher)发布的消息时,注册到该主题的所有订阅者(Subscriber)都可收到该消息。实际上,Java EE把这个Topic设计成一个被观察者,而所有订阅者都注册到该被观察者,当发布者发布消息时,该消息将会引起Topic主题的改变,这种改变将会触发注册到该Topic上的所有观察者。