观察者模式 Observer
这是软件设计模式的一种。
又被称为:
发布-订阅<Publish/Subscribe>模式、
模型-视图<Model/View>模式、
源-收听者<Source/Listener>模式
或从属者<Dependents>模式)
观察者模式(Observer)完美的将观察者和被观察的对象分离开。
此种模式中,一个目标物件管理所有相依于它的观察者物件,并且在它本身的状态改变时主动发出通知。
这通常透过呼叫各观察者所提供的方法来实现。
观察者设计模式:观察者设计模式解决的问题时当一个对象发生指定的动作时,要通过另外一个对象做出相应的处理。
观察者设计模式的步骤:
1. 当前目前对象发生指定的动作是,要通知另外一个对象做出相应的处理,这时候应该把对方的相应处理方法定义在接口上。
2. 在当前对象维护接口的引用,当当前对象发生指定的动作这时候即可调用接口中的方法了。
此种模式通常被用来实作事件处理系统。 有多个观察者时,不可以依赖特定的通知次序。
Swing大量使用观察者模式,许多GUI框架也是如此。
案例说明: 编写一个气象站 类、一个工人 类 、一个学生类,当气象站更新天气 的时候,要通知 人和学生 做出相应的处理。
public class WeatherStation { private String weather;//当前天气 String[] weathers = {"下雨","下雪","下冰雹","出太阳"}; private static List<BookWeather> list = new ArrayList<BookWeather>();//该集合中存储的都是需要收听天气预报的人 Random random = new Random(); public void addListaner(BookWeather e){ list.add(e); } public void startWork(){ //开始工作 new Thread(){ @Override public void run() { while(true){ updateWeather();
for(BookWeather item : list)
{ item.notifyWeather(weather); //更新天气给收听者 } try { Thread.sleep(random.nextInt(1000)+500);//每0.5-1.5秒更新一次天气 } catch (InterruptedException e) { e.printStackTrace(); } } } }.start(); } public void updateWeather(){//更新天气 weather = weathers[random.nextInt(4)]; System.out.println("天气:"+ weather); }
}
public interface BookWeather { //订阅天气预报的接口 public void notifyWeather(String weather); }
public class Person implements BookWeather {//Person要根据天气做出相应的处理 String name; public Person(String name){ this.name = name; } //下雨","下雪 ","下冰雹","出太阳" @Override public void notifyWeather(String weather) { if("下雨".equals(weather)){ System.out.println(name+"打着雨伞 上班"); }else if("下雪".equals(weather)){ System.out.println(name+"戴着被子 上班"); }else if("下冰雹".equals(weather)){ System.out.println(name+"带着头盔 上班"); }else if("出太阳".equals(weather)){ System.out.println(name+"嗮着太阳 上班"); } } }
public class Student implements BookWeather { String name; public Student(String name) { this.name = name; } @Override public void notifyWeather(String weather) { if ("下雨".equals(weather)) { System.out.println(name + "打着雨伞 上学"); } else if ("下雪".equals(weather)) { System.out.println(name + "戴着被子 上学"); } else if ("下冰雹".equals(weather)) { System.out.println(name + "带着头盔 上学"); } else if ("出太阳".equals(weather)) { System.out.println(name + "嗮着太阳 上学"); } } }
public class test { public static void main(String[] args) throws InterruptedException { WeatherStation station = new WeatherStation(); station.startWork(); Person p1 = new Person("小明"); Person p2 = new Person("小红"); Student p3 = new Student("小青 "); station.addListaner(p1); station.addListaner(p2); station.addListaner(p3); } }
输出: