设计模式——观察者模式

在日常生活中，观察者模式与我们息息相关，就比如爱打游戏的我在操控虚拟角色时，这个角色有hp和mp，在游戏中会有一些对应的面板来展示hp和mp，这个时候其实就是利用了观察者模式，具体是怎么实现的呢？请往下看。
就拿我最先接触到的游戏的传奇来说，一般的，在游戏中，展示人物hp和mp有多个地方

image.png

假设游戏角色被怪物只因打了一下，此时三个地方需要发生变化，角色上方血条，圆盘血条，和数字血条。那我们如何设计呢？
不考虑其他因素，最简单的设计就是当人物掉血时，改变三个地方，代码如下：、

class Role {
    private String name;
    private Integer hp;
    private Integer mp;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getHp() {
        return hp;
    }

    public void setHp(Integer hp) {
        this.hp = hp;
        // 改变人物血量hp
        System.out.println("血条更新hp为："+hp);
        System.out.println("球型更新hp为："+hp);
        System.out.println("面板更新hp为："+hp);
    }

    public Integer getMp() {
        return mp;
    }

    public void setMp(Integer mp) {
        this.mp = mp;
    }
}

class Monster {
    public void attact(Role r){
        r.setHp(r.getHp()-10);
    }
}

public class Test {
    public static void main(String[] args) {
        Role role = new Role();
        role.setName("qiansion");
        role.setHp(100);
        role.setMp(100);
        Monster monster = new Monster();
        monster.attact(role);
    }
}

输出如下：
血条更新hp为：100
球型更新hp为：100
面板更新hp为：100
血条更新hp为：90
球型更新hp为：90
面板更新hp为：90
看似没有什么问题，但是现在变化来了。产品经理需要再添加一个显示血量的地方
那么就需要在以前的代码中，继续新添加代码，这样不好

不符合开闭原则
就是上面代码本身耦合性就太高

image.png

鉴于以上问题，我们需要重新设计一下整个模型，在之前的代码中，面板，球型，血条显示都是在人物的类中，现在可以将他们抽取出来。等人物hp发生了变化，然后通知各个组件改变相应的数据。而两个类之间传递数据只有两种模式就是 pull 和 push，在本例中，明显push更为方便（因为pull需要各个组件不停的询问人物血条是否变化，内耗过大且实时性较差），当人物血条发生变化，人物主动的push数据到其他组件。而其他组件就等着人物来push，所以我们可以称这些组件为“观察者”

现在，我们可以着手重新设计Role类了，首先思考Role血量发生变化，他需要通知到各个观察者们，那么Role类就必须知道观察者都有哪些，所以需要一个集合去存放这些观察者们，相应的，也需要一些操作观察者的方法，当然最重要的还是通知方法。

观察者们除了关注人物血条的变化，还得接受数据(人物当前血量)，面板，球型，血条都需要接收这个数据，所以可以抽出一个接受数据的接口，让三个组件去实现。

综上，代码如下

class Role {
    private String name;
    private Integer hp;
    private Integer mp;
    private List<Observer> observers = new ArrayList<Observer>();

    public void addObserver(Observer obj){
        observers.add(obj);
    }

    public void removeObserver(Object obj){
        observers.remove(obj);
    }

    public void notifyObservers(){
        for (Observer observer : observers) {
            observer.update(hp);
        }
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getHp() {
        return hp;
    }

    public void setHp(Integer hp) {
        this.hp = hp;
        notifyObservers();
    }

    public Integer getMp() {
        return mp;
    }

    public void setMp(Integer mp) {
        this.mp = mp;
    }
}

interface Observer{
    // 需要一个方法，来接受主体发来的新数据
    void update(int hp);
}

class Panel implements Observer{

    @Override
    public void update(int hp) {
        System.out.println("面板血条更改为："+ hp);
    }
}

class BallPanel implements Observer{

    @Override
    public void update(int hp) {
        System.out.println("球形血条更改为："+ hp);
    }
}

class HeadPanel implements Observer{

