java设计模式-----9、观察者模式

  Observer模式是行为模式之一,它的作用是当一个对象的状态发生变化时,能够自动通知其他关联对象,自动刷新对象状态。

  Observer模式提供给关联对象一种同步通信的手段,使某个对象与依赖它的其他对象之间保持状态同步。

  观察者模式的结构

  观察者模式的角色和职责

  1、Subject(被观察者)
      被观察的对象。当需要被观察的状态发生变化时,需要通知队列中所有观察者对象。Subject需要维持(添加,删除,通知)一个观察者对象的队列列表。

  2、ConcreteSubject
      被观察者的具体实现。包含一些基本的属性状态及其他操作。

  3、Observer(观察者)
      接口或抽象类。当Subject的状态发生变化时,Observer对象将通过一个callback函数得到通知。

  4、ConcreteObserver
      观察者的具体实现。得到通知后将完成一些具体的业务逻辑处理。

  而被观察者想要起作用,就必须继承java.util包下的Observable类,这是它的方法,后面会有介绍

构造方法摘要
Observable()
          构造一个带有零个观察者的 Observable。
方法摘要
 void addObserver(Observer o)
          如果观察者与集合中已有的观察者不同,则向对象的观察者集中添加此观察者。
protected  void clearChanged()
          指示对象不再改变,或者它已对其所有的观察者通知了最近的改变,所以 hasChanged 方法将返回 false
 int countObservers()
          返回 Observable 对象的观察者数目。
 void deleteObserver(Observer o)
          从对象的观察者集合中删除某个观察者。
 void deleteObservers()
          清除观察者列表,使此对象不再有任何观察者。
 boolean hasChanged()
          测试对象是否改变。
 void notifyObservers()
          如果 hasChanged 方法指示对象已改变,则通知其所有观察者,并调用 clearChanged 方法来指示此对象不再改变。
 void notifyObservers(Object arg)
          如果 hasChanged 方法指示对象已改变,则通知其所有观察者,并调用 clearChanged 方法来指示此对象不再改变。
protected  void setChanged()
          标记此 Observable 对象为已改变的对象;现在 hasChanged 方法将返回 true

  下面写一个例子:新建一个Person类

 1 public class Person {
 2     private String name;
 3     private String sex;
 4     private int age;
 5     
 6     public String getName() {
 7         return name;
 8     }
 9     public void setName(String name) {
10         this.name = name;
11     }
12     public String getSex() {
13         return sex;
14     }
15     public void setSex(String sex) {
16         this.sex = sex;
17     }
18     public int getAge() {
19         return age;
20     }
21     public void setAge(int age) {
22         this.age = age;
23     }
24 }

   我们要做的就是监听成员变量name,sex,age的变化,在数值变化是,执行我们的操作,所以Person就是被观察者,所以server必须继承Observable,而Observable中有这三个方法:

  1、notifyObservers() : 如果 hasChanged 方法指示对象已改变,则通知其所有观察者,并调用 clearChanged 方法来指示此对象不再改变。

    这个方法是通知观察者被观察者是否改变的,只要hasChanged()方法指示的对象改变,就会调用观察者中的方法。

  2、hasChanged() : 测试对象是否改变。

  3、setChanged() :标记此 Observable 对象为已改变的对象;现在 hasChanged 方法将返回 true

  所以,如果想观察成员变量是否改变,就要在set方法中,执行setChanged()与notifyObservers()

  所以,被观察者应该改为:

 1 import java.util.Observable;
 2 
 3 public class Person extends Observable{
 4     private String name;
 5     private String sex;
 6     private int age;
 7     
 8     public String getName() {
 9         return name;
10     }
11     public void setName(String name) {
12         this.name = name;
13         this.setChanged();
14         this.notifyObservers();
15     }
16     public String getSex() {
17         return sex;
18     }
19     public void setSex(String sex) {
20         this.sex = sex;
21         this.setChanged();
22         this.notifyObservers();
23     }
24     public int getAge() {
25         return age;
26     }
27     public void setAge(int age) {
28         this.age = age;
29         this.setChanged();
30         this.notifyObservers();
31     }
32 }

  有了被观察者,就要有观察者,观察者必须实现java.util包下的Observer接口,并重写update(Observable o, Object arg)方法,当被观察者改变时,就会执行update()方法

 1 import java.util.Observable;
 2 import java.util.Observer;
 3 
 4 public class MyObserver implements Observer {
 5 
 6     @Override
 7     public void update(Observable o, Object arg) {
 8         System.out.println("对象已改变");
 9     }
10 
11 }

  现在,就可以执行看一看了。不过在执行set()方法之前一定要使用addObserver(Observer o) 这个方法注册观察者,不然不会生效。

 1 public class MainClass {
 2     public static void main(String[] args) {
 3         Person person = new Person();
 4         //注册观察者
 5         person.addObserver(new MyObserver());
 6         person.setName("小明");
 7         person.setSex("男");
 8         person.setAge(18);
 9     }
10 }

输出结果是这样的:

      对象已改变
      对象已改变
      对象已改变

  同时,notifyObservers()为什么是s结尾呢,因为我们可以同时注册多个观察者,这样写

 1 public class MainClass {
 2     public static void main(String[] args) {
 3         Person person = new Person();
 4         //注册观察者
 5         person.addObserver(new MyObserver());
 6         person.addObserver(new MyObserver());
 7         
 8         person.setName("小明");
 9         person.setSex("男");
10         person.setAge(18);
11     }
12 }

  我们注册两个观察者,两个都会生效,结果就变为了:    

      对象已改变
     对象已改变
     对象已改变
     对象已改变
     对象已改变
     对象已改变

  还有三个方法deleteObserver(Observer o) ,deleteObservers() ,countObservers() 

 1 public class MainClass {
 2     public static void main(String[] args) {
 3         Person person = new Person();
 4         //注册观察者
 5         MyObserver myObserver = new MyObserver();
 6         person.addObserver(myObserver);
 7         person.addObserver(new MyObserver());
 8         //获得当前对象已注册的观察者数目
 9         person.countObservers();
10         //删除指定的一个观察者
11         person.deleteObserver(myObserver);
12         //删除该对象全部观察者
13         person.deleteObservers();
14         
15         person.setName("小明");
16         person.setSex("男");
17         person.setAge(18);
18     }
19 }

  

  观察者模式的典型应用

    1、侦听事件驱动程序设计中的外部事件

    2、侦听/监视某个对象的状态变化

    3、发布者/订阅者(publisher/subscriber)模型中,当一个外部事件(新的产品,消息的出现等等)被触发时,通知邮件列表中的订阅者

原文地址:https://www.cnblogs.com/xiaobai1226/p/8528322.html