首页 > 代码库 > 观察者模式

观察者模式

     定义:定义了对象之间的一对多依赖,当一个对象改变状态时,它的所有依赖者都会收到通知并自动更新。

    类图:

     

        利用观察者模式,主题是具有状态的对象,并且可以控制这些状态。有许多观察者依赖主题来告诉他们状态何时改变了。这就产生一个关系:“一个“主题对”多个“观察者的关系。

        当两个对象之间松耦合,他们依然可以交互,但是不太清楚彼此的细节。观察者模式提供了一种对象设计,让主题和观察者之间松耦合。

代码

   主题接口

public interface Subject {
    public void registerObserver(Observer o);
    public void removeObserver(Observer o);
    public void notifyObserver();
}

具体主题类

import java.util.ArrayList;


public class ConcreteSubject implements Subject{
	private ArrayList observers = new ArrayList();
	private String name;
	@Override
	public void notifyObserver() {
		for (int i = 0; i < observers.size(); i++) {
			Observer observer = (Observer)observers.get(i);
			observer.update();
		}
	}

	@Override
	public void registerObserver(Observer o) {
		 observers.add(o);
	}

	@Override
	public void removeObserver(Observer o) {
		int i = observers.indexOf(o);
		if (i >= 0) {
			observers.remove(i);
		} 
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
		notifyObserver();
	}

}

观察者接口

public interface Observer {
   public void update();
}
具体观察者1

public class ConcreteObserver implements Observer{

	private ConcreteSubject consubject;
	@Override
	public void update() {
		 
		 System.out.println(consubject.getName());
	}
	public ConcreteObserver(ConcreteSubject consubject) {
		 
		this.consubject = consubject;
	}
  
}

具体观察者2

public class ConcreteObserver2 implements Observer{
  
	private ConcreteSubject consubject;
	@Override
	public void update() {
		 
		 System.out.println(consubject.getName());
	}
	public ConcreteObserver2(ConcreteSubject consubject) {
		 
		this.consubject = consubject;
	}
	
}

客户端

public class ClientTest {
 
	public static void main(String[] args) {
		 
		ConcreteSubject sub = new ConcreteSubject();
		sub.registerObserver(new ConcreteObserver(sub));
		sub.registerObserver(new ConcreteObserver2(sub));
		sub.setName("Allen");
	}

}


运行结果

Allen

Allen

    通过运行结果可以看到,我们只调用了Subject的方法,但同时两个观察者的相关方法都被同时调用了。仔细看一下代码,其实很简单,无非就是在Subject类中关联一下Observer类,并且在notifyObserver方法中遍历一下Observer的update方法就行了。