    @Override
    public void update(int hp) {
        System.out.println("头部血条更改为："+ hp);
    }
}

class Monster {
    public void attact(Role r){
        r.setHp(r.getHp()-10);
    }
}

public class Test {
    public static void main(String[] args) {
        Role role = new Role();
        role.setName("qiansion");
        role.setHp(100);
        role.setMp(100);
        Panel panel = new Panel();
        BallPanel ballPanel = new BallPanel();
        HeadPanel headPanel = new HeadPanel();
        role.addObserver(panel);
        role.addObserver(ballPanel);
        role.addObserver(headPanel);
        Monster monster = new Monster();
        monster.attact(role);
    }
}

输出如下：
面板血条更改为：90
球形血条更改为：90
头部血条更改为：90
跟之前的代码相比，明显耦合度降低了，符合了单一职责。产品经理如果需要新添加一个展示血条的地方，那么可以新建一个类实现Observer接口，并将该类添加到role的观察者列表中。
现在仍然存在一个缺点：
目前主体Role只会把自己的hp广播给所有的观察者，那么如果想也把mp一起广播呢？势必要违反开闭原则！！而且游戏业务经常变化，导致Role类的属性越来越多，难道每次多一个属性，都要修改Observer的update 方法吗？

显然，上面的方法过于简漏，在Observer的update方法里直接把Role对象传进去即可解决，组件想展示什么就能够展示什么

class Role {
    private String name;
    private Integer hp;
    private Integer mp;
    private List<Observer> observers = new ArrayList<Observer>();

    public void addObserver(Observer obj){
        observers.add(obj);
    }

    public void removeObserver(Object obj){
        observers.remove(obj);
    }

    public void notifyObservers(){
        for (Observer observer : observers) {
            observer.update(this);
        }
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getHp() {
        return hp;
    }

    public void setHp(Integer hp) {
        this.hp = hp;
        notifyObservers();
    }

    public Integer getMp() {
        return mp;
    }

    public void setMp(Integer mp) {
        this.mp = mp;
    }

    @Override
    public String toString() {
        return "Role{" +
                "name='" + name + '\'' +
                ", hp=" + hp +
                ", mp=" + mp +
                '}';
    }
}

interface Observer{
    // 需要一个方法，来接受主体发来的新数据
    void update(Role r);
}

class Panel implements Observer{

    @Override
    public void update(Role r) {
        System.out.println("面板血条更改为："+ r);
    }
}

class BallPanel implements Observer{

    @Override
    public void update(Role r) {
        System.out.println("球形血条更改为："+ r);
    }
}

class HeadPanel implements Observer{

    @Override
    public void update(Role r) {
        System.out.println("头部血条更改为："+ r);
    }
}

class Monster {
    public void attact(Role r){
        r.setHp(r.getHp()-10);
    }
}

public class Test {
    public static void main(String[] args) {
        Role role = new Role();
        role.setName("qiansion");
        role.setHp(100);
        role.setMp(100);
        Panel panel = new Panel();
        BallPanel ballPanel = new BallPanel();
        HeadPanel headPanel = new HeadPanel();
        role.addObserver(panel);
        role.addObserver(ballPanel);
        role.addObserver(headPanel);
        Monster monster = new Monster();
        monster.attact(role);
    }
}

输出如下：
面板血条更改为：Role{name='qiansion', hp=90, mp=100}
球形血条更改为：Role{name='qiansion', hp=90, mp=100}
头部血条更改为：Role{name='qiansion', hp=90, mp=100}
目前每当主体Role的状态发生变化，就算主体有很多个属性，也不会影响代码
修改之后也带来一些问题，作为一个接口，Observer接口中的update方法，居然出现了具体类名！如此，Observer就只能观察Role这个类了，观察不了别的类的对象了，不容易拓展。

继续修改

class Role {
    private String name;
    private Integer hp;
    private Integer mp;
    private List<Observer> observers = new ArrayList<Observer>();

    public void addObserver(Observer obj){
        observers.add(obj);
    }

    public void removeObserver(Object obj){
        observers.remove(obj);
    }

