Spring的监听器使用（实用，直接拿去修改可用）

一，前言

这里我们以ApplicationListener为例，简单说明一下监听器如何使用。

本人基本只输出实用，即用的代码，希望能帮助到各位，如果想研究底层逻辑，大家可自行根据代码去类源码查看。

监听器的使用主要分三部分：

实现ApplicationListener接口
继承ApplicationEvent类
使用ApplicationEventPublisher

我将按正式项目方法进行监听器的使用。结合线程池，进行异步解耦

照例，我们先简单搭一个springboot项目。

二，代码展示

启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;@SpringBootApplication
@EnableAsync  // springboot 开启异步支持
public class Applications {public static void main(String[] args) {SpringApplication.run(Applications.class, args);}
}

modle类

import lombok.Data;@Data
public class RojerEventModel {private String name;private Integer age;// true 为boy  false 为 girlprivate Boolean sex;
}

event类

import com.luojie.moudle.RojerEventModel;
import org.springframework.context.ApplicationEvent;public class RojerEvent extends ApplicationEvent {public RojerEventModel model;public RojerEvent(RojerEventModel model) {super(model);this.model = model;}}

listener类

import com.luojie.event.RojerEvent;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;@Component
@Slf4j
public class RojerListener implements ApplicationListener<RojerEvent> {@Override@Async("asyncExecutor")  // 使用异步线程池进行处理public void onApplicationEvent(RojerEvent event1) {if (event1.model.getSex()) {a();} else {b();}}public void a() {log.info("this is a boy");}public void  b() {log.info("this is a girl");}}

异步线程池配置类

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;@Configuration
public class AsyncPools {@Bean(name = "asyncExecutor")public Executor getAsyncExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10); // 设置核心线程数executor.setMaxPoolSize(20); // 设置最大线程数executor.setQueueCapacity(100); // 设置队列容量executor.setThreadNamePrefix("async-executor-"); // 设置线程名前缀executor.setKeepAliveSeconds(5000);// 设置线程最大等待时间executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());// 设置线程拒绝策略executor.initialize();return executor;}}

三，运行展示

展示图

四，实际项目运用场景

缓存更新：如果应用程序使用了缓存（如redis），可以使用监听器来监听数据变更事件，并在数据变更时刷新缓存。且我们可以做到避免redis故障影响服务正常运行，做到缓存与服务解耦。
日志记录：监听方法调用、请求处理等事件，并记录日志。这样可以方便地进行系统监控和故障排查。
权限控制：监听用户登录、权限变更等事件，并根据事件触发相应的权限控制逻辑。
消息通知：监听消息队列中的消息，然后根据消息内容进行相应的业务处理。这样可以实现异步消息处理和解耦。
数据同步：如果用程序涉及多个数据源之间的数据同步，可以使用监听器来监听数据变更事件，并在数据变更时触发相应的同步操作。
定时任务：监听定时任务的执行情况，并根据执行结果进行相应的处理。这样可以实现定时任务的监控和管理。