正文 

当前位置： 首页 > java > java教程

java中观察者模式与委托，还在傻傻分不清

华为云开发者社区      2022-05-19     577

关键词：

本文分享自华为云社区《Java中观察者模式与委托的对比》，作者： 小小张自由--张有博 。

代码背景

一个班级，有两类学生，A类：不学习，玩，但是玩的东西不一样，有的是做游戏，有的是看电视

B类：放哨的学生，专门看老师的动向，如果老师进班了就立即通知大家。

如此就形成了一个需求，放哨的学生要通知所有玩的学生：老师来了，而不同的学生有不同的反应，有的马上把电视关闭，有的停止玩游戏。

观察者模式

介绍

观察者模式：定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有的观察者对象，使他们能够自动更新自己。

**主要解决：**一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。

**何时使用：**一个对象（目标对象）的状态发生改变，所有的依赖对象（观察者对象）都将得到通知，进行广播通知。

**如何解决：**使用面向对象技术，可以将这种依赖关系弱化。

**关键代码：**在抽象类里有一个 ArrayList 存放观察者们。

实现

观察者（学生）

/**
 * 抽象的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:32
 */
public interface Observer 

    public abstract void updateState();



/**
 * 具体的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:39
 */
public class ConcreteObserver implements Observer

    //观察者的姓名
    private String name;

    //观察者的状态
    private String observerState;

    //明确具体的通知者
    private ConcreteSubject subject;

   //get set方法省略

    public ConcreteObserver(String name, ConcreteSubject subject) 
        this.name = name;
        this.subject = subject;
    

    @Override
    public void updateState() 
        observerState=subject.getSubjectState();
        System.out.println(name+"在打游戏");
        String str=String.format("观察者%s的：新状态是%s", name,observerState);
        System.out.println(str);
    

/**
 * 具体的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:39
 */
public class ConcreteObserver2 implements Observer

    //观察者的姓名
    private String name;

    //观察者的状态
    private String observerState;

    //明确具体的通知者
    private ConcreteSubject subject;

   //get set方法省略

    public ConcreteObserver2(String name, ConcreteSubject subject) 
        this.name = name;
        this.subject = subject;
    

    @Override
    public void updateState() 
        observerState=subject.getSubjectState();
        System.out.println(name+"在看电视");
        String str=String.format("观察者%s：新状态是%s", name,observerState);
        System.out.println(str);
    

复制代码

通知者（老师）

/**
 * 抽象的通知者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:30
 */
public abstract class Subject 

    //管理观察者的集合
    private List<Observer> observers=new ArrayList<>();

    //增加观察者
    public void add(Observer observer)
        observers.add(observer);
    

    //减少观察者
    public void detach(Observer observer)
        observers.remove(observer);
    
    /**
     * 通知所有的观察者
     */
    public void notifyMsg()
        for (Observer observer : observers) 
            observer.updateState();
        
    


/**
 * 具体的通知者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:38
 */
public class ConcreteSubject extends Subject 

    //通知者的状态
    private String subjectState;

    //get set方法
    public String getSubjectState() 
        return subjectState;
    

    public void setSubjectState(String subjectState) 
        this.subjectState = subjectState;
    

复制代码

Main方法

/**
 * 控制台Main方法
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:48
 */
public class MainTest 

    public static void main(String[] args) 
        //创建一个主题/通知者
        ConcreteSubject subject=new ConcreteSubject();

        //new出观察者（学生）
        ConcreteObserver studentZhang = new ConcreteObserver("小张", subject);
        ConcreteObserver studentLiu = new ConcreteObserver("小刘", subject);
        ConcreteObserver studentWang = new ConcreteObserver("小王", subject);

        //将观察者添加到通知队列里
        subject.add(studentZhang);
        subject.add(studentLiu);
        subject.add(studentWang);

        //通知者（老师）状态修改，通知每个学生
        subject.setSubjectState("老师回来了，我要好好学习");
        subject.notifyMsg();

        System.out.println("-----------");
    


复制代码

委托

介绍

