摘要:前言由于之前使用事件机制出现了问题,所以特意去了解这块的源码。事件机制其实就是事件发布订阅注意在中订阅指的是监听。
前言
由于之前使用Spring事件机制出现了问题,所以特意去了解这块的源码。Spring事件机制其实就是事件发布/订阅(注意在Spring中订阅指的是监听)。
PS:Spring版本为5.1.5.RELEASE
源码分析 初始化初始化这块关键是核心组件的注册
ApplicationEventPublisher的初始化与注册,关键方法为AbstractApplicationContext的方法prepareBeanFactory()
ApplicationEventMulticaster的初始化与注册,关键方法为AbstractApplicationContext的initApplicationEventMulticaster()方法
ApplicationListener的初始化与注册,关键方法为AbstractApplicationContext的registerListeners()方法
这块不细说,感兴趣的可以自行跟踪关键方法
事件发布/订阅事件发布/订阅的关键方法为AbstractApplicationContext的publishEvent,源码如下:
protected void publishEvent(Object event, ResolvableType eventType) { // 避免空指针 Assert.notNull(event, "Event must not be null"); if (logger.isTraceEnabled()) { logger.trace("Publishing event in " + getDisplayName() + ": " + event); } // 处理event对象,将其转换为ApplicationEvent ApplicationEvent applicationEvent; if (event instanceof ApplicationEvent) { applicationEvent = (ApplicationEvent) event; } else { applicationEvent = new PayloadApplicationEvent
通过代码跟踪,发现Spring中使用ApplicationEventMulticaster的默认实现SimpleApplicationEventMulticaster来触发事件的监听,关键方法为multicastEvent()方法,源码如下:
@Override public void multicastEvent(final ApplicationEvent event, ResolvableType eventType) { // 获取事件类型 ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event)); for (final ApplicationListener> listener : getApplicationListeners(event, type)) {//依次遍历事件监听器 // 获取线程池 Executor executor = getTaskExecutor(); if (executor != null) {//线程池不为null,则异步调用监听器 executor.execute(new Runnable() { @Override public void run() { invokeListener(listener, event); } }); } else {// 同步调用监听器 invokeListener(listener, event); } } }
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/73958.html
摘要:哪吒社区技能树打卡打卡贴函数式接口简介领域优质创作者哪吒公众号作者架构师奋斗者扫描主页左侧二维码,加入群聊,一起学习一起进步欢迎点赞收藏留言前情提要无意间听到领导们的谈话,现在公司的现状是码农太多,但能独立带队的人太少,简而言之,不缺干 ? 哪吒社区Java技能树打卡 【打卡贴 day2...
摘要:前言以下源码基于版本解析。实现源码分析对于的实现,总结来说就是定位加载和注册。定位就是需要定位配置文件的位置,加载就是将配置文件加载进内存注册就是通过解析配置文件注册。下面我们从其中的一种使用的方式一步一步的分析的实现源码。 前言 以下源码基于Spring 5.0.2版本解析。 什么是IOC容器? 容器,顾名思义可以用来容纳一切事物。我们平常所说的Spring IOC容器就是一个可以容...
摘要:是一个相对比较新的微服务框架,年才推出的版本虽然时间最短但是相比等框架提供的全套的分布式系统解决方案。提供线程池不同的服务走不同的线程池,实现了不同服务调用的隔离,避免了服务器雪崩的问题。通过互相注册的方式来进行消息同步和保证高可用。 Spring Cloud 是一个相对比较新的微服务框架,...
阅读 3384·2023-04-26 01:46
阅读 2905·2023-04-25 20:55
阅读 5470·2021-09-22 14:57
阅读 2973·2021-08-27 16:23
阅读 1711·2019-08-30 14:02
阅读 2062·2019-08-26 13:44
阅读 643·2019-08-26 12:08
阅读 2950·2019-08-26 11:47