Java--设计模式-15-观察者模式

packagecom.xing.design.observer;
/***  观察者* @author xing*/publicinterfaceObserver {
/*** 观察到的响应*/voidresponse(Stringmessage);
}

packagecom.xing.design.observer;
/*** 观察者1* @author xing* @createTime*/publicclassObserverOneimplementsObserver{
@Overridepublicvoidresponse(Stringmessage) {
System.out.println("我是观察者1，收到->"+message);
  }
}
packagecom.xing.design.observer;
/*** 观察者2* @author xing* @createTime*/publicclassObserverTwoimplementsObserver{
@Overridepublicvoidresponse(Stringmessage) {
System.out.println("我是观察者2，收到->"+message);
  }
}

packagecom.xing.design.observer;
importjava.util.ArrayList;
importjava.util.List;
/*** 被观察的目标类* @author xing*/publicclassObserveTheTarget {
/*** 存放观察者*/protectedList<Observer>observerList=newArrayList<Observer>();
/*** 通知消息*/privateStringmessage;
publicvoidsetMessage(Stringmessage) {
this.message=message;
callObserver();
  }
/*** 增加观察者* @param observer*/publicvoidadd(Observerobserver) {
observerList.add(observer);
    }
/*** 删除观察者* @param observer*/publicvoidremove(Observerobserver) {
observerList.remove(observer);
    }
publicvoidcallObserver() {
System.out.println("被观察的目标类ObserveTheTarget发出通知"+message);
for(Observerobserver : observerList) {
observer.response(message);
      }
    }
}

packagecom.xing.design.observer;
publicclassObserverDemo {
publicstaticvoidmain(String[] args) {
// 被观察的目标ObserveTheTargetobserveTheTarget=newObserveTheTarget();
// 观察者1ObserverOneobserverOne=newObserverOne();
// 观察者2ObserverTwoobserverTwo=newObserverTwo();
// 添加观察者observeTheTarget.add(observerOne);
observeTheTarget.add(observerTwo);
// 被观察目标变化时，观察者会随之反应observeTheTarget.setMessage("兄弟们，你们好啊！哈哈哈哈哈");
observeTheTarget.setMessage("兄弟们，再见啊！");
// 去掉观察者1observeTheTarget.remove(observerOne);
observeTheTarget.setMessage("小2，就剩下你了啊！");
  }
}