package com.wanmei.meishu.ms;

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

//觀察者接口
interface Observable{
	//觀察
	void addSub(ISubject sub);
	//取消觀察
	void removeSub(ISubject sub,String msg);
	//讀取消息
	void watch(String msg);
	//獲取觀察者名稱
	String getName();
}
//觀察者實例
class Observer implements Observable {
	private String name;
	public Observer(String name) {
		this.name = name;
	}
	@Override
	public void addSub(ISubject sub){
		sub.addObserver(this);
		System.out.println("Observer:用戶【"+this.name+"】 訂閱了消息");
	}
	@Override
	public void removeSub(ISubject sub,String msg){
		sub.removeObserver(this);
		System.out.println("Observer:用戶【"+this.name+"】 取消了訂閱消息," + (msg == null ? "" : ("并說：" + msg)));
	}
	@Override
	public void watch(String msg) {
		System.out.println("Observer:用戶【"+this.name+"】讀取到的訂閱消息是：" + msg);
	}
	
	public String getName() {
		return name;
	}
}

//被觀察者接口
interface ISubject{
	//給觀察者們發(fā)送消息
	void sendMsg(String msg);
	//添加一個觀察者
	void addObserver(Observable user);
	//取消一個觀察者
	void removeObserver(Observable user);
}

//被觀察者實現(xiàn)方式
class SubjectImpl implements ISubject{
	
	//持有觀察者隊列
	private List<Observable> observerList;

	//添加一個觀察者
	public synchronized void addObserver(Observable user){
		if(observerList == null){
			observerList = new ArrayList<Observable>();
		}
		observerList.add(user);
		String str = "";
		for (Observable observable : observerList) {
			str+= observable.getName()+"、";
		}
		System.out.println("ISubject:目前已有用戶：" + str.substring(0, str.length()-1));
	}
	//取消一個觀察者
	public void removeObserver(Observable user){
		observerList.remove(user);
		if(!observerList.isEmpty()){
			String str = "";
			for (Observable observable : observerList) {
				str+= observable.getName()+"、";
			}
			System.out.println("ISubject:目前剩余用戶：" + str.substring(0, str.length()- 1));
		}
	}
	@Override
	public void sendMsg(String msg) {
		if(!observerList.isEmpty()){
			System.out.println("ISubject:發(fā)送消息：" + msg);
			for (Observable observable : observerList) {
				observable.watch(msg);
			}
		}
	}
	
}

public class ObserverTest {

	public static void main(String[] args) {
		ISubject sub = new SubjectImpl();
		//第一個觀察者
		Observable u1 = new Observer("吳文俊");
		u1.addSub(sub);
		Observable u2 = new Observer("吳華云");
		u2.addSub(sub);
		Observable u3 = new Observer("李爪哇");
		u3.addSub(sub);
		sub.sendMsg("PHP是世界上最好的語言！");
		u3.removeSub(sub,"去死吧，PHP");
		sub.sendMsg("PHP是世界上最好的語言！");
		
		
	}
}