观察者模式

观察者模式是使用频率最高的设计模式之一，它用于建立一种对象与对象之间的依赖关系，一个对象发生改变时将自动通知其他对象，其他对象将相应作出反应。在观察者模式中，发生改变的对象称为观察目标，而被通知的对象称为观察者，一个观察目标可以对应多个观察者，而且这些观察者之间可以没有任何相互联系，可以根据需要增加和删除观察者，使得系统更易于扩展。

观察者模式(Observer Pattern)：定义对象之间的一种一对多依赖关系，使得每当一个对象状态发生改变时，其相关依赖对象皆得到通知并被自动更新。观察者模式的别名包括发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。观察者模式是一种对象行为型模式。

观察者模式一般有以下几种角色： 
● Subject（目标）：目标又称为主题，它是指被观察的对象。在目标中定义了一个观察者集合，一个观察目标可以接受任意数量的观察者来观察，它提供一系列方法来增加和删除观察者对象，同时它定义了通知方法snedNotify()。目标类可以是接口，也可以是抽象类或具体类。 
● ConcreteSubject（具体目标）：具体目标是目标类的子类，通常它包含有经常发生改变的数据，当它的状态发生改变时，向它的各个观察者发出通知；同时它还实现了在目标类中定义的抽象业务逻辑方法（如果有的话）。如果无须扩展目标类，则具体目标类可以省略。 
● Observer（观察者）：观察者将对观察目标的改变做出反应，观察者一般定义为接口，该接口声明了更新数据的方法update()，因此又称为抽象观察者。 
● ConcreteObserver（具体观察者）：在具体观察者中维护一个指向具体目标对象的引用，它存储具体观察者的有关状态，这些状态需要和具体目标的状态保持一致；它实现了在抽象观察者Observer中定义的update()方法。通常在实现时，可以调用具体目标类的attach()方法将自己添加到目标类的集合中或通过detach()方法将自己从目标类的集合中删除。

 具体代码演示：

工程结构如下：

创建发布消息的实体类：

package com.sunyard.bean;

