用法介绍Java Observer模式

Java Observer是一种设计模式,它定义了对象之间的一对多依赖性,当一个对象改变状态,它的所有依赖者都会自动被通知并更新。

一、Java Observer模式基础

1、Observer模式主要是用于实现分布式系统的事件服务,实现事件驱动架构。其主要由两类对象组成:被观察者(Subject)和观察者(Observer)。


// 被观察者
public class Subject {
    private List observers = new ArrayList();
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
}

2、观察者(Observer)定义了一个更新接口,当被观察者状态发生改变时,这个接口就会被调用。


// 观察者
public interface Observer {
    void update(String message);
}

二、Java Observer模式实现步骤

1、首先,创建观察者接口和具体的观察者类。观察者接口定义了一个更新接口,具体的观察者类实现了观察者接口。


// 观察者接口
public interface Observer {
    void update(String message);
}

// 具体观察者类
public class ConcreteObserver implements Observer {
    public void update(String message) {
        System.out.println("ConcreteObserver get message: " + message);
    }
}

2、其次,创建被观察者类。被观察者类维护观察者列表,并实现注册观察者、移除观察者、通知观察者等方法。


// 被观察者类
public class Subject {
    private List observers = new ArrayList();

    public void registerObserver(Observer observer) {
        observers.add(observer);
    }
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
}

三、Java相应的Observer类的使用

1、Java内置的Observer模式主要涉及java.util.Observer接口和java.util.Observable类。Observable类是被观察者类,Observer接口是观察者接口。当Observable类的notifyObservers()方法被调用时,会通知所有已注册的观察者。


import java.util.Observable;
import java.util.Observer;

public class JavaObservable extends Observable {
    void change(String str) {
        setChanged();
        notifyObservers(str);
    }
}

public class JavaObserver implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("Received response: " + arg);
    }
}

2、使用Java内置的Observer模式,可以通过创建Observable子类和Observer实现类,然后使用Observer实例注册Observable实例,最后通过Observable实例来通知Observer实例。


public static void main(String args[]) {
    JavaObserver observer = new JavaObserver();
    JavaObservable observable = new JavaObservable();
    observable.addObserver(observer);
    observable.change("Hello, Observer!");
}

本文标题为:用法介绍Java Observer模式

基础教程推荐