请选择 进入手机版 | 继续访问电脑版

Spring源码之事件监听机制(下)

[复制链接]
小甜心 发表于 2020-12-31 18:15:48 | 显示全部楼层 |阅读模式 打印 上一主题 下一主题
文章目次



  一、手写事件监听机制框架

1.准备

JDK为我们提供了事件监听的支持,在java.util包的下面提供了事件监听接口以及事件类。


2.事件监听接口

  1. public interface IEventListener extends EventListener {    void onApplicationEvent(E event);}
复制代码
界说一个事件监听接口供事件监听类实现
3.事件管理器

  1. public class EventMulticaster {    private Set set = new LinkedHashSet();    public void registerListener(IEventListener listener) {        if (!set.contains(listener)) {            set.add(listener);        }    }    public void removeListener(IEventListener listener) {        if (!set.contains(listener)) {            set.remove(listener);        }    }    public Set getEventListeners() {        return set;    }}
复制代码
界说一个事件管理器,存储事件监听以及对事件监听的增删操纵
4.事件发布器

  1. public class EventPublisher {    private EventMulticaster eventMulticaster;    public void initEventMulticaster() {        if (eventMulticaster == null) {            eventMulticaster = new EventMulticaster();        }    }    public void registerListener(IEventListener listener) {        if (eventMulticaster != null) {            eventMulticaster.registerListener(listener);        }    }    public void removeListener(IEventListener listener) {        if (eventMulticaster != null) {            eventMulticaster.removeListener(listener);        }    }    public void publishEvent(EventObject eventObject) {        if (eventMulticaster != null) {            Set set = eventMulticaster.getEventListeners();            for (IEventListener listener : set) {                listener.onApplicationEvent(eventObject);            }        }    }}
复制代码
5.需求

和上一篇一样:在订单服务中,用户下单乐成后,需要物流服务和库存服务举行相应的处理处罚,采取异步解耦的方式。
6.编码


  • 订单事件
  1. public class OrderEvent extends EventObject {    public OrderEvent(Object source) {        super(source);    }}
复制代码

  • 库存监听
  1. public class StoreListener implements IEventListener{    @Override    public void onApplicationEvent(OrderEvent event) {        System.out.println("库存服务运行中……");    }}
复制代码

  • 物流监听
  1. public class LogisticsListener implements IEventListener {    @Override    public void onApplicationEvent(OrderEvent event) {        System.out.println("物流服务运行中……");    }}
复制代码

  • 订单服务
  1. System.out.println("订单服务开始运行");System.out.println("创建订单完成,通知物流、库存……");// 初始化事件管理器EventPublisher eventPublisher = new EventPublisher();eventPublisher.initEventMulticaster();// 添加事件监听eventPublisher.registerListener(new LogisticsListener());eventPublisher.registerListener(new StoreListener());// 发布事件eventPublisher.publishEvent(new OrderEvent(this));
复制代码

  • 效果
  订单服务开始运行
创建订单完成,通知物流、库存……
物流服务运行中……
库存服务运行中……
二、观察者模式

1.概述

  观察者模式(有时又被称为模子(Model)-视图(View)模式、源-收听者(Listener)模式或附属者模式)是软件设计模式的一种。在此种模式中,一个目的物件管理所有相依于它的观察者物件,而且在它本身的状态改变时主动发出通知。这通常透过召唤各观察者所提供的方法来实现。此种模式通常被用来实现事件处理处罚系统。(百度百科)
事件监听机制举行建模分析,当不思量事件发布器之后,可以简朴的理解为:一个事件对应着多个监听者,当事件发布的时候,监听者收到消息,是不是就是典范的观察者模式。
2.UML图

其实JDK已经为我们提供了对观察者模式的支持,下面是我根据JDK中提供的观察者与被观察者绘制的UML图:

从UML图中可以看出:被观察者也被称为主题,与观察者之间是一对多的关系,主题存储着所有观察者,当主题状态变动的时候,通知观察者举行更新。
3.Coding验证


  • 主题
  1. public class Subject extends Observable {    public void setChanged() {        super.setChanged();    }}
复制代码

  • 观察者
  1. public class ConcreteObserver1 implements Observer {    private String name;    public ConcreteObserver1(String name) {        this.name = name;    }    @Override    public void update(Observable o, Object arg) {        System.out.println(name + ":当前状态:" + o.hasChanged() + ",内容:" + arg.toString());    }}
复制代码

  • 客户端验证
  1. public class Client {    public static void main(String[] args) {        Subject subject = new Subject();        subject.addObserver(new ConcreteObserver1("观察者1"));        subject.addObserver(new ConcreteObserver2("观察者2"));        subject.setChanged();        subject.notifyObservers("我已经不是当初你认识的我自己……");    }}
复制代码

  • 效果
  观察者2:当前状态:false,内容:我已经不是当初你认识的我自己……
观察者1:当前状态:false,内容:我已经不是当初你认识的我自己……
  小结

  从Spring的事件监听机制,到自界说监听框架,再到观察者模式,一路走来,从繁入简,相信各人对Spring的监听机制已经有了清晰的认知。
  那我们从设计模式,到Sping的事件监听再回顾一下。当对象之间存在着一对多的关系,一个对象改变,依赖于它的所有对象都会收到通知,这就是我们的观察者模式。但被观察者与观察者之间依然存在着很强的耦合关系,所以为了降低这种耦合关系,我们在被观察者和观察者之间放置一个消息通道,也就是事件发布器,这就是事件监听机制,Spring的事件监听机制就是依托于此,只不外它更加的完善。
  好了,这篇文章到这里就竣事了,相信到这里再转头看Spring的事件监听机制源码一定会有不一样的收获。

来源:https://blog.csdn.net/qq_27023083/article/details/111938356
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则


专注素材教程免费分享
全国免费热线电话

18768367769

周一至周日9:00-23:00

反馈建议

27428564@qq.com 在线QQ咨询

扫描二维码关注我们

Powered by Discuz! X3.4© 2001-2013 Comsenz Inc.( 蜀ICP备2021001884号-1 )