定义了对象之间的一对多的依赖，这样一来，当一个对象改变时，它的所有的依赖者都会收到通知并自动更新。

被观察者要继承： Observable类  实现消息推送  、setChanged  notifyObservers();

观察者要继承： Observer类  实现updata(); 注册 

 

package 观察者模式;import java.util.Observable;import java.util.Observer;/** *  * @author 红尘Dream * 观察者模式： 一对多的模式  * 当被观察者发生变化时， 观察者会受到通知自动更新 * 服务被观察者 ： 推送消息 通知观察者 * 观察者： 订阅主题    自动更新消息 */public class Test{    public static void main(String[] args)    {        Service s = new Service(); //创建被观察者 服务者        Observerl o = new Observerl(); //创建观察者        Observerl o1 = new Observerl(); //创建观察者        Observerl o2 = new Observerl(); //创建观察者        Observerl o3 = new Observerl(); //创建观察者        Observerl o4 = new Observerl(); //创建观察者                o.registerService(s);//订阅服务        o1.registerService(s);        o2.registerService(s);        o3.registerService(s);        o4.registerService(s);        //取消订阅        o1.unRegisterService(s);        s.setMsg("今天新闻热点");                            }}/** * 服务类  被观察者  用于推送消息 */class Service extends Observable{    private String msg;        public String getMsg()    {        return msg+"(来自服务者（被观察者）)";    }        /**     *      * 推送消息     */    public void setMsg(String msg)    {        this.msg = msg;        setChanged();//设置改变        notifyObservers();// 通知观察者    }        } /** *  被观察者 类 */class Observerl implements Observer{        /**     * 订阅 服务     *      */    public void registerService(Observable observable)    {        observable.addObserver(this);    }        /**     * 取消订阅     */    public void unRegisterService(Observable observable)    {        observable.deleteObserver(this);    }    /**     *  实现观察者的更新方法     */    @Override    public void update(Observable arg0, Object arg1)    {        if(arg0 instanceof Service)        {            Service s = (Service) arg0;            System.out.println("观察者更新："+s.getMsg());        }    }    }

执行结果：

观察者更新：今天新闻热点(来自服务者（被观察者）)观察者更新：今天新闻热点(来自服务者（被观察者）)观察者更新：今天新闻热点(来自服务者（被观察者）)观察者更新：今天新闻热点(来自服务者（被观察者）)