/**
 * <p>发布招聘信息类</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class Job {
    private String title;//招聘标题
    
    public Job(String title) {
        this.title = title;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }
}    

创建抽象观察者：

package com.sunyard.observer;

import com.sunyard.subject.Subject;

/**
 * <p>抽象观察者类</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public interface Observer {
    //声明响应方法，当某个状态触发时，调用该方法进行相应的操作
    public void update(Subject subject);
}

具体观察者：

package com.sunyard.observer;

import com.sunyard.subject.HR;
import com.sunyard.subject.HeadHunter;
import com.sunyard.subject.Subject;

/**
 * <p>具体观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class JobSeeker implements Observer{
    private String name;
    
    public JobSeeker(String name){
        this.name = name;
    }
    
    @Override
    public void update(Subject subject) {
        if(subject instanceof HeadHunter){
            System.out.println("求职者的名字是:" + name);
            System.out.println("HeadHunter更新了职位信息");
            System.out.println(((HeadHunter) subject).getName());
            System.out.println("职位信息如下:");
            System.out.println(((HeadHunter) subject).getLastJob().getTitle());
        } else if(subject instanceof HR){
            System.out.println("求职者的名字是:" + name);
            System.out.println("HeadHunter更新了职位信息");
            System.out.println(((HR) subject).getName());
            System.out.println("职位信息如下:");
            System.out.println(((HR) subject).getLastJob().getTitle());
        }
    }
    
}

package com.sunyard.observer;

import com.sunyard.subject.HR;
import com.sunyard.subject.HeadHunter;
import com.sunyard.subject.Subject;

/**
 * <p>具体观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class DBManager implements Observer{
    private String name;

    public DBManager(String name) {
        this.name = name;
    }
    
    @Override
    public void update(Subject subject) {
        if(subject instanceof HeadHunter){
            System.out.println("求职者的名字是:" + name);
            System.out.println("HeadHunter更新了职位信息");
            System.out.println(((HeadHunter) subject).getName());
            System.out.println("职位信息如下:");
            System.out.println(((HeadHunter) subject).getLastJob().getTitle());
        } else if(subject instanceof HR){
            System.out.println("求职者的名字是:" + name);
            System.out.println("HeadHunter更新了职位信息");
            System.out.println(((HR) subject).getName());
            System.out.println("职位信息如下:");
            System.out.println(((HR) subject).getLastJob().getTitle());
        }
    }
}

创建抽奖被观察者：

package com.sunyard.subject;

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

import com.sunyard.observer.Observer;

/**
 * <p>抽象被观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public abstract class Subject {
    //定义一个观察者集合用于存储所有的观察者对象
    protected List<Observer> observers = new ArrayList<Observer>();
    
    //注册方法，用于向观察者集合中增加一个观察者
    public void attach(Observer observer){
        observers.add(observer);
    }
    
    //注销方法，用于在观察者集合中删除一个观察者
    public void detach(Observer observer) {
        observers.remove(observer);
    }
    
    //声明抽象通知方法
    public abstract void sendNotify(Subject subject);
}

创建具体被观察者：

package com.sunyard.subject;

import com.sunyard.bean.Job;
import com.sunyard.observer.Observer;
/**
 * <p>具体被观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class HeadHunter extends Subject{
    private String name;
    
    private Job myJobLast;//最新发布的招聘信息
    
    public HeadHunter(String name){
        this.name = name;
    }
    
    // 发布招聘，发布时发送通知
    public void publishJob(Job job) {
        myJobLast = job;
        sendNotify(this);
    }

    public String getName() {
        return name;
    }

    public Job getLastJob() {
        return myJobLast;
    }
    
    @Override
    public void sendNotify(Subject subject) {
        //遍历观察者集合，调用每一个观察者的响应方法
        for(Observer observer : observers){
            observer.update(subject);
        }
    }
    
}

package com.sunyard.subject;

import com.sunyard.bean.Job;
import com.sunyard.observer.Observer;

/**
 * <p>具体被观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class HR extends Subject{
    private String name;
    
    private Job myJobLast;//最新发布的招聘
    
    public HR(String name){
        this.name = name;
    }
    
    // 发布招聘，发布时发送通知
    public void publishJob(Job job) {
        myJobLast = job;
        sendNotify(this);
    }

    public Job getLastJob() {
        return myJobLast;
    }
    
    public String getName() {
        return name;
    }

    @Override
    public void sendNotify(Subject subject) {
        //遍历观察者集合，调用每一个观察者的响应方法
        for (Observer observer : observers) {
            observer.update(subject);
        }
    }
    
}

观察者测试类：

package com.sunyard.test;

import com.sunyard.bean.Job;
import com.sunyard.observer.DBManager;
import com.sunyard.observer.JobSeeker;
import com.sunyard.subject.HR;
import com.sunyard.subject.HeadHunter;

/**
 * <p>测试观察者</p>
 * @author:774346810@qq.com
 * @date:2017-6-25
 */
public class ObserverPattern {
    public static void main(String[] args) {
        HeadHunter headHunter = new HeadHunter("猎头");
        
        HR hr = new HR("人事");
        
        JobSeeker jobSeeker1 = new JobSeeker("求职者1");
        JobSeeker jobSeeker2 = new JobSeeker("求职者2");
        JobSeeker jobSeeker3 = new JobSeeker("求职者3");
        
        DBManager dbManager = new DBManager("管理员");
        
        //完成订阅注册添加
        headHunter.attach(jobSeeker1);
        headHunter.attach(jobSeeker2);
        headHunter.attach(jobSeeker3);
        headHunter.attach(dbManager);
        
        //猎头发布招聘，将会依次给观察者发通知
        headHunter.publishJob(new Job("工作信息1"));
        
        //移除某个观察者
        headHunter.detach(jobSeeker2);
        
        //再次发布招聘，测试移除订阅
        headHunter.publishJob(new Job("工作信息2"));
        
        hr.attach(jobSeeker2);
        hr.attach(dbManager);
        
        hr.publishJob(new Job("工作信息3"));
    }
}

输入结果：

求职者的名字是:求职者1
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息1
求职者的名字是:求职者2
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息1
求职者的名字是:求职者3
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息1
求职者的名字是:管理员
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息1
求职者的名字是:求职者1
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息2
求职者的名字是:求职者3
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息2
求职者的名字是:管理员
HeadHunter更新了职位信息
猎头
职位信息如下:
工作信息2
求职者的名字是:求职者2
HeadHunter更新了职位信息
人事
职位信息如下:
工作信息3
求职者的名字是:管理员
HeadHunter更新了职位信息
人事
职位信息如下:
工作信息3