首页 > 文章列表 > Java实现观察者模式的方法和示例

Java实现观察者模式的方法和示例

java
447 2023-04-29

JAVA怎样实现观察者模式

概念

观察者模式又叫做发布-订阅模式,是对象间的一对多的关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新

组成 

抽象主题角色(Subject

也叫抽象目标类,抽象主题知道自己的观察者有哪些,提供删除和新增观察者的方法以及通知观察者的抽象方法,由抽象类或接口实现

抽象观察者角色(Observer

包含了一个更新的抽象方法,当收到具体主题的更新通知后调用,由抽象类或接口实现

具体主题角色(Concrete Subject

也叫具体目标类,实现抽象目标类的通知方法,当具体主题发生改变时通知所有订阅自己的观察者

具体观察者角色(Concrete Observer

实现抽象观察者角色的抽象方法,收到主题更改通知后更改自身状态

实现 

抽象观察者Observer接口

包含一个观察者接收通知改变自身状态方法

public interface Observer {

	//收到通知,改变自身状态

    void update();

}

具体观察者ObserverOneObserverTwo

实现Observer接口中的update方法

public class ObserverOne implements Observer{

    @Override

    public void update() {

        System.out.println("第一个观察者收到通知,状态更新了");

    }

}
public class ObserverTwo implements Observer {

    @Override

    public void update() {

        System.out.println("第二个观察者收到通知,状态更新了");

    }

}

Subject接口

包含添加,删除,通知观察者方法,由抽象目标类实现,还有一个自身操作的方法,由具体目标类实现

public interface Subject {

    //添加观察者

    void add(Observer observer);

    //删除观察者

    void remove(Observer observer);

    //通知所有观察者

    void notifyObservers();

    //自身操作

    void operation();

}

抽象目标类AbstractSubject

抽象类,因为观察者数量不固定,所以使用Vector动态数组存储观察者,实现Subject接口中的add,remove,notifyObservers方法,operation方法由具体目标类实现

public abstract class AbstractSubject implements Subject{

    Vector<Observer> vector = new Vector<Observer>();

    @Override

    public void add(Observer observer){

        vector.add(observer);

    }

    @Override

    public void remove(Observer observer){

        vector.remove(observer);

    }

    @Override

    public void notifyObservers(){

        for (Observer observer : vector) {

            observer.update();

        }

    }

}

具体目标类MySubject

继承AbstractSubject类,实现operation方法,并在operation方法中调用notifyObservers方法以达到自身状态改变后通知观察者的效果

public class MySubject extends AbstractSubject{

    @Override

    public void operation() {

        System.out.println("具体目标状态改变");

        System.out.println("正在通知观察者。。。");

        notifyObservers();

        System.out.println("通知完毕!");

    }

}

测试类Test

public class Test {

    public static void main(String[] args) {

        MySubject mySubject = new MySubject();

        mySubject.add(new ObserverOne());

        mySubject.add(new ObserverTwo());

        mySubject.operation();

    }

}

总结 

观察者模式主要解决了什么问题

在低耦合的条件下,一个对象状态发生改变,其他对象会收到通知

观察者模式什么时候使用

一个对象状态改变,所有有依赖关系的对象都会收到广播通知

观察者模式的优点

观察者和目标是抽象耦合的,低耦合,是一套触发机制

观察者模式的缺点

  • ①如果一个目标中依赖的直接观察者和间接观察者有很多的话,通知所有观察者需要花费很多时间

  • ②如果观察者和被观察者之间有循环依赖的话,可能会出现循环调用,导致系统崩溃

  • ③观察者无法知道目标状态是如何变化的,只能知道目标状态发生了改变

观察者模式的注意事项

  • ①JAVA中已经有了观察者模式的支持类,可以直接使用

  • ②避免循环调用

  • ③如果顺序执行观察者的更新方法,某一观察者错误会导致系统卡住,一般采用异步方式。