import java.util.ArrayList;
import java.util.List;/*** 功能:*         目标对象,作为被观察者,它知道观察它的观察者,并提供注册和删除观察者的接口* @author Administrator**/
public class Subject
{//用来保存注册的观察者对象,也就是报纸的订阅者private List<Observer> readers = new ArrayList<Observer>();/*** 功能:*         注册观察者对象（报纸的读者需要向报社订阅,先要注册）* @param observer 观察者对象*/public void attach(Observer reader){readers.add(reader);}/*** 功能:*         删除观察者对象（报纸的读者可以取消订阅）* @param observer*/public void detach(Observer reader){readers.remove(reader);}/*** 功能:*         通知所有的观察者*         （当有报纸出版后，就要主动的送到读者手中，相当于通知读者）*/protected void notifyAllObservers(){for(Observer reader : readers){reader.update(this);}}
}

/*** 功能:*         具体的目标对象,负责把有关状态存入到相应的观察者对象*         并在自己状态发生改变时,通知各个观察者*         （报纸对象）* @author Administrator**/
public class NewPaper extends Subject
{//报纸的具体内容private String content;/*** 功能:*         获取报纸的具体内容* @return*/public String getContent(){return content;}/*** 功能:*         设置报纸的具体内容，相当于出版报纸* @param content*/public void setContent(String content){this.content = content;//通知所有注册的读者this.notifyAllObservers();}
}

/*** 功能:*         观察者接口,定义一个更新的接口给那些在目标发生改变的时候被通知的对象*         （报纸的读者）* @author Administrator**/
public interface Observer
{/*** 功能:*         更新的接口* @param subject 传入目标对象,方便获取相应的目标对象的状态*/public void update(Subject subject);
}

/*** 功能:*         具体的观察者对象,实现更新的方法,使自身的状态和目标的状态保存一致*         （真正的读者）* @author Administrator**/
public class Reader implements Observer
{//读者的姓名private String name;@Overridepublic void update(Subject subject){//这里采用拉的方式System.out.println(name + "收到报纸，内容为: "+ ((NewPaper)subject).getContent());}public String getName(){return name;}public void setName(String name){this.name = name;}
}

public class Client
{public static void main(String[] args){//创建一个报纸，作为被观察者NewPaper subject = new NewPaper();//创建阅读者,也就是观察者Reader reader1 = new Reader();reader1.setName("罗纳尔多");Reader reader2 = new Reader();reader2.setName("贝克汉姆");//注册观察者
        subject.attach(reader1);subject.attach(reader2);subject.setContent("世界杯要开始了哦.....");}
}

import java.util.ArrayList;
import java.util.List;/*** 功能:*         目标对象，作为被观察者，使用推模型* @author Administrator**/
public class Subject
{    //用来保存注册的观察者对象（报纸订阅者）private List<Observer> readers = new ArrayList<Observer>();/*** 功能:*         注册观察者对象（报纸的读者需要向报社订阅,先要注册）* @param observer 观察者对象*/public void attach(Observer reader){readers.add(reader);}/*** 功能:*         删除观察者对象（报纸的读者可以取消订阅）* @param observer*/public void detach(Observer reader){readers.remove(reader);}/*** 功能:*         通知所有的观察者*         （当有报纸出版后，就要主动的送到读者手中，相当于通知读者）*/protected void notifyAllObservers(String content){for(Observer reader : readers){reader.update(content);}}
}

public class NewsPaper extends Subject
{private String content;public String getContent(){return content;}public void setContent(String content){this.content = content;//通知所有注册的观察者(读者)this.notifyAllObservers(content);}
}

/*** 功能:*         观察者（报纸的读者）* @author Administrator**/
public interface Observer
{/*** 功能:*         被通知的方法,直接把报纸的内容推送过来* @param content*/public void update(String content);
}

public class Reader implements Observer
{//读者的姓名private String name;@Overridepublic void update(String content){//这里采用推的方式System.out.println(name + "收到报纸了，内容是:" + content);}public String getName(){return name;}public void setName(String name){this.name = name;}
}

public class Client
{public static void main(String[] args){//创建一个报纸，作为被观察者NewsPaper subject = new NewsPaper();//创建阅读者,也就是观察者Reader reader1 = new Reader();reader1.setName("罗纳尔多");Reader reader2 = new Reader();reader2.setName("贝克汉姆");//注册观察者
        subject.attach(reader1);subject.attach(reader2);subject.setContent("世界杯要开始了哦.....");}
}

两种模型的比较：（1）推模型是假定目标对象知道观察者需要的数据；而拉模型是目标对象不知道观察者具体
需要什么数据，没有办法的情况下，把自身传给观察者，让观察者自己去按需取值。
（2）推模型可能会使得观察者对象难以复用，因为观察者定义的update方法是按需而定义的，
可能无法兼顾没有考虑到的使用情况。这就意味着出现新情况的时候，就可能需要提供新的update方法，
或者干脆重新实现观察者。java中的观察者在java.util包里面有一个类Observable,实现了大部分目标的功能。
java.util包里面有一个类Observer，其中定义了update的方法，就是观察者的接口

import java.util.Observable;public class NewsPaper extends Observable
{//报纸的具体内容private String content;/*** 功能:*         获取报纸的具体内容* @return*/public String getContent(){return content;}/*** 功能:*         设置报纸的具体内容,相当于出版报纸* @param content*/public void setContent(String content){this.content = content;//通知观察者this.setChanged();this.notifyObservers(this.content);//采用推的方法
        }
}

import java.util.Observable;
import java.util.Observer;/*** 功能:*         观察者（读者）* @author Administrator**/
public class Reader implements Observer
{private String name;public String getName(){return name;}public void setName(String name){this.name = name;}@Overridepublic void update(Observable arg0, Object obj){System.out.println(name + "收到报纸了，内容为:"+obj);}
}

public class Client
{public static void main(String[] args){//创建一个报纸，作为被观察者NewsPaper subject = new NewsPaper();//创建阅读者，也就是观察者Reader reader1 = new Reader();reader1.setName("罗纳尔多");Reader reader2 = new Reader();reader2.setName("贝克汉姆");//注册阅读者
        subject.addObserver(reader1);subject.addObserver(reader2);//出版报纸subject.setContent("世界杯要开始了咯");}
}