Java设计模式-观察者模式

栏目: 后端 · 发布时间: 5年前

内容简介:观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态上发生变化时,会通知所有观察者对象,让他们能够自动更新自己。观察者模式主要由以下四个角色组成,分别是抽象主题角色、抽象观察者角色、具体主题角色、具体观察者角色。把所有观察者对象的引用保存在一个集合中,每个抽象主题角色都可以有任意数量的观察者,抽象主题提供一个接口,可以增加和删除观察者角色,一般用一个抽象类或接口来实现。

观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态上发生变化时,会通知所有观察者对象,让他们能够自动更新自己。

观察者模式的组成

观察者模式主要由以下四个角色组成,分别是抽象主题角色、抽象观察者角色、具体主题角色、具体观察者角色。

抽象主题角色

把所有观察者对象的引用保存在一个集合中,每个抽象主题角色都可以有任意数量的观察者,抽象主题提供一个接口,可以增加和删除观察者角色,一般用一个抽象类或接口来实现。

抽象观察者角色

为所有具体的观察者定义一个接口,在得到主题的通知时更新自己。

具体主题角色

在具体主题内部状态改变时,给所有登记过的观察者发出通知,具体主题角色通常用一个子类实现。

具体观察者角色

该角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态相协调,如果需要,具体观察者角色可以有一个指向具体主题角色的引用,通常用一个子类实现

观察者模式的代码示例

抽象主题角色:

public interface AbstractSubject {
    public void addObserver(AbstractObserver observer);
    public void removeObserver(AbstractObserver observer);
    public void notification();
}
复制代码

具体主题角色:

public class ConcreteSubject implements AbstractSubject {
    List<AbstractObserver> list = new ArrayList<AbstractObserver>();
    @Override
    public void addObserver(AbstractObserver observer) {
        list.add(observer);
    }
    @Override
    public void removeObserver(AbstractObserver observer) {
        list.remove(observer);
    }
    # 状态改变了,所有观察者更新自己的界面
    @Override
    public void notification() {
        for (AbstractObserver abstractObserver : list) {
            abstractObserver.update();
        }
    }
}
复制代码

抽象观察者角色:

public interface AbstractObserver {
    public void update();
}
复制代码

测试类

class Client {
    public static void main(String[] args) {
       #生成一个主题角色
        AbstractSubject subject = new ConcreteSubject();
        #为主题角色增加观察者对象,这里采用匿名内部类的方式,与AWT编程里的安装监听器类似
        subject.addObserver(new AbstractObserver() {
            @Override
            public void update() {
                System.out.println("A同学您的APP需要更新");
            }
        });
        subject.addObserver(new AbstractObserver() {
            @Override
            public void update() {
                System.out.println("B同学您的APP需要更新");
            }
        });
        subject.addObserver(new AbstractObserver() {
            @Override
            public void update() {
                System.out.println("C同学您的APP需要更新");
            }
        });
        subject.notification();
    }
}
复制代码

Java内置的观察者模式框架

java内置观察者模式框架提供了 类Observable接口Observer

类Observable 对应抽象主题角色,内部维护Vector集合来存储具体观察者角色 接口Observer 对应抽象观察者角色

根据上面在描述,如何基于 Java 内置的观察者模式框架实现一个观察者模式呢?

  1. 写一个类(具体主题角色)继承Observable(抽象主题角色),只需要写一个change方法即可 (该方法作用是通知已注册的具体主题角色更新自己)
  2. 写一个类(具体观察者角色)实现Observer(抽象观察者角色),只需要实现方法update(Observable o, Object arg)即可
  3. 写一个测试类进行测试

代码实战演示

具体主题角色:

public class Watched extends Observable {
    #状态改变的时候调用已注册的观察者的update方法,让它们更新自己
    public void count(int number) {
        for (; number >= 0; number--) {
            try {
                Thread.sleep(1000);
                #告知变更
                setChanged();     
                 #通知所有与我相关的Observer
                notifyObservers(number);  
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}
复制代码

具体观察者角色:

public class Watcher implements Observer {
    #当主题角色事件触发时,会调用所有已注册的具体观察者角色的update方法
    @Override
    public void update(Observable o, Object arg) {
        int number = (Integer) arg;
        System.out.println(number);
    }
}
复制代码

测试类:

public class Client {
    public static void main(String[] args) {
        #创建主题角色
        Watched watched = new Watched();
        #创建观察者角色
        Observer watcher1 = new Watcher();
        #自实现
        Observer watcher2 = new Observer() {
            @Override
            public void update(Observable o, Object arg) {
                int number = (Integer) arg;
                if (0 == number) {
                    System.out.println("done");
                }
            }
        };
        watched.addObserver(watcher1);
        watched.addObserver(watcher2);
        watched.count(10);
    }
}
复制代码

java观察者模式框架的总结

  • 被观察者要继承 Observable
  • 被观察者通知观察者时,也就是 调用notifyObservers方法时一定要先调用setChanged()方法 ,该方法作用是将对象里面的changed这个boolean变量设为true,因为notifyObservers要首先检查该变量是否为true,如果为false就不执行而直接返回了。
  • Observable类中两个重载的notifyObservers方法,带参数的那个方法里面的参数就是Observer接口中的update方法中的第二个参数。 notifyObservers(number); 中的number变量参数,实际是传递到Observer接口中 update(Observable o, Object arg) 的第二个参数arg中的。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

C++Primer Plus

C++Primer Plus

Stephen Prata、孙建春、韦强 / 孙建春、韦强 / 人民邮电出版社 / 2005-5 / 72.00元

C++ Primer Plus(第五版)中文版,ISBN:9787115134165,作者:(美)Stephen Prata著;孙建春,韦强译一起来看看 《C++Primer Plus》 这本书的介绍吧!

HTML 编码/解码
HTML 编码/解码

HTML 编码/解码

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

UNIX 时间戳转换
UNIX 时间戳转换

UNIX 时间戳转换