    public void notifyObservers(){
        for (Observer observer : observers) {
            observer.update();
        }
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getHp() {
        return hp;
    }

    public void setHp(Integer hp) {
        this.hp = hp;
        notifyObservers();
    }

    public Integer getMp() {
        return mp;
    }

    public void setMp(Integer mp) {
        this.mp = mp;
    }

    @Override
    public String toString() {
        return "Role{" +
                "name='" + name + '\'' +
                ", hp=" + hp +
                ", mp=" + mp +
                '}';
    }
}

interface Observer{
    // 需要一个方法，来接受主体发来的新数据
    void update();
}

class Panel implements Observer{
    private Role r;
    public Panel(Role r){
        this.r = r;
    }
    @Override
    public void update() {
        System.out.println("面板血条更改为："+ r);
    }
}

class BallPanel implements Observer{
    private Role r;
    public BallPanel(Role r){
        this.r = r;
    }
    @Override
    public void update() {
        System.out.println("球形血条更改为："+ r);
    }
}

class HeadPanel implements Observer{
    private Role r;
    public HeadPanel(Role r){
        this.r = r;
    }
    @Override
    public void update() {
        System.out.println("头部血条更改为："+ r);
    }
}

class Monster {
    public void attact(Role r){
        r.setHp(r.getHp()-10);
    }
}

public class Test {
    public static void main(String[] args) {
        Role role = new Role();
        role.setName("qiansion");
        role.setHp(100);
        role.setMp(100);
        Panel panel = new Panel(role);
        BallPanel ballPanel = new BallPanel(role);
        HeadPanel headPanel = new HeadPanel(role);
        role.addObserver(panel);
        role.addObserver(ballPanel);
        role.addObserver(headPanel);
        Monster monster = new Monster();
        monster.attact(role);
    }
}

输出如下：
面板血条更改为：Role{name='qiansion', hp=90, mp=100}
球形血条更改为：Role{name='qiansion', hp=90, mp=100}
头部血条更改为：Role{name='qiansion', hp=90, mp=100}
修改后，主体不再主动推送数据，从push的方式修改为 push + pull的方式，主体只是通知观察者“我变了”，观察者收到消息，就自己去看主体哪儿变了，巧妙之处就在于此，因为这种推+拉的模式，主体中有观察者，观察者中有主体。再以上代码中还可以做一些抽象，Role类中的addObserver和removeObserver等都可以抽象为接口，这就是最完整的观察者模式

interface Subject {
    void addObserver(Observer observer);
    void removeObserver(Observer observer);
    void notifyObservers();
}

class Role implements Subject{
    private String name;
    private Integer hp;
    private Integer mp;
    private List<Observer> observers = new ArrayList<Observer>();

    @Override
    public void addObserver(Observer observer){
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer){
        observers.remove(observer);
    }

    @Override
    public void notifyObservers(){
        for (Observer observer : observers) {
            observer.update();
        }
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getHp() {
        return hp;
    }

    public void setHp(Integer hp) {
        this.hp = hp;
        notifyObservers();
    }

    public Integer getMp() {
        return mp;
    }

    public void setMp(Integer mp) {
        this.mp = mp;
    }

    @Override
    public String toString() {
        return "Role{" +
                "name='" + name + '\'' +
                ", hp=" + hp +
                ", mp=" + mp +
                '}';
    }
}

interface Observer{
    // 需要一个方法，来接受主体发来的新数据
    void update();
}

class Panel implements Observer{
    private Role r;
    public Panel(Role r){
        this.r = r;
        r.addObserver(this);
    }
    @Override
    public void update() {
        System.out.println("面板血条更改为："+ r);
    }
}

class BallPanel implements Observer{
    private Role r;
    public BallPanel(Role r){
        this.r = r;
        r.addObserver(this);
    }
    @Override
    public void update() {
        System.out.println("球形血条更改为："+ r);
    }
}

class HeadPanel implements Observer{
    private Role r;
    public HeadPanel(Role r){
        this.r = r;
        r.addObserver(this);
    }
    @Override
    public void update() {
        System.out.println("头部血条更改为："+ r);
    }
}

class Monster {
    public void attact(Role r){
        r.setHp(r.getHp()-10);
    }
}

public class Test {
    public static void main(String[] args) {
        Role role = new Role();
        role.setName("qiansion");
        role.setHp(100);
        role.setMp(100);
        Panel panel = new Panel(role);
        BallPanel ballPanel = new BallPanel(role);
        HeadPanel headPanel = new HeadPanel(role);
        Monster monster = new Monster();
        monster.attact(role);
    }
}

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 200,527评论 5赞 470
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 84,314评论 2赞 377
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 147,535评论 0赞 332
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,006评论 1赞 272
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 62,961评论 5赞 360
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,220评论 1赞 277
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,664评论 3赞 392
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,351评论 0赞 254
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,481评论 1赞 294
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,397评论 2赞 317
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,443评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,123评论 3赞 315
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,713评论 3赞 303
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,801评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,010评论 1赞 255
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,494评论 2赞 346
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,075评论 2赞 341

设计模式——观察者模式

推荐阅读更多精彩内容