设计模式--观察者模式"推"数据

观察者模式：定义对象间的一种一对多的依赖关系，当一个对象的状态发生变化时，所有依赖他的对象得到通知并被自动更新。

 

观察者模式机构的四种角色：

1、主题：是一个接口，定义具体主题需要实现的方法，如：添加、删除、通知观察者的方法。

2:、观察者：是一个接口，定义具体观察者用来更新数据的方法。

3、具体主题：主题接口的实现类，需要包含一个集合，用来存放观察者的引用，以便数据变化时通知具体观察者。

4、具体观察者：观察者的实现类，包含主题接口的变量，以便具体主题将自己添加或删除在主题存放观察者的集合的引用。

 

UML：

 

 

 观察者模式 “推”：具体主题变化后数据全部交给具体观察者。

例子，求职中心与求职者，有一个大学毕业生和一个留学生都希望能及时知道求职中心最新的职业需求信息。

 

Subject：

/**
 * 
 */
package org.rico.pattern.demo.observer;

/**
 * @author rico 2013-3-3
 *  主题：定义具体主题需要实现的方法，如：添加、删除、通知观察者的方法。
 */
public interface Subject {
	
	/**
	 * 新增观察者
	 * @param observer
	 */
	public void add(Observer observer);
	
	/**
	 * 删除观察者
	 * @param observer
	 */
	public void delete(Observer observer);
	
	/**
	 * 主题通知观察者更新数据
	 */
	public void notifyObserver();
	
}

 

Observer：

/**
 * 
 */
package org.rico.pattern.demo.observer;

/**
 * @author rico 2013-3-3
 *  定义具体观察者用来更新数据的方法。
 */
public interface Observer {
	
	/**
	 * 观察者接受主题数据变化的通知，然后更新自己的数据。
	 * @param msg
	 */
	public void update(String msg);
}

 

HaiGuiStudent：

/**
 * 
 */
package org.rico.pattern.demo.observer.impl;

import org.rico.pattern.demo.observer.Observer;
import org.rico.pattern.demo.observer.Subject;

/**
 * @author rico 2013-3-3
 * 具体观察者（留学生），包含主题接口的变量，以便具体主题将自己添加或删除在主题存放观察者的集合的引用
 */
public class HaiGuiStudent implements Observer {
	private Subject subject;
	
	public HaiGuiStudent(Subject subject) {
		this.subject = subject;
		subject.add(this);
	}

	/* 更新数据(non-Javadoc)
	 * @see org.rico.pattern.demo.observer.Observer#update(java.lang.String)
	 */
	@Override
	public void update(String msg) {
		System.out.println("HaiGuiStudent: " + msg);
	}

}

 

JobCenter：

/**
 * 
 */
package org.rico.pattern.demo.observer.impl;

import java.util.ArrayList;
import java.util.List;

import org.rico.pattern.demo.observer.Observer;
import org.rico.pattern.demo.observer.Subject;

/**
 * @author rico 2013-3-3
 * 求职中心（具体主题）
 */
public class JobCenter implements Subject {
	private List<Observer> observers = null;
	private String msg;
	
	public JobCenter() {
		observers = new ArrayList<Observer>();
	}

	/* 新增求职者(non-Javadoc)
	 * @see org.rico.pattern.demo.observer.Subject#add(org.rico.pattern.demo.observer.Observer)
	 */
	@Override
	public void add(Observer observer) {
		if(!observers.contains(observer)) {
			observers.add(observer);
		}
	}

	/* 删除求职者(non-Javadoc)
	 * @see org.rico.pattern.demo.observer.Subject#delete(org.rico.pattern.demo.observer.Observer)
	 */
	@Override
	public void delete(Observer observer) {
		if(observers.contains(observer)) {
			observers.remove(observer);
		}
	}

	/* 数据更新，通知求职者(non-Javadoc)
	 * @see org.rico.pattern.demo.observer.Subject#notifyObserver()
	 */
	@Override
	public void notifyObserver() {
		for(Observer ob : observers) {
			ob.update(msg);
		}
	}

	public String getMsg() {
		return msg;
	}

	public void setMsg(String msg) {
		this.msg = msg;
	}

}

 

UniversityStudent：

/**
 * 
 */
package org.rico.pattern.demo.observer.impl;

import org.rico.pattern.demo.observer.Observer;
import org.rico.pattern.demo.observer.Subject;

/**
 * @author rico 2013-3-3
 * 具体观察者（大学毕业生），包含主题接口的变量，以便具体主题将自己添加或删除在主题存放观察者的集合的引用
 */
public class UniversityStudent implements Observer {
	private Subject subject;
	
	public UniversityStudent(Subject subject) {
		this.subject = subject;
		subject.add(this);
	}

	/* 更新数据(non-Javadoc)
	 * @see org.rico.pattern.demo.observer.Observer#update(java.lang.String)
	 */
	@Override
	public void update(String msg) {
		System.out.println("UniversityStudent: " + msg);
	}

}

 

 ObserverTest：

/**
 * 
 */
package org.rico.pattern.demo.observer;

import org.rico.pattern.demo.observer.impl.HaiGuiStudent;
import org.rico.pattern.demo.observer.impl.JobCenter;
import org.rico.pattern.demo.observer.impl.UniversityStudent;

/**
 * @author rico 2013-3-3
 * 
 */
public class ObserverTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		JobCenter jobCenter = new JobCenter();
		Observer university = new UniversityStudent(jobCenter);
		Observer haigui = new HaiGuiStudent(jobCenter);
		
		System.out.println("###################job one#######################");
		jobCenter.setMsg("job one......");
		jobCenter.notifyObserver();
		
		System.out.println("###################job two#######################");
		jobCenter.setMsg("job two......");
		jobCenter.notifyObserver();
		
		System.out.println("###################job three#######################");
		jobCenter.delete(university);
		jobCenter.setMsg("job three......");
		jobCenter.notifyObserver();
	}

}