Shiliew 植树人

观察者模式


  工作上的项目可能又要经历一次重构,因为作为上游业务,我们做了太多控制下游业务逻辑的事情,使得项目之间的耦合很高,不利于功能的扩展和维护。因此想到了观察者设计模式,上游业务只负责通知,而不去控制下游怎么做,解除功能上的耦合。

观察者模式

  观察者模式(又被称为发布-订阅(Publish/Subscribe)模式,属于行为型模式的一种,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时,会通知所有的观察者对象,使他们能够自动更新自己。

  观察者模式主要是为了维护不同功能模块对象的一致性的同时降低或者解除它们之间的耦合。

角色

1.抽象主题(Subject):它把所有观察者对象的引用保存到一个聚集里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象。

2.具体主题(ConcreteSubject):将有关状态存入具体观察者对象;在具体主题内部状态改变时,给所有登记过的观察者发出通知。

3.抽象观察者(Observer):为所有的具体观察者定义一个接口,在得到主题通知时更新自己。

4.具体观察者(ConcreteObserver):实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题状态协调。

类图

  引用网上好文的类图: 观察者模式类图

Java代码示例

抽象主题


package com.shiliew.observe;


public interface Subject {

    void addObserve(Observe observe);
    void deleteObserve(Observe observe);
    void notifyObserve();
}

抽象观察者


package com.shiliew.observe;

public abstract class Observe {

    public abstract void update(String state);
}

具体主题


package com.shiliew.observe;

import java.util.ArrayList;
import java.util.List;

public class ConcreteSubject implements Subject {

    private List<Observe> list = new ArrayList<Observe>();

    private String state;

    public String getState() {
        return state;
    }

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

    public void addObserve(Observe observe){
        list.add(observe);
    }

    public void deleteObserve(Observe observe){
        list.remove(observe);
    }

    public void notifyObserve(){
        for (Observe observe : list){
            observe.update(this.getState());
        }
    }
}

具体观察者


package com.shiliew.observe;

public class ConcreteObserve extends Observe {

    public void update(String state){
        System.out.println("state:" + state);
    }
}

测试类


package com.shiliew.test;

import com.shiliew.observe.ConcreteObserve;
import com.shiliew.observe.ConcreteSubject;
import com.shiliew.observe.Observe;

public class Test {

    public static void main(String [] args){
        ConcreteSubject subject = new ConcreteSubject();

        Observe observe = new ConcreteObserve();

        subject.addObserve(observe);

        subject.setState("状态改变!");

        subject.notifyObserve();
    }
}

参考

设计模式学习笔记-观察者模式


Comments

comments powered by HyperComments