public class MyEvent extends ApplicationEvent {
    
    public MyEvent(Object source) {
        super(source);
    }
}

@Autowired
    private ApplicationEventPublisher applicationEventPublisher;
    public void enent(){
        //業(yè)務(wù)代碼
        //發(fā)送事件
        applicationEventPublisher.publishEvent(new MyEvent(this));
    }

@Component
public class MyLin implements ApplicationListener<MyEvent> {
    @Override
    public void onApplicationEvent(MyEvent event) {
        System.out.println("監(jiān)聽到事件");
    }
}

@Component
public class MyLin2 {
    //注意方法的參數(shù)類型是監(jiān)聽的類型
    @EventListener
    public void onApplicationEvent(MyEvent event) {
        System.out.println("監(jiān)聽到事件2");
    }
}

    @Bean
    public SimpleApplicationEventMulticaster applicationEventMulticaster(ThreadPoolExecutor executor){
        SimpleApplicationEventMulticaster multicaster = new SimpleApplicationEventMulticaster();
        multicaster.setTaskExecutor(executor);
        return multicaster;
    }

@Component
public class AsyncEventListener {
    
    private static final Logger logger = LoggerFactory.getLogger(AsyncEventListener.class);
    
    /**
     * 異步處理事件 - 不會(huì)阻塞主線程
     */
    @Async("taskExecutor")  // 指定使用配置的線程池
    @EventListener
    public void handleAsyncEvent(MyEvent event) {
        logger.info("異步事件處理開始 - 事件: {}", event.getMessage());
        logger.info("當(dāng)前線程: {}", Thread.currentThread().getName());
        
        try {
            // 模擬耗時(shí)操作
            Thread.sleep(3000);
            logger.info("異步事件處理完成: {}", event.getMessage());
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            logger.error("異步事件處理被中斷", e);
        }
    }
    
    /**
     * 同步處理事件 - 會(huì)阻塞主線程
     */
    @EventListener
    public void handleSyncEvent(MyEvent event) {
        logger.info("同步事件處理開始 - 事件: {}", event.getMessage());
        logger.info("當(dāng)前線程: {}", Thread.currentThread().getName());
        
        try {
            // 模擬耗時(shí)操作
            Thread.sleep(2000);
            logger.info("同步事件處理完成: {}", event.getMessage());
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            logger.error("同步事件處理被中斷", e);
        }
    }
}

@SpringBootTest
public class EventTest {
    
    @Autowired
    private BusinessService businessService;
    
    @Test
    public void testAsyncEvent() {
        System.out.println("測(cè)試開始 - 主線程: " + Thread.currentThread().getName());
        
        long startTime = System.currentTimeMillis();
        businessService.doBusiness();
        long endTime = System.currentTimeMillis();
        
        System.out.println("業(yè)務(wù)方法執(zhí)行時(shí)間: " + (endTime - startTime) + "ms");
        
        // 給異步事件處理留出時(shí)間
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}