美文网首页
Java设计模式之观察者模式

Java设计模式之观察者模式

作者: bamboolmc | 来源:发表于2018-05-18 16:11 被阅读0次

    概念

      观察者模式:又称发布(publish)-订阅(Subscribe)模式、模型(Model)-视图(View)模式、源(Source)-监听器(Listener)模式或从属者(Dependents)模式,是一种对象行为型模式。
      定义对象间的一对多的依赖关系,当被观察者对象进行状态改变时,则所有依赖它的观察者对象都会得到通知并更新状态。

    UML

    观察者模式

    角色

    • 抽象主题(Subject):又称抽象被观察者(Observable),抽象主题维护一个集合,用来保存所有观察者对象的引用。提供一个接口,用来添加或删除观察者对象。
    • 具体主题(ConcreteSubject):又称具体被观察者(ConcreteObservable),在具体主题状态发生改变时,给所有注册该主题的具体观察者对象发出通知。
    • 抽象观察者(Observer):观察者的抽象类,定义了一个update接口,得到主题更新的通知后,更新自己。
    • 具体观察者(ConcreteObserver):实现抽象观察者的update接口,给出具体的更新状态。

    简单示例

      笑傲江湖中辟邪剑谱一重出江湖,就引起了各大门派的觊觎,这就是典型的观察者模式啊。福威镖局被观察者、五岳剑派各大掌门等人为观察者,观察者模式开启。

    抽象主题(Observable)
    java.util库Observer源码

    package java.util;
    
    public class Observable {
        private boolean changed = false;
        private final ArrayList<Observer> observers;
    
        public Observable() {
            observers = new ArrayList<>();
        }
    
        public synchronized void addObserver(Observer o) {
            if (o == null)
                throw new NullPointerException();
            if (!observers.contains(o)) {
                observers.add(o);
            }
        }
    
        public synchronized void deleteObserver(Observer o) {
            observers.remove(o);
        }
    
        public void notifyObservers() {
            notifyObservers(null);
        }
    
        public void notifyObservers(Object arg) {
    
            Observer[] arrLocal;
    
            synchronized (this) {
                if (!hasChanged())
                    return;
    
                arrLocal = observers.toArray(new Observer[observers.size()]);
                clearChanged();
            }
    
            for (int i = arrLocal.length-1; i>=0; i--)
                arrLocal[i].update(this, arg);
        }
    
        public synchronized void deleteObservers() {
            observers.clear();
        }
    
        protected synchronized void setChanged() {
            changed = true;
        }
    
        protected synchronized void clearChanged() {
            changed = false;
        }
    
        public synchronized boolean hasChanged() {
            return changed;
        }
    
        public synchronized int countObservers() {
            return observers.size();
        }
    }
    

    具体主题(ConcreteSubject)
    福威镖局

    package com.bamboolmc.designpattern.ObserverMode;
    
    import java.util.Observable;
    
    public class FuWeiBoard extends Observable{
    
        //发布事件--辟邪剑谱重现江湖
        public void publishPiXie(){
            System.out.println("我福威镖局,辟邪剑谱重现江湖");
            //标志状态修改
            setChanged();
            //通知所有观察者
            notifyObservers();
        }
    }
    

    抽象观察者(Observer)
    java.util库Observer接口源码

    package java.util;
    
    public interface Observer {
        void update(Observable o, Object arg);
    }
    

    具体观察者(ConcreteObserver)
    林平之、岳不群、余沧海

    package com.bamboolmc.designpattern.ObserverMode;
    
    import java.util.Observable;
    import java.util.Observer;
    
    public class LinPingzhi implements Observer {
    
        public LinPingzhi() {
        }
    
        @Override
        public void update(Observable o, Object arg) {
            doSomething();
    
        }
    
        private void doSomething() {
            System.out.println("我林平之,这是我家祖传剑法!……  先要自*  &^*$*%  神功已成,我终于可以报仇了");
        }
    }
    
    package com.bamboolmc.designpattern.ObserverMode;
    
    import java.util.Observable;
    import java.util.Observer;
    
    public class YuCanghai implements Observer {
        public YuCanghai() {
        }
    
        @Override
        public void update(Observable o, Object arg) {
            doSomething();
    
        }
    
        private void doSomething() {
            System.out.println("我余沧海,江湖传闻的第一剑谱,是我的!………… 我擦,没抢到,晦气!");
        }
    }
    
    package com.bamboolmc.designpattern.ObserverMode;
    
    import java.util.Observable;
    import java.util.Observer;
    
    public class YueBuqun implements Observer{
        public YueBuqun() {
        }
    
        @Override
        public void update(Observable o, Object arg) {
            doSomething();
    
        }
        private void doSomething(){
            System.out.println("我岳不群,有了剑谱,我就是五岳盟主! …… \"欲练此功,必先自*\" 咔@%#&*   神功在体,谁敢跟我夺五岳盟主^_^");
        }
    }
    
    

    观察者模式使用

    package com.bamboolmc.designpattern.ObserverMode;
    
    import java.util.Observable;
    
    public class FuWeiBoard extends Observable{
    
        //发布事件--辟邪剑谱重现江湖
        public void publishPiXie(){
            System.out.println("我福威镖局,辟邪剑谱重现江湖");
            //标志状态修改
            setChanged();
            //通知所有观察者
            notifyObservers();
        }
    }
    

    输出结果

    我福威镖局,辟邪剑谱重现江湖
    我岳不群,有了剑谱,我就是五岳盟主! …… "欲练此功,必先自*" 咔@%#&*   神功在体,谁敢跟我夺五岳盟主^_^
    我余沧海,江湖传闻的第一剑谱,是我的!………… 我擦,没抢到,晦气!
    我林平之,这是我家祖传剑法!……  先要自*  &^*$*%  神功已成,我终于可以报仇了
    

    适用环境

    • 一个系统多个的对象对某些特定的对象的状态或者属性改变感兴趣,就可以采取该模式。
    • 事件多级触发场景。
    • 消息队列,事件总线处理机制

    作用

      最重要的作用就是解耦,将被观察者和观察者解耦,使其依赖性更小或者毫无依赖。

    相关文章

      网友评论

          本文标题:Java设计模式之观察者模式

          本文链接:https://www.haomeiwen.com/subject/vempdftx.html