委托可以看做是函数的抽象，是函数的“类”。委托的实例将代表一个具体的函数

一个委托可以搭载多个方法，所有的方法被依次唤起。可以使委托对象所搭载的方法并不需要属于同一类。

委托事件模型可以由三个组件定义：事件、事件源和事件侦听器。

委托的实现简单来讲就是用反射来实现的。

实现

观察者

/**
 * 监听器/观察者 玩游戏
 * 事件监听器
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:17
 */
public class PlayingGameListener 

    public PlayingGameListener()
        System.out.println("我正在玩游戏 开始时间"+new Date());
    
    public void stopPlayingGame(Date date)
        System.out.println("老师来了，快回到座位上，结束时间"+date);
    



/**
 * 监听器/观察者 看电视
 * 事件监听器
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:17
 */
public class WatchingTVListener 

    public WatchingTVListener()
        System.out.println("我正在看电视 "+new Date());
    
    public void stopWatchingTV(Date date)
        System.out.println("老师来了，快关闭电视 。 结束时间"+date);
    

复制代码

通知者

/**
 * 通知者的抽象类
 * 事件源
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:15
 */
public abstract class Notifier 

    //每个通知者都有一个需要通知的队列（通知：对象、方法、参数）
    private EventHandler eventHandler=new EventHandler();

    public EventHandler getEventHandler() 
        return eventHandler;
    

    public void setEventHandler(EventHandler eventHandler) 
        this.eventHandler = eventHandler;
    

    //增加需要帮忙放哨的学生
    public abstract void addListener(Object object,String methodName,Object...args);
    //告诉所有要帮忙放哨的学生：老师来了
    public abstract void notifyX();

/**
 * 通知者的子类，放哨人
 * 事件源
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:15
 */
public class GoodNotifier extends Notifier 

    @Override
    public void addListener(Object object, String methodName, Object...args) 
        System.out.println("有新的同学委托尽职尽责的放哨人!");
        this.getEventHandler().addEvent(object, methodName, args);
    

    @Override
    public void notifyX() 
        System.out.println("尽职尽责的放哨人告诉所有需要帮忙的同学：老师来了");
        try
            //优化：异步通知
            this.getEventHandler().notifyX();
        catch(Exception e)
            e.printStackTrace();
        
    

复制代码

事件

/**
 * 抽象出的事件类，也可以称为方法类
 * 事件
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:03
 */
public class Event 

    //要执行方法的对象
    private Object object;
    //要执行的方法名称
    private String methodName;
    //要执行方法的参数
    private Object[] params;
    //要执行方法的参数类型
    private Class[] paramTypes;

    //若干setter getter
    public Object getObject() 
        return object;
    

    public String getMethodName() 
        return methodName;
    
    public void setMethodName(String methodName) 
        this.methodName = methodName;
    

    public Object[] getParams() 
        return params;
    
    public void setParams(Object[] params) 
        this.params = params;
    

    public Class[] getParamTypes() 
        return paramTypes;
    
    
    public void setParamTypes(Class[] paramTypes) 
        this.paramTypes = paramTypes;
    

    public Event()

    
    public Event(Object object,String methodName,Object...args)
        this.object=object;
        this.methodName=methodName;
        this.params=args;
        contractParamTypes(this.params);
    

    //根据参数数组生成参数类型数组
    private void contractParamTypes(Object[] params)
        this.paramTypes=new Class[params.length];
        for(int i=0;i<params.length;i++)
            this.paramTypes[i]=params[i].getClass();
        
    
    //执行该 对象的该方法
    public void invoke() throws Exception
        //通过class,method,paramTypes 确定执行哪个类的哪个方法
        Method method=object.getClass().getMethod(this.getMethodName(), this.getParamTypes());
        if(null==method)
            return;
        
        //方法执行
        method.invoke(this.getObject(), this.getParams());
    


复制代码

事件处理

/**
 * 管理哪些事件需要执行
 * 管理事件
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:03
 */
