观察者模式

概述

如果一个对象A的行为依赖另一个对象B的状态，我们可以有两种实现方式：

一种是对象A轮询对象B的状态，根据轮询结果决定自己的行为；另一种是对象B在自身状态发生改变时，主动通知对象A。

不难看出，第二种凡是会比第一种方式效率高，观察者模式即采用第二种方式，观察者模式可以用于事件监听、通知发布等场合。可以确保观察者在不使用轮询监控的情况下，及时收到相关消息和事件。

类图

 

 主题接口依赖观察者接口，因为要在主题中注册观察者（观察者订阅主题）

 

jdk已经提供了观察者模式

实例

Observer

/**
 * 观察者接口
 *
 * @author zhya
 * @date 2018/9/14
 **/
public interface IObserver {
    /**
     * 通知
     *
     * @param event
     */
    void update(Event event);
}

Concrete Observer

/**
 * 实际观察者
 *
 * @author zhangyang
 * @date 2018/9/14
 **/
public class Observer implements IObserver {
    private String name;

    public Observer(String name) {
        this.name = name;
    }

    /**
     * 通知
     *
     * @param event
     */
    @Override
    public void update(Event event) {
        System.out.println(new StringBuffer("observer ").append(this.name).append(" received notification : ").append(event.getMsg()));
    }
}

Subject

/**
 * 主题/被观察者接口
 *
 * @author zhangyang
 * @date 2018/9/14
 **/
public interface ISubject {
    /**
     * 注册监听者
     *
     * @param observer
     */
    void attach(IObserver observer);

    /**
     * 注销监听者
     *
     * @param observer
     */
    void deattach(IObserver observer);

    /**
     * 变更通知
     *
     * @param event
     */
    void inform(Event event);
}

Concrete Subject

import java.util.List;
import java.util.Vector;

/**
 * 实际主题/被观察者
 *
 * @author zhangyang
 * @date 2018/9/14
 **/
public class Subject implements ISubject {
    private final List<IObserver> observers = new Vector<>();

    /**
     * 注册监听者
     *
     * @param observer
     */
    @Override
    public void attach(IObserver observer) {
        if (!observers.contains(observer)) {
            observers.add(observer);
        }
    }

    /**
     * 注销监听者
     *
     * @param observer
     */
    @Override
    public void deattach(IObserver observer) {
        observers.remove(observer);
    }

    /**
     * 变更通知
     *
     * @param event
     */
    @Override
    public void inform(Event event) {
        System.err.println("subject has new event : " + event.toString());
        observers.forEach(observer -> observer.update(event));
    }
}

Main测试类

/**
 * 测试类
 *
 * @author zhya
 * @date 2018/9/14
 **/
public class Main {
    public static void main(String[] args) {
        // 监听者
        IObserver observer1 = new Observer("observer1");
        IObserver observer2 = new Observer("observer2");

        // 主题
        ISubject subject = new Subject();

        // 注册监听
        subject.attach(observer1);
        subject.attach(observer2);

        // 主题状态变更
        Event event = new Event("ding ding");
        subject.inform(event);
        System.out.println("------------------------------------------");

        // 注销监听
        subject.deattach(observer1);

        // 主题状态变更
        event = new Event("dang dang");
        subject.inform(event);

    }
}

执行结果