【设计模式专题】观察者模式实战详细分析

简介: 【设计模式专题】观察者模式实战详细分析

正文


一 什么是观察者模式


定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知,并自动更新。


新手经常会把观察者模式经常与发布订阅模式,其实二者还是有一些区别的,


二 观察者模式与发布订阅模式的区别


  • 观察者模式主要的使用场景是一对多的状态,且需要知道通知的对象是谁。
  • 发布订阅模式的主要使用场景是一对多或者多对多的状态,且不需要知道通知的对象也就是消费者是谁。
  • 观察者模式属于Gang of Four 提出的23中设计模式中的一种,发布订阅模式并不属于其中的一种而是一种软件设计理念。
  • 观察者模式耦合度较高,因为观察者模式中目标的只有一个,观察者需要知道目标的所有行为。
  • 发布订阅的耦合度较低,而发布订阅的发布者可以有多个,订阅者不需要知道发布者是谁,只需要关心发布的内容。


三 编写demo案例


比如今天是周一,Leader需要公司里的员工加班,员工分别有Jack、Mark,然而每个人对加不加班是有自己的看法和行为的,这时就可以把Leader作为目标/主题,Jack、Mark做为观察者,观察者需要根据目标的指令来做出对应的行为。


一般观察者模式有4个角色,分别为:抽象目标类、具体目标类、抽象观察类、具体观察类。


代码实现如下:


抽象目标类 :MySubject

一 什么是观察者模式
定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知,并自动更新。
新手经常会把观察者模式经常与发布订阅模式,其实二者还是有一些区别的,
二 观察者模式与发布订阅模式的区别
观察者模式主要的使用场景是一对多的状态,且需要知道通知的对象是谁。
发布订阅模式的主要使用场景是一对多或者多对多的状态,且不需要知道通知的对象也就是消费者是谁。
观察者模式属于Gang of Four 提出的23中设计模式中的一种,发布订阅模式并不属于其中的一种而是一种软件设计理念。
观察者模式耦合度较高,因为观察者模式中目标的只有一个,观察者需要知道目标的所有行为。
发布订阅的耦合度较低,而发布订阅的发布者可以有多个,订阅者不需要知道发布者是谁,只需要关心发布的内容。
三 编写demo案例
比如今天是周一,Leader需要公司里的员工加班,员工分别有Jack、Mark,然而每个人对加不加班是有自己的看法和行为的,这时就可以把Leader作为目标/主题,Jack、Mark做为观察者,观察者需要根据目标的指令来做出对应的行为。
一般观察者模式有4个角色,分别为:抽象目标类、具体目标类、抽象观察类、具体观察类。
代码实现如下:
抽象目标类 :MySubject
————————————————
版权声明:本文为CSDN博主「掂掂三生有幸」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/weixin_42469135/article/details/12641330

具体目标类 :Leader

/**
 * @author liuy 抽象观察者类
 * @create 2022-08-18-13:05
 */
public interface MyObserver {
    void response(int state); //抽象响应方法
}

具体观察者类一:Jack

/**
 * @author liuy 具体观察者类
 * @create 2022-08-18-13:05
 */
public class Jack implements MyObserver {
    @Override
    public void response(int state) {
        String name = "Jack:";
        if(state ==1){
            System.out.println(name + "需要加班,开摆!");
        }else {
            System.out.println(name + "哈哈哈,不加班就可以回家打游戏了");
        }
    }
}

具体观察者类二:Mark

/**
 * @author liuy 具体观察者类
 * @create 2022-08-18-13:05
 */
public class Mark implements MyObserver {
    @Override
    public void response(int state) {
        String name = "Mark:";
        if(state ==1){
        System.out.println(name + "我爱加班,因为有加班费");
        }else {
            System.out.println(name + "呜呜呜,没加班费拿了");
        }
    }
}

现在基本的观察者模式已经实现了,现在开始测试。

/**
 * @author liuy 客户端测试
 * @create 2022-08-18-13:05
 */
public class Client {
    public static void main(String[] args) {
        MySubject subject = new Leader();
        MyObserver obs1, obs2;
        obs1 = new Jack();
        obs2 = new Mark();
        subject.attach(obs1);
        subject.attach(obs2);
//        subject.detach(ObserverEnum.Dog.getMyObserver());
        System.out.println("===================== 第一天 =======================");
        //1代表需要加班,2代表不加班
        System.out.println("Leader:今天所有人都要加班!");
        subject.push(1);
        System.out.println("===================== 第二天 ====================");
        //1代表需要加班,2代表不加班
        System.out.println("Leader:今天大家不用加班了!");
        subject.push(2);
    }
}

测试结果


0000.png


相信有一些小伙伴已经发现了,如果像测试类中的写法,每次发送消息的时候都需要new对应的对象然后添加到观察者集合中,这样很不方便


我们可以使用观察者模式+工厂模式来解决这个问题。


四 优化demo案例 观察者模式+工厂模式


创建观察者工厂枚举类:ObserverEnum

