本文来看下java设计模式之观察者模式。

观察者模式,顾名思义,一个被观察的人状态改变了,观察他的人也都知道了。不难理解。咱们举一个比较好的例子吧。以前一直说游戏什么的,咱们这次来看下文章。
现在的博客都是可以订阅的,而且我们使用了使用了一些工具后,他们更新了是可以随时通知到我们的。为了方便描述,我就直接说是博客更新了就通知到我们吧。
你看,我们的RSS订阅源

public interface RSS {

    public void addDevice(Device device);
    public void delDevice(Device device);
    public void notifyDevice(String message);

}

我们的博客

public class Blog implements RSS {

    private List<Device> deviceList=new ArrayList<>();

    public Blog() {
    }

    @Override
    public void addDevice(Device device) {
        this.deviceList.add(device);
    }

    @Override
    public void delDevice(Device device) {
        this.deviceList.remove(device);
    }

    @Override
    public void notifyDevice(String message) {
        for (Device device:deviceList){
            device.update(message);
        }
    }


    public void updateArticle(){
        System.out.println("I write a new article");
        this.notifyDevice("new article");
    }

}

看看我们谁在观察这些博客文章吧。都有各种设备

public interface Device {
    public void update(String message);
}

我有个kindle,订阅了这些信息

public class Kindle implements Device {
    @Override
    public void update(String message) {
        System.out.println("the blog update");
        System.out.println("content is: "+message);
    }
}

好啦,我们来看下

public class Web {
    public static void main(String[] args) {
        Blog blog=new Blog();
        Device kindle=new Kindle();
        blog.addDevice(kindle);
        blog.updateArticle();
    }
}

不复杂吧!
你看,在我们这个订阅管理里面,我们有自己的RSS订阅源就相当于被观察者,然后我们的设备就相当于观察者,被观察者如果有了新的内容,就通知到观察者。很简单的一个流程。
而且,更好的消息是,java帮我们把RSS还有Device做好了。我们就直接继承就好啦。

public class OBlog extends Observable {
    public void updateArticle(){
        System.out.println("I write a new article");
        this.setChanged();
        this.notifyObservers("new article");
    }
}

我们就只需要写自己的业务就好啦。除此之外呢,注意我们在使用notifyObservers()之前要setChanged()来通知有内容更新。

public class OKindle implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("the blog update");
        System.out.println("content is: "+arg.toString());
    }
}

调用过程也很简单

        OKindle oKindle=new OKindle();
        OBlog oBlog=new OBlog();
        oBlog.addObserver(oKindle);
        oBlog.updateArticle();

..................分割线.................
似乎没有太复杂的,就没有什么需要解释的了.

java 设计模式

发表新评论