设计方式之观察者（Observer）模式

设计模式之观察者（Observer）模式

Observer模式中文名称叫观察者模式，在Java中，可以通过JDK提供的java.util.Observable类和 java.util.Observer接口实现Observer模式。Observer模式定义对象间的一对一或一对多的依赖关系，当一个对象（Observable）的状态发生改变时, 所有依赖于它的对象（Observer）都得到通知并被自动更新。

下面，我们分别来看下Observable类和Observer接口的方法和作用。

1、 Observable 类代表被观察者（java.util.Observable ）

主要方法有：

        void setChanged() ：设置被观察者的状态已经被改变
        void addObserver(Observer observer) ：添加观察者
        int countObservers() ：返回所有观察者的数目
        void deleteObserver(Observer observer) ：删除指定观察者
        void deleteObservers() ：删除所有观察者
        boolean hasChanged() ：被观察者的状态是否被改变，如果是则返回true，否则返回false
        void notifyObservers() ：通知所有观察者（没有参数）

void notifyObservers(Object arg) ：通知所有观察者（带参数，参数一般设定为被改变的属性）
void clearChanged() ：清除被观察者状态的改变（即调用 hasChanged() 时会返回 false）

2、Observer 接口代表观察者（java.util.Observer ）

void update(Observable observable, Object arg) ：当被观察者调用 notifyObservers(*) 方法

时，会根据被观察者的 hasChanged() 方法来判断它的状态是否被改变，如果被观察者的状态被改变了，则

会调用观察者的 update 方法，参数 observable 为被观察者对象， arg 为调用 notifyObservers( Object arg ) 时传入的参数 arg ，如果调用的是 notifyObservers() 方法，则 arg 为 null（注意：应该把这个参数 arg 设定为被观察者的被改变的属性）。

以下是一个Observer模式的例子：

1、被观察者Car类，继承至Observable类

package com.huawei.observer.observable;

import java.util.Observable;

public class Car extends Observable implements Runnable{

	private Float gasoline;//汽车的汽油量

	public Car(Float gasoline) {
		super();
		this.gasoline = gasoline;
	}

	public Float getGasoline() {
		return gasoline;
	}

	public void setGasoline(Float gasoline) {
		this.gasoline = gasoline;
	}
	
	/**
	 * 模拟汽车行驶过程中的耗油的方法
	 */
	public synchronized void consume(){
		if(--gasoline < 5){//若油箱中的油少于5升则让汽车提示驾驶员加油。
			this.setChanged();
			this.notifyObservers(gasoline);//通知驾驶员加油。
		}
	}

	/**
	 * 模拟汽车的行驶过程
	 */
	@Override
	public void run() {
		while(Boolean.TRUE){
			consume();
			if(gasoline == 0){//当油箱中还剩0升油时汽车停止
				break;
			}
			try {
				Thread.sleep(1000);//每一秒钟耗油1升
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
	
}

2、观察者Driver类，实现Observer接口

package com.huawei.observer.observer;

import java.util.Observable;
import java.util.Observer;

import com.huawei.observer.observable.Car;

public class Driver implements Observer {

	private String name;//驾驶员名字
	
	public Driver(String name) {
		super();
		this.name = name;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}


	@Override
	public void update(Observable observable, Object object) {
		Car car = null;//当前行驶的汽车。
		Float gasoline = null;//当前行驶的汽车的油量。
		
		if(observable instanceof Car){
			car = (Car)observable;
		}else{
			return ;
		}
		
		if(object instanceof Float){
			gasoline = (Float)object;
		}else{
			return ;
		}
		if(gasoline != 0){
			System.out.println("驾驶员"+name+"您好，您的油箱汽油还剩  " + gasoline + " 升，请尽快加油！" );
		}else{
			System.out.println("驾驶员"+name+"您好，您的油箱已无汽油，汽车已停止！" );
		}
	}

}

3、测试类Test

package com.huawei.observer.main;

import com.huawei.observer.observable.Car;
import com.huawei.observer.observer.Driver;

public class Test {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		Car car = new Car(35F);//实例化被观察者，即汽车，初始状态油箱35升油。
		Driver driver = new Driver("William");//实例化观察者，即汽车驾驶员，名字是William。
		
		car.addObserver(driver);//为被观察者（汽车）添加观察者（驾驶员）
		
		new Thread(car).start();//启动汽车行驶的线程，每一秒钟耗油1升。
	}

}

4、运行测试类，（汽车行驶30秒钟后）输出结果如下：

驾驶员William您好，您的油箱汽油还剩 4.0 升，请尽快加油！
驾驶员William您好，您的油箱汽油还剩 3.0 升，请尽快加油！
驾驶员William您好，您的油箱汽油还剩 2.0 升，请尽快加油！
驾驶员William您好，您的油箱汽油还剩 1.0 升，请尽快加油！
驾驶员William您好，您的油箱已无汽油，汽车已停止！

设计方式之观察者（Observer）模式

相关推荐