【ArcGIS微课1000例】0107：ArcGIS加载在线历史影像服务WMTS-CFANZ编程社区

核心

观察者模式主要用于1：N的通知。当一个对象(目标对象Subject或者Abservable)的状态变化时，他需要及时告知一系列对象(观察者对象，Observer),令他们做出响应。
通知观察者的方式：
- 推:
  - 每次都会把通知以广播方式发送给所有观察者，所有观察者只能被动接收。
- 拉：
  - 观察者只要知道有情况变化即可。至于什么时候获取内容，获取什么内容，都可以自主决定。

观察者模式角色

抽象主题对象(Subject)： 聚合所有的观察者，提供注册和移除观察者的方法，并且提供通知所有观察者的方法。
具体的主题对象(ConcreteSubject)： 实现抽象主题对象。并提供状态修改方法；
抽象观察者(Observer)： 提供更新观察者的方法；
具体观察者(ConcreteObserver)： 实现抽象观察者.

场景

聊天室程序的创建。服务器创建好后，A,B,C三个客户端连上来公开聊天。A向服务器发送数据，服务器端聊天数据改变。我们希望将这些聊天数据分别发给其他在线的客户。也就是说，每个客户端需要更新服务端的数据；
网站上，很多人订阅了“java主题“的新闻，当有这个主题新闻时，就会将这些新闻发送给所有订阅的人。
这些场景，我们都可以使用观察者模式来处理。我们可以把多个订阅者、客户端称之为观察者；需要同步给多个订阅者的数据封装到对象中，称之为目标。

开发中常见的场景

聊天室程序的服务器转发给所有客户端；
网络游戏场景中，服务器将客户端的状态进行分发；
邮件订阅；
servlet中监听器的实现；
spring项目中的事件监听器的实现；

代码实现

抽象主题对象

/**
 * 抽象主题对象
 */
public abstract class Subject {
	// 所有的观察者
	protected List<Observer> list = new ArrayList<Observer>();	
	public void registerObserver(Observer obs){
		list.add(obs);
	}
	public void removeObserver(Observer obs){
		list.remove(obs);
	}
	//通知所有观察者更新状态
	public void notifyAllObserver(){
		for(Observer obs:list){
			obs.update(this);
		}
	}
}

具体主题对象

/**
 * 具体的主题对象
 */
public class ConcreteSubject extends Subject{
	private int state;
	public int getState() {
		return state;
	}
	public void setState(int state) {
		this.state = state;
		//主题(目标)对象发生变化，请通知所有观察者
		this.notifyAllObserver();
	}
}

抽象观察者类

/**
 * 	抽象观察者
 */
public interface Observer {
	void update(Subject subject);	
}

具体观察者类

/**
 * 具体观察者A
 */
public class AObserver implements Observer{
	private int state;
	public int getState() {
		return state;
	}
	public void setState(int state) {
		this.state = state;
	}
	@Override
	public void update(Subject subject) {
		this.state=((ConcreteSubject)subject).getState();
	}
}
/**
 * 具体观察者B
 */
public class BObserver implements Observer{
	private int state;
	
	public int getState() {
		return state;
	}
	public void setState(int state) {
		this.state = state;
	}
	@Override
	public void update(Subject subject) {
		this.state=((ConcreteSubject)subject).getState();
	}
}

客户端调用

public static void main(String[] args) {
	//目标对象
	ConcreteSubject subject=new ConcreteSubject();
	//创建多个观察者
	AObserver observerA=new AObserver();
	BObserver observerB=new BObserver();
	//将观察者添加到subject对象的观察者队伍中
	subject.registerObserver(observerA);
	subject.registerObserver(observerB);
	
	//改变subject状态之前
	System.out.println("改变subject状态之前");
	System.out.println(observerA.getState());
	System.out.println(observerB.getState());
	
	//改变subject状态
	subject.setState(300);
	//观察者状态是否发生变换
	System.out.println("改变subject状态之后");
	System.out.println(observerA.getState());
	System.out.println(observerB.getState());
}