JAVA 设计模式观察者模式-阿里云开发者社区

JAVA 设计模式观察者模式

2015-01-20 797

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 用途观察者模式 (Observer) 观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

用途

观察者模式 (Observer)

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

观察者模式是一种 行为型模式。

结构

图-观察者模式结构图

Subject : 主题类，保存所有订阅此主题的观察者，观察者的 数量是任意的。定义 添加观察者 ( Attach) 和 删除观察者 (Detach) 的接口。

abstract class Subject {
     protected String name;
     protected String state;
     protected List<Observer> observers = new ArrayList<Observer>();

     public abstract String getState();
     public abstract void setState(String state);
     public abstract void Notify();

     public Subject(String name) {
         this.name = name;
    }

     public void Attach(Observer observer) {
        observers.add(observer);
    }

     public void Detach(Observer observer) {
        observers.remove(observer);
    }
}

Observer : 观察者类，定义更新接口 (Update)，当收到 Subject 的通知时，Observer 需要同步更新信息。

abstract class Observer {
     protected String name;
     protected Subject subject;
     public Observer(String name, Subject subject) {
         this.name = name;
         this.subject = subject;
    }
     public abstract void Update();
}

ConcreteSubject : 具体主题类，存储对于这个主题感兴趣的所有观察者。当内部状态发生变化时，应通知所有登记的观察者 (Notify)。

class ConcreteSubject extends Subject {
     public ConcreteSubject(String name) {
         super(name);
    }

    @Override
     public String getState() {
         return state;
    }

    @Override
     public void setState(String state) {
         this.state = state;
    }

    @Override
     public void Notify() {
        System.out.println("======= " + this.name + "主题发布新消息 =======");
         for (Observer observer : observers) {
            observer.Update();
        }
    }
}

ConcreteObserver : 具体观察者类，实现 Observer 的更新接口 (Update)，以便和 Subject 同步状态信息。

class ConcreteObserver extends Observer {
     private String state;
     public ConcreteObserver(String name, Subject subject) {
         super(name, subject);
    }

    @Override
     public void Update() {
        state = subject.getState();
        System.out.println( this.name + "收到当前状态：" + state);
    }
}

测试代码

public class ObserverPattern {
     public static void main(String[] args) {
        ConcreteSubject subject = new ConcreteSubject("天气");
        ConcreteObserver observer1 = new ConcreteObserver("张三", subject);
        ConcreteObserver observer2 = new ConcreteObserver("李四", subject);
        ConcreteObserver observer3 = new ConcreteObserver("王五", subject);

        subject.Attach(observer1);
        subject.Attach(observer2);
        subject.Attach(observer3);
        subject.setState("今天下雨");
        subject.Notify();

        subject.Detach(observer2);
        subject.setState("明天天晴");
        subject.Notify();
    }
}

View Code

运行结果

======= 天气主题发布新消息 =======
张三收到当前状态：今天下雨
李四收到当前状态：今天下雨
王五收到当前状态：今天下雨
======= 天气主题发布新消息 =======
张三收到当前状态：明天天晴
王五收到当前状态：明天天晴

View Code