Spring注解驱动之ApplicationListener异步处理事件说明

更新时间：2022年09月30日 09:04:07 作者：融极

这篇文章主要介绍了Spring注解驱动之ApplicationListener异步处理事件说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

概述

之前我们讲过简单使用ApplicationListener发布事件，处理事件，但是发现是同一个线程发送事件并自己处理事件的。

下面我们就来说下如何使用自定义的线程池来异步处理接收的事件。

示例

实现一个ApplicationListener用于处理事件

package com.atguigu.ext;

import org.springframework.context.ApplicationListener;
import org.springframework.context.PayloadApplicationEvent;
import org.springframework.stereotype.Component;

@Component
public class MyApplicationListener implements ApplicationListener<PayloadApplicationEvent> {

    public void onApplicationEvent(PayloadApplicationEvent applicationEvent) {
        System.out.println("exe thread start:" + Thread.currentThread().getName() + ", time:" + System.currentTimeMillis());
        System.out.println("收到事件：" + applicationEvent);
        System.out.println(applicationEvent.getPayload());
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("exe thread end:" + Thread.currentThread().getName() + ", time:" + System.currentTimeMillis());
    }
}

自定义事件多波器

package com.atguigu.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.SimpleApplicationEventMulticaster;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

@Configuration
@ComponentScan("com.atguigu.ext")
public class ExtConfig {

    @Bean
    public SimpleApplicationEventMulticaster applicationEventMulticaster() {
        SimpleApplicationEventMulticaster simpleApplicationEventMulticaster = new SimpleApplicationEventMulticaster();
        BlockingQueue<Runnable> blockingQueue = new LinkedBlockingDeque<>(1000);
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 5, 10, TimeUnit.SECONDS, blockingQueue);
        simpleApplicationEventMulticaster.setTaskExecutor(threadPoolExecutor);
        return simpleApplicationEventMulticaster;
    }
}

之前看源码可以发现，在容器创建的refresh方法中的initApplicationEventMulticaster()方法执行时，先从容器中获取name为applicationEventMulticaster的组件，如果获取不到就好创建一个默认的applicationEventMulticaster组件，该组件默认是不会设置taskExecutor任务执行器的，所以这里我们自定义一个设置了TaskExecutor的多波器，当执行initApplicationEventMulticaster方法从beanFactory中获取applicationEventMulticaster组件时，走getBean逻辑。

BeanFactory.getBean()逻辑是先从容器查看是否有该组件，如果没有获取该组件的定义，如果有定义就会创建一个组件返回并把组件保存到容器中。

测试用例

package com.atguigu;

import com.atguigu.config.ExtConfig;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

/**
 * @Description :
 * @Version : V1.0.0
 * @Date : 2022/9/1 15:07
 */
public class AnnotationTest {
    public static void main(String[] args) {
        final AnnotationConfigApplicationContext applicationContext
                = new AnnotationConfigApplicationContext(ExtConfig.class);
        System.out.println("main thread start:" + Thread.currentThread().getName() + ", time:" + System.currentTimeMillis());
        applicationContext.publishEvent("发送事件");
        System.out.println("main thread end:" + Thread.currentThread().getName() + ", time:" + System.currentTimeMillis());
        applicationContext.close();
    }
}

测试结果

main thread start:main, time:1663499481185
main thread end:main, time:1663499481188
exe thread start:pool-1-thread-1, time:1663499481188
收到事件：org.springframework.context.PayloadApplicationEvent[source=org.springframework.context.annotation.AnnotationConfigApplicationContext@5ebec15: startup date [Sun Sep 18 19:11:20 CST 2022]; root of context hierarchy]
发送事件
九月 18, 2022 7:11:21 下午 org.springframework.context.annotation.AnnotationConfigApplicationContext doClose
信息: Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@5ebec15: startup date [Sun Sep 18 19:11:20 CST 2022]; root of context hierarchy
exe thread end:pool-1-thread-1, time:1663499484198

通过测试结果可以看出，main线程很快就返回了，而实际处理事件的线程是pool-1-thread-1，等待了3s多才返回。

ApplicationListener异步执行源码分析

参考：Spring注解驱动之ApplicationListener用法

与上面同步执行不同的地方就是使用了自定义的多波器里面的线程池执行了事件处理。

多波器的获取。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

使用java一维数组模拟压栈弹栈
这篇文章主要介绍了如何使用java一维数组模拟压栈弹栈,需要的朋友可以参考下
2021-04-04
Spring Security中的Servlet过滤器体系代码分析
这篇文章主要介绍了Spring Security中的Servlet过滤器体系,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-07-07
Java Web开发项目中中文乱码解决方法汇总
这篇文章主要为大家详细汇总了Java Web开发项目中中文乱码的解决方法，分析了5种Java Web中文乱码情况，感兴趣的小伙伴们可以参考一下
2016-05-05
spring注解@Service注解的使用解析
这篇文章主要介绍了spring注解@Service注解的使用解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-07-07
Java中如何正确遍历删除List中的元素
删除List中元素这个场景很场景,很多人可能直接在循环中直接去删除元素,这样做对吗？下面小编就来和大家一起讨论如何正确遍历删除List中的元素,文中有详细的代码示例供大家参考,需要的朋友可以参考下
2023-11-11
详解Java抽象类与普通类的区别
今天给大家带来的是关于Java的相关知识,文章围绕着Java抽象类与普通类的区别展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下
2021-06-06
SpringBoot项目URL访问异常的问题处理
这篇文章主要介绍了SpringBoot项目URL访问异常的问题处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-07-07
Java 实战项目之在线点餐系统的实现流程
读万卷书不如行万里路，只学书上的理论是远远不够的，只有在实战中才能获得能力的提升，本篇文章手把手带你用java+SSM+jsp+mysql+maven实现在线点餐系统,大家可以在过程中查缺补漏，提升水平
2021-11-11
一文搞懂MyBatis多数据源Starter实现
本文将实现一个MyBatis的Springboot的Starter包，引用这个Starter包后，仅需要提供少量配置信息，就能够完成MyBatis多数据源的初始化和使用，需要的小伙伴可以参考一下
2023-04-04
详细解读Druid数据库连接池的使用
这篇文章主要介绍了Druid数据库连接池的使用,数据库连接池负责分配、管理和释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个,需要的朋友可以参考下
2023-03-03