导航：首页 > 开发技术 >

JAVA怎样实现观察者模式

发表于：2025-01-19 作者：千家信息网编辑

千家信息网最后更新 2025年01月19日，这篇文章将为大家详细讲解有关JAVA怎样实现观察者模式，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。概念观察者模式又叫做发布-订阅模式，是对象间的一对多的关系，当一

千家信息网最后更新 2025年01月19日JAVA怎样实现观察者模式

这篇文章将为大家详细讲解有关JAVA怎样实现观察者模式，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

概念

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

组成

抽象主题角色（Subject）

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

抽象观察者角色（Observer）

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

具体主题角色（Concrete Subject）

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

具体观察者角色（Concrete Observer）

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

实现

抽象观察者Observer接口

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

public interface Observer {        //收到通知，改变自身状态    void update();}

具体观察者ObserverOne和ObserverTwo

实现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 vector = new Vector();    @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();    }}