/**
 * @Author liuy
 * @Description 观察者工厂枚举类
 * @Date 2022/8/18 14:55
 * @Version 1.0
 */
public enum ObserverEnum {
    Mouse(new Jack()),
    Dog(new Mark()),
    ;
    ObserverEnum(MyObserver myObserver) {
        this.myObserver = myObserver;
    }
    private  MyObserver  myObserver;
    public MyObserver getMyObserver() {
        return myObserver;
    }
    public void setMyObserver(MyObserver myObserver) {
        this.myObserver = myObserver;
    }
    public static List<MyObserver> getObservers(){
        return Arrays.stream(ObserverEnum.values()).map(ObserverEnum::getMyObserver).collect(Collectors.toList());
    }
}

然后只需要修改抽象目标类中的观察者集合成员变量:observers

import java.util.List;
/**
 * @author liuy 抽象目标类
 * @create 2022-08-18-13:05
 */
public abstract class MySubject {
    //所有观察者集合
    //旧 protected List<MyObserver> observers = new ArrayList<>() ;
    protected List<MyObserver> observers = ObserverEnum.getObservers();
    //注册方法
    public void attach(MyObserver observer){
        observers.add(observer);
    }
    //注销方法
    public void detach(MyObserver observer){
        observers.remove(observer);
    }
    public abstract void push(int state); //抽象通知方法
}

测试

/**
 * @author liuy 客户端测试
 * @create 2022-08-18-13:05
 */
public class Client {
    public static void main(String[] args) {
        MySubject subject = new Leader();
        System.out.println("===================== 第一天 =======================");
        //1代表需要加班,2代表不加班
        System.out.println("Leader:今天所有人都要加班!");
        subject.push(1);
        System.out.println("===================== 第二天 ====================");
        //1代表需要加班,2代表不加班
        System.out.println("Leader:今天大家不用加班了!");
        subject.push(2);
    }
}

000.png


五 优缺点


主要优点

(1)观察者模式可以实现表示层和数据逻辑层的分离,定义了稳定的消息传递机制,并抽象了更新接口,使得可以有各种各样的表示层充当具体的观察者角色。


(2)观察者模式在观察目标和观察者之间建立一个抽象的耦合。观察者对象只需要维持一个抽象观察者的集合,无需了解其具体观察者。


(3)观察者模式支持广播通信,观察目标会向所有已注册的观察者发送通知,降低了一对多系统的设计难度。


(4)观察者模式满足开闭原则的要求,增加新的具体观察者无须修改原有的系统代码。


主要缺点

(1)如果一个观察目标对象有很多的直接观察者和间接观察者,那么所有的观察者接收到消息会耗费大量的时间。


(2)如果观察者和被观察者之间存在循环依赖,那么观察目标会触发它们之间进行循环调用,可能导致系统崩溃。


(3)观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的,而仅仅只是知道目标观察对象发生了变化


目录
打赏
0
0
0
0
19
分享
相关文章
并发设计模式实战系列(5):生产者/消费者
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发设计模式实战系列,第五章,废话不多说直接开始~
85 1
并发设计模式实战系列(8):Active Object
🌟 大家好,我是摘星!🌟今天为大家带来的是并发设计模式实战系列,第8章,废话不多说直接开始~
29 0
并发设计模式实战系列(8):Active Object
并发设计模式实战系列(2):领导者/追随者模式
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发设计模式实战系列,第二章领导者/追随者(Leader/Followers)模式,废话不多说直接开始~
66 0
并发设计模式实战系列(1):半同步/半异步模式
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发设计模式实战系列,第一章半同步/半异步(Half-Sync/Half-Async)模式,废话不多说直接开始~
52 0
并发设计模式实战系列(4):线程池
需要建立持续的性能剖析(Profiling)和调优机制。通过以上十二个维度的系统化扩展,构建了一个从。设置合理队列容量/拒绝策略。动态扩容/优化任务处理速度。检查线程栈定位热点代码。调整最大用户进程数限制。CPU占用率100%
171 0
并发设计模式实战系列(7):Thread Local Storage (TLS)
🌟 大家好,我是摘星! 🌟今天为大家带来的是并发设计模式实战系列,第七章Thread Local Storage (TLS),废话不多说直接开始~
82 0
并发设计模式实战系列(9):消息传递(Message Passing)
🌟 大家好,我是摘星!🌟今天为大家带来的是并发设计模式实战系列,第九章,废话不多说直接开始~
61 0
并发设计模式实战系列(10):Balking(犹豫模式)
🌟 大家好,我是摘星!🌟今天为大家带来的是并发设计模式实战系列,第10章,废话不多说直接开始~
30 0
并发设计模式实战系列(11):两阶段终止(Two-Phase Termination)
🌟 大家好,我是摘星!🌟今天为大家带来的是并发设计模式实战系列,第十一章,废话不多说直接开始~
33 0
并发设计模式实战系列(12):不变模式(Immutable Object)
🌟 大家好,我是摘星!🌟今天为大家带来的是并发设计模式实战系列,第十二章,废话不多说直接开始~
50 0

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等