import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor

/**
 * 模擬業(yè)務(wù)對(duì)象實(shí)體類(lèi)
 * @author csdn:孟秋與你
 */
public class MyBizEntity {
    private String name;
    private Integer age;
}

import org.springframework.context.ApplicationEvent;

/**
 * 自定義事件（繼承ApplicationEvent）
 * @author csdn:孟秋與你
 */
public class MyEvent extends ApplicationEvent {


    public MyEvent(Object source) {
        super(source);
    }
    public MyEvent() {
        // java基礎(chǔ)：如果父類(lèi)只有有參構(gòu)造 子類(lèi)需要使用其它構(gòu)造函數(shù) 必須在構(gòu)造函數(shù)第一行調(diào)用super 因?yàn)樽宇?lèi)也是調(diào)用父類(lèi)的構(gòu)造函數(shù)
        super(null);
        // do other
    }
}

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

/**
 * 監(jiān)聽(tīng)事件
 */
@Component
public class MyApplicationListener implements ApplicationListener {
    @Override
    public void onApplicationEvent(ApplicationEvent applicationEvent) {

        // 必須判斷自己要的類(lèi)型  因?yàn)闀?huì)監(jiān)聽(tīng)到所有繼承ApplicationEvent的事件
        if (applicationEvent instanceof MyEvent) {
            Object source = applicationEvent.getSource();
            MyBizEntity bizEntity = (MyBizEntity) source;
            System.out.println(bizEntity.getName() + "：------------name");
        }

    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RequestMapping("/test/listener")
@RestController
public class MainBizController {

    @Autowired
    private ApplicationContext context;

    @GetMapping
    public String test() {
        // do something
        
        // 模擬要傳遞的業(yè)務(wù)對(duì)象
        MyBizEntity bizEntity = new MyBizEntity("name",18);
        MyEvent event = new MyEvent(bizEntity);
        // 上下文 發(fā)布事件
        context.publishEvent(event);
        return "success";
    }
}

@Configuration
public class EventConfig {

    @Bean(name = "applicationEventMulticaster")
    public SimpleApplicationEventMulticaster simpleApplicationEventMulticaster(TaskExecutor taskExecutor) {
        SimpleApplicationEventMulticaster eventMulticaster = new SimpleApplicationEventMulticaster();
        eventMulticaster.setTaskExecutor(taskExecutor);
        return eventMulticaster;
    }
}

@Configuration
public class AsyncInBootConfig {

    /** 核心線程池大小 */
    private int corePoolSize = 20;

    /**
     * 最大可創(chuàng)建的線程數(shù)
     */
    private int maxPoolSize = 50;

    /**
     * 隊(duì)列最大長(zhǎng)度
     */
    private int queueCapacity = 100;

    /**
     * 線程池維護(hù)線程所允許的空閑時(shí)間
     */
    private int keepAliveSeconds = 300;

    @Primary
    @Bean(name = "threadPool")
    /**
     * springboot 線程池方式
     */
    public ThreadPoolTaskExecutor threadPoolTaskExecutor()
    {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(maxPoolSize);
        executor.setCorePoolSize(corePoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setKeepAliveSeconds(keepAliveSeconds);
        // 線程池對(duì)拒絕任務(wù)(無(wú)線程可用)的處理策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }
}