文档章节

设计模式之观察者模式

Lubby
 Lubby
发布于 2015/12/21 13:05
字数 649
阅读 70
收藏 2

观察者模式又称为发布订阅模式,里面角色分为观察者,被观察者。被观察者的动作会通知给注册的观察者。

现在设计一个故事,监狱里面有犯人和警察,警察会监控犯人的一举一动。当犯人吃饭的时候,警察会收到通知。

一、简单的观察者实现:

Observable:

public abstract class Observable {
    private Vector<Observer> obs = new Vector<>();

    public void notifyObs(Object param) {
        for (Observer ob : obs) {
            ob.update(param);
        }
    }

    public void addObserver(Observer ob) {
        this.obs.add(ob);
    }

    public void removeObserver(Observer ob) {
        this.obs.remove(ob);
    }

    public int getObserverSize() {
        return this.obs.size();
    }

    public boolean containObserver(Observer ob) {
        return this.obs.contains(ob);
    }
}

Observer:

public interface Observer  {
    void update(Object param);
}

Criminal:

public class Criminal extends Observable {
    public void eat(String food) {
        System.out.println("criminal is eating " + food);
        this.notifyObs(food);
    }
}

Police A:

public class PoliceA implements Observer {
    @Override
    public void update(Object param) {
        System.out.println("police A get message. param is "  + param);
    }
}

Police B:

public class PoliceB implements Observer {
    @Override
    public void update(Object param) {
        System.out.println("police A get message. param is "  + param);
    }
}

Test:

public class Test {
    public static void main(String[] args) {
        Criminal criminal = new Criminal();
        criminal.addObserver(new PoliceA());
        criminal.addObserver(new PoliceB());
        criminal.eat("西餐");
    }
}

上面的代码非常简单,很容易看懂。Observable是对观察者的抽象,里面有个Vectory,放入的是观察者。当有观察者注册的时候就放入到Vectory里面。Crimimal继承了Observable,当犯人吃饭的时候就依次通知Vectory里面的观察者。

JDK里面本身就存在Observable和Observer两个类,方便我们直接使用观察者模式。

二、使用JDK里面观察者的实现

Criminal:

public class Criminal extends Observable {

    public void eat(String food) {
        System.out.println("criminal eat " + food);
        super.setChanged();
        notifyObservers("criminal is eating " + food);
    }
}

Police A:

public class PoliceA implements Observer{
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("Police A watch : " + arg);
    }
}

Police B:

public class PoliceB implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("Police B watch . " + arg);
        System.out.println(o);
    }
}

Test:

public class Test {
    public static void main(String[] args) {
        Criminal criminal = new Criminal();
        criminal.addObserver(new PoliceA());
        criminal.addObserver(new PoliceB());
        criminal.eat("川菜");
    }
}


二、观察者模式的缺点

  1. 当某些观察者执行时间过长,会导致后面的观察者过长的延迟.  

    解决办法:使用异步处理,无论是在观察者端通知的步骤使用异步还是被观察者收到通知然后执行的步骤使用异步,都可以.

  2. 观察者同时也可以是被观察者。广播链太长,可维护性很差。


© 著作权归作者所有

共有 人打赏支持
Lubby
粉丝 54
博文 93
码字总数 49533
作品 0
杭州
程序员
私信 提问

暂无文章

python实现下载网络图片

项目需求: 有时候我们做爬虫的时候,需要把爬取到的图片资源保存到我们本地,以防爬取的图片链接被原来资源主人变更,所以就需要把好不容易拿到的资源永久变为自己的,就需要把图片链接下载到我们...

银装素裹
31分钟前
1
0
米利型和摩尔型状态机

1. 经典状态机 x(t)为当前输入 z(t)为当前输出 组合逻辑电路输出s(t+1)为次态 状态寄存器(也就是一组触发器)输出s(t)为现态 2. 米利状态机(Mealy) 组合逻辑C1模块有两个输入端:当前输入x(t...

易冥天
33分钟前
4
0
Kafka是如何解决常见的微服务通信问题的

微服务自成立以来就以不同的方式相互沟通。有些人更喜欢使用HTTP REST API,但这些API有自己的排队问题,而有些则更喜欢较旧的消息队列,比如RabbitMQ,它们带有扩展和操作方面的问题。 以K...

java菜分享
37分钟前
1
0
关于php的xdebug配置(编辑器vscode)

虽然说echo和print_r是公认的最实用的调试工具,但是效率真的没有可视化的直接断点那么高。这里简单介绍如果安装及配置xdebug for vscode 一、PHP环境处的配置 1、编译安装 下载及编译php,因...

元谷
51分钟前
7
0
heartbeat

http://www.linux-ha.org/doc/users-guide/_building_and_installing_heartbeat_from_source.html kaer@linux-sqlf:~/Reusable-Cluster-Components-glue--0a7add1d9996> ./configure --enabl......

李有常
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部