观察者模式

观察者模式的定义

观察者模式也叫做发布订阅模式

定义：定义对象间一种一对多的依赖关系，使得每当一个对象改变状态，则所有依赖于它的对象都会得到通知并被自动更新。

观察者模式的通用类图如下：

观察者模式通用类图.png

名字解释

Subject被观察者

定义被观察者必须实现的职责，它必须能够动态地增加、取消观察者。它一般是抽象类或者是实现类，仅仅完成作为被观察者必须实现的职责：管理观察者并通知观察者。

Oberver观察者

观察者接收到消息后，即进行update（更新方法）操作，对接收到的信息进行处理。

ConcreteSubject具体的被观察者

定义被观察者自己的业务逻辑，同时定义对哪些事件进行通知。

ConcreteObserver具体的观察者

每个观察者在接收到消息后的处理反应是不同，各个观察者有自己的处理逻辑。

代码示例

被观察者

public abstract class Subject {
     //定义一个观察者数组
     private Vector<Observer> obsVector = new Vector<Observer>();
     //增加一个观察者
     public void addObserver(Observer o){
             this.obsVector.add(o);
     }
     //删除一个观察者
     public void delObserver(Observer o){
             this.obsVector.remove(o);
     }
     //通知所有观察者
     public void notifyObservers(){
             for(Observer o:this.obsVector){
                     o.update();
             }
     }
}

被观察者的职责非常简单，就是定义谁能够观察，谁不能观察，程序中使用ArrayList和Vector没有太大区别，ArrayList是线程异步，不安全；Vector是线程同步，安全。

具体的被观察者

public class ConcreteSubject extends Subject {
     //具体的业务
     public void doSomething(){
             /*
              * do something
              */
             super.notifyObservers();
     }
}

观察者

public interface Observer {
     //更新方法
     public void update();
}

具体的观察者

public class ConcreteObserver implements Observer {
     //实现更新方法
     public void update() {
             System.out.println("接收到信息，并进行处理！");
     }
}

场景类

public class Client {
     public static void main(String[] args) {
             //创建一个被观察者
             ConcreteSubject subject = new ConcreteSubject();
             //定义一个观察者
             Observer obs= new ConcreteObserver();
             //观察者观察被观察者
             subject.addObserver(obs);
             //观察者开始活动了
             subject.doSomething();
     }
}

观察者模式的扩展

JDK中已经提供了java.util.Observable实现类和java.util.Observer接口，我们直接使用现成类来实现一个小示例，模拟发邮件通知相关用户有新活动了

被观察者

import java.util.Observable;

public class Email extends Observable {
    private String account = "CCTV@email.com";
    private String content;

    public String getAccount() {
        return account;
    }


    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    /**
     * 有新活动就发送邮件
     */
    public void sendEmail(String content){
        this.setContent(account);

        //需要调用此方法，否则无法通知观察者
        super.setChanged();
        //通知所有的观察者
        super.notifyObservers();
    }
}

两个观察者

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

public class Zhangsan implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        Email email = (Email) o;
        System.out.println("张三：" + email.getAccount() + "： 发来有邮件，内容为：" + email.getAccount());
    }
}

public class Lisi implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        Email email = (Email) o;
        System.out.println("李四收到： "+email.getAccount()+ "： 发来有邮件，内容为："+email.getAccount());
    }
}

场景类

public class Client {
    public static void main(String[] args) {
        //两个观察者
        Zhangsan zhangsan = new Zhangsan();
        Lisi lisi = new Lisi();

        //被观察者
        Email email = new Email();
        email.addObserver(zhangsan);
        email.addObserver(lisi);

        email.sendEmail("有新活动了");

    }
}