public class EventHandler 

    //是用一个List
    private List<Event> objects;
    //添加某个对象要执行的事件，及需要的参数
    public void addEvent(Object object,String methodName,Object...args)
        objects.add(new Event(object,methodName,args));
    

    public EventHandler()
        objects=new ArrayList<Event>();
    

    //通知所有的对象执行指定的事件
    public void notifyX() throws Exception
        for(Event e : objects)
            e.invoke();
        
    

复制代码

Main方法

/**
 * 启动类
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:19
 */
public class EventMain 

    public static void main(String[] args) 
        //创建一个尽职尽责的放哨者
        Notifier goodNotifier = new GoodNotifier();

        //创建一个玩游戏的同学，开始玩游戏
        PlayingGameListener playingGameListener = new PlayingGameListener();
        //创建一个看电视的同学，开始看电视
        WatchingTVListener watchingTVListener = new WatchingTVListener();
        //玩游戏的同学告诉放哨的同学，老师来了告诉一下
        goodNotifier.addListener(playingGameListener, "stopPlayingGame", new Date());
        //看电视的同学告诉放哨的同学，老师来了告诉一下
        goodNotifier.addListener(watchingTVListener, "stopWatchingTV", new Date());
        try 
            //一点时间后
            Thread.sleep(1000);
         catch (Exception e) 
            e.printStackTrace();
        
        //老师出现，放哨的人通知所有要帮忙的同学:老师来了
        goodNotifier.notifyX();
    

复制代码

总结

1.先有观察者模式后有委托事件技术

2.观察者模式只能通知继承 Observer类 的子类，也可以将Observer改成接口

for (Observer observer : observers) 
        observer.updateState();

复制代码

3.委托可以通知任何类的任何方法。反射、everone

    Method method=object.getClass().getMethod(this.getMethodName(), this.getParamTypes());
    if(null==method)
        return;
    
    method.invoke(this.getObject(), this.getParams());
复制代码

4.委托与观察者比多了一个事件执行者，解除观察者与通知者的耦合，可以做到通知任何对象的任何方法。

5.让A类学生和B类学生完全解耦，即A类完全不知道B类的学生，却可以通知B类的学生

6.建立一套触发机制，可以使用异步通知

7.观察者/委托挺像MQ里边的订阅发布。生产者、队列、消费者。


点击关注，第一时间了解华为云新鲜技术~​

cookiesession,token，还在傻傻分不清？

摘要：session和token本质上是没有区别的，都是对用户身份的认证机制，只是他们实现的校验机制不一样而已。本文分享自华为云社区《​​Session/Cookie/Token还傻傻分不清？​​》，作者：龙哥手记。相信项目中用JWTToken的应该不... 查看详情

cookiesession,token，还在傻傻分不清？(代码片段)

摘要：session和token本质上是没有区别的，都是对用户身份的认证机制，只是他们实现的校验机制不一样而已。本文分享自华为云社区《Session/Cookie/Token还傻傻分不清？》，作者：龙哥手记。相信项目中用JWTT... 查看详情

cookiesession,token，还在傻傻分不清？(代码片段)

摘要：session和token本质上是没有区别的，都是对用户身份的认证机制，只是他们实现的校验机制不一样而已。本文分享自华为云社区《Session/Cookie/Token还傻傻分不清？》，作者：龙哥手记。相信项目中用JWTT... 查看详情

旁路电容与去耦电容，傻傻分不清

关注v-x-公-众-号：【嵌入式基地】后-台-回-复：【电赛】即可获资料回复【编程】即可获取包括有：C、C++、C#、JAVA、Python、JavaScript、PHP、数据库、微信小程序、人工智能、嵌入式、Linux、Unix、QT、物联网、算法... 查看详情

进程线程与协程傻傻分不清？一文带你吃透！

前言欢迎来到操作系统系列，依然采用图解+大白话的形式来讲解，让小白也能看懂，帮助大家快速科普入门本篇开始介绍进程、线程、协程，相信很多小白们对这几个概念理解的不清晰，这里全部给你们安排的明明白白，我们... 查看详情

ci/cd和devops还在傻傻分不清吗？今日一文让你通透

