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