观察者模式简单理解

这里介绍的只是这种模式中最简单的部分。这里的特点就是“统一通知，各自处理”。先看下项目结构：

1、一共就这几个类。我先是写了“目标对象（被观察者）”这个类，然后被观察者需要知道有哪些“观察者”，相应的，需要提供接口（方法）给外界添加、删除“观察者”:

WeatherSubject.class

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

/*
 * 目标对象，它知道观察它的观察者，并提供注册（添加）和删除观察者的接口
 * @author 火龙裸先生
 * */
public class WeatherSubject {
    
    //用来保存注册的观察者对象
    private List<IObserver> observers = new ArrayList<IObserver>();
    
//    attach detach notifyObservers
    //把订阅天气的人添加到订阅者列表中
    public void attach(IObserver observer){
        observers.add(observer);
    }
    
    
    /**
     * 删除集合中的指定观察者(订阅天气的人)
     * @author 火龙裸先生
     * */
    public void detach(IObserver observer){
        observers.remove(observer);
    }
    
    /**
     * 通知所有注册的观察者对象(所有订阅天气的人)
     * @author 火龙裸先生
     * */
    protected void notifyObservers(){
        for(IObserver observer : observers){
            observer.updata(this);
        }    
    }

}

2、虽然有了上面这个目标对象（被观察者），但是还要有一个再具体的目标对象（被观察者）:

ConcreteWeatherSubject.class

/**
 * 具体的目标对象，负责把有关状态存入到相应的观察者对象中
 * 
 * */
public class ConcreteWeatherSubject extends WeatherSubject {
    
    //获取天气的内容信息
    private String weatherContent;

    public String getWeatherContent() {
        return weatherContent;
    }

    public void setWeatherContent(String weatherContent) {
        this.weatherContent = weatherContent;
        //内容有了，说明天气更新了，通知所有订阅天气的人
        this.notifyObservers();
    }
}

3、上面的目标对象（被观察者）中的"notifyObservers()"方法中，调用了一个updata(this)方法，传递的参数是它当前类的对象:

IObserver.class

/**
 * 这是一个观察者接口，定义一个更新的接口给那些在目标发生改变的时候被通知的对象
 * @author火龙裸先生
 * */
public interface IObserver {

    /**
     * 更新数据的接口
     * subject 传入目标对象,方便获取相应的目标对象的状态
     * @author 火龙裸先生
     * */
    void updata(WeatherSubject weatherSubject);

}

4、OK，现在终于要开始写我们的“观察者”了，这里通过实现上面的观察者接口，来实现具体的更新操作:

ConcreteObserver.class

/**
 * 具体的观察者对象，实现更新的方法，使自身的状态和目标的状态保持一致
 * @author 火龙裸先生
 * */
public class ConcreteObserver implements IObserver{
    //观察者的名字，是谁收到了这个讯息，你的女朋友还是他老妈
    private String observerName;
    
    //天气内容的情况,这个消息从目标处获取
    private String weatherContent;
    
    //提醒的内容，你的女朋友提醒约会。而她老妈提醒购物
    private String remindThing;

    
    public String getObserverName() {
        return observerName;
    }


    public void setObserverName(String observerName) {
        this.observerName = observerName;
    }


    public String getWeatherContent() {
        return weatherContent;
    }


    public void setWeatherContent(String weatherContent) {
        this.weatherContent = weatherContent;
    }


    public String getRemindThing() {
        return remindThing;
    }


    public void setRemindThing(String remindThing) {
        this.remindThing = remindThing;
    }

    /**
     * 获取目标类的状态同步到观察者的状态中去
     * */
    public void updata(WeatherSubject weatherSubject) {
        weatherContent = ((ConcreteWeatherSubject)weatherSubject).getWeatherContent();
        System.out.println(observerName+"收到了。"+weatherContent+remindThing);
    }

}

5、现在模式已经写完了，那么还差一个测试类:

public class Client {

    /**
     *  测试类
     * @param args
     */
    public static void main(String[] args) {
        //1 创建目标
        ConcreteWeatherSubject weather = new ConcreteWeatherSubject();
        
        //2 创建观察者
        ConcreteObserver observerGirl = new ConcreteObserver();
        ConcreteObserver observerMum = new ConcreteObserver();
        observerGirl.setObserverName("女朋友");
        observerGirl.setRemindThing("咱们一块去约会吧,哈哈哈。。。。。");
        
        observerMum.setObserverName("丈母娘");
        observerMum.setRemindThing("适合去逛商场。");
        
        //3 注册观察者
        weather.attach(observerGirl);
        weather.attach(observerMum);
        
        //4 目标发布天气
        weather.setWeatherContent("明天天气晴朗，气温28度，蓝天白云。");
    }

}

运行结果：