基本概念持续集成​ 持续集成的重点在于构建编译及测试，开发人员每天要提交很多次代码到分支，在分支合并到主干前，需要通过编译和测试识别出问题。持续集成的流程就是通过自动化的构建（主要是构建编译、自动化测... 查看详情

sessiontokenjwtoauth2傻傻分不清

...会涉及到权限、认证等类似的概念。但是很多小伙伴还是傻傻的分不清这些的概念和区别，今天我们就来好好的捋一捋，将其区别 查看详情

均值与期望：傻傻分不清？

作者：一人文章大纲众多原因造成平均值与期望的混淆学习与应用过程当中对于二者“不加区分”二者联系十分紧密语言文化的影响区分平均值和期望明确平均值的研究范畴-数理统计明确期望的研究范畴-概率论大数定理的... 查看详情

傻傻分不清之cookiesessiontokenjwt

1.傻傻分不清之Cookie、Session、Token、JWT 查看详情

okr与影响地图，别再傻傻分不清

摘要：OKR和影响地图虽然都是为了一个目标去进行规划的方法，但是两者侧重的内容却不一致。本文分享自华为云社区《一分钟读懂OKR与影响地图》，作者：敏捷的小智。什么是OKR及影响地图OKR：ObjectivesandKeyR... 查看详情

设计模式存在哪些关联关系，六种关系傻傻分不清---uml图示详解(代码片段)

...一套符号语言。不同的符号对应不同的含义。在之前设计模式章节中我们文章中用到的就是UML类图，UML除了类图意外还有用例图，活动图，时序图。关于UML如何绘制，这里主要推荐两种方式一种是通过draw.io，... 查看详情

设计模式存在哪些关联关系，六种关系傻傻分不清---uml图示详解(代码片段)

...一套符号语言。不同的符号对应不同的含义。在之前设计模式章节中我们文章中用到的就是UML类图，UML除了类图意外还有用例图，活动图，时序图。关于UML如何绘制，这里主要推荐两种方式一种是通过draw.io，... 查看详情

带你了解android的jitaotdalvikart，不再傻傻分不清

为了解释以上概念，我们得从Android编译过程说起。   我们使用Java开发android，在编译打包APK文件时，会经过以下流程：  Java编译器将应用中所有Java文件编译为class文件,dx工具将应用编译输出的类文件转换为Dalvi... 查看详情

javaspi和api，傻傻分不清？

最近新写了一个中间件「运行时动态日志等级开关」，其中使用JavaSPI机制实现了自定义配置中心，保证良好的扩展性。项目地址，走过路过可以点个star：）https://github.com/saigu/LogLevelSwitch在使用过程中，突然发现SPI其实和日常写A... 查看详情

很多人傻傻分不清b2b和bsm

...跨境B2C。一个是C2m。大家看到没，是大C、小m。这个模式就是薇娅KOL直播。这个模式在2018年曾鸣教授的《智能商业》一书中有详细介绍。一个KOL大V的视频直播销量&#x 查看详情

bionioaio，还傻傻分不清？(代码片段)

作者：rickiyang出处：www.cnblogs.com/rickiyang/p/11074238.html我们知道java的I/O模型一共有四种，分别是：传统的BIO，伪异步I/O，NIO和AIO。为了澄清概念和分清区别，我们还是先简单的介绍一下他们的概念，然后再去比较优劣。1.概念澄清1... 查看详情

进程线程与协程傻傻分不清？一文带你吃透！

前言欢迎来到操作系统系列，依然采用图解+大白话的形式来讲解，让小白也能看懂，帮助大家快速科普入门本篇开始介绍进程、线程、协程，相信很多小白们对这几个概念理解的不清晰，这里全部给你们安... 查看详情

别再傻傻分不清avsxh.26xmpeg-x了

...标准的更新换代也极大促进了音视频技术的发展以及行为模式的变更。从电视到网络视频以及现在的网络直播、点播、音视频会议等等，这些变化的背后都离不开音视频编解码技术的更新迭代。比如H.264(仍然是目前使用最多... 查看详情