java设计模式-Observer（观察者）模式

程序员文章站 2022-07-12 20:36:52

...

    Observer的定义
    定义对象间的一种一对多的依赖关系，以便当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并自动刷新。

    因为java里有Obserable和Observer, 所以通常在java里不会自己设计观察者模式。

    Java 中的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() ：清除被观察者状态的改变

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

void update(Observable observable, Object arg) ：当被观察者调用 notifyObservers() 方法
时，会根据被观察者的 hasChanged() 方法来判断它的状态是否被改变，如果被观察者的状态被改变了，则
会调用观察者的 update 方法，参数 observable 为被观察者对象， arg 为调用 notifyObservers( Object arg ) 时传入的参数 arg ，如果调用的是 notifyObservers() 方法，则 arg 为 null。

下面为股票涨跌通知的代码样例
观察者：

package observer;

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

public class Broker implements Observer {
	private String name;

	public Broker(String name) {
		this.name = name;
	}

	public String getName() {
		return name;
	}

	
	public void update(Observable observable, Object arg) {//注意此处，update方法接收到了 状态改变的对象、改变的状态 两个参数，
        //这意味着我们可以有两种方式过去改变的信息，一中是被观察者”推“给观察者(如：arg)，另一种是观察者从被观察者”拉“过来（被观察者有公开方法，如：name）
		if (observable instanceof Stock && arg instanceof Float) {
			if ((Float)arg > ((Stock)observable).getPrice()) {
				System.out.println(this.name + " 说 : "
						+ ((Stock) observable).getName() + "涨到 " + arg + "元了 ！");
			}else{
				System.out.println(this.name + " 说 : "
						+ ((Stock) observable).getName() + "降到 " + arg + "元了 ！");
			}
		
		}
	}
}

被观察者：


package observer;

import java.util.Observable;

public class Stock extends Observable {
	private String name;
	private float price;

	public Stock(String name, float price) {
		this.name = name;
		this.price = price;
	}

	public String getName() {
		return name;
	}

	public float getPrice() {
		return price;
	}

	public void setPrice(float price) {
		
		if(this.price < price){
//设置被观察者的状态已经被改变
			this.setChanged();
//唤醒观察者的update方法
			this.notifyObservers(price);
//更改被观察者的状态
			this.price = price;
		}
		if(this.price > price){
			this.setChanged();
			this.notifyObservers(price);
			this.price = price;
		}
	}
}

测试：

package observer;

public class Test {
	public static void main(String[] args) {
		Stock stock = new Stock("中华科技", 1.5f);
		Broker tom = new Broker("Tom");
		Broker leo = new Broker("Leo");
//添加两个观察者
		stock.addObserver(tom);
		stock.addObserver(leo);
//股票价格上涨，通知两个观察者
		stock.setPrice(1.6f);
//股票价格下降，通知两个观察者		
		stock.setPrice(1.4f);
	
	}
}