spring boot publishEvent 异步执行

在 Spring Boot 中，我们可以通过使用 ApplicationEventPublisher 接口的 publishEvent() 方法来发布事件。默认情况下，该方法是同步执行的，即事件发布后会等待所有监听器处理完事件后才会返回。

如果我们想要异步执行事件处理，可以使用 @Async 注解来实现。具体步骤如下：

1.在配置类上添加 @EnableAsync 注解启用异步执行。

2.在对应的事件监听器方法上添加 @Async 注解。

这样，当事件发布时，对应的监听器方法会在一个新线程中异步执行，从而不会阻塞主线程的执行。

示例代码如下：

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(100);
        executor.setQueueCapacity(10);
        executor.setThreadNamePrefix("AsyncThread-");
        executor.initialize();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

@Component
public class MyEventListener {

    @Async
    @EventListener
    public void handleEvent(MyEvent event) {
        // 处理事件
    }
}

@Component
public class MyEventPublisher {

    @Autowired
    private ApplicationEventPublisher publisher;

    public void publishEvent(MyEvent event) {
        publisher.publishEvent(event);
    }
}

在上面的示例代码中，我们先定义了一个 AsyncConfig 配置类，通过实现 AsyncConfigurer 接口来配置线程池等参数。然后在 MyEventListener 类中，我们使用 @Async 注解来标识 handleEvent() 方法是一个异步方法。最后，在 MyEventPublisher 类中，我们调用 ApplicationEventPublisher 的 publishEvent() 方法来发布事件。

这样，当我们调用 MyEventPublisher 的 publishEvent() 方法时，MyEventListener 中对应的 handleEvent() 方法就会在一个新线程中异步执行，不会阻塞主线程的执行。