在服务器 crashed/shut 关闭后恢复 Async ThreadPoolTaskexecutor

Question

我有一个 Spring rest 控制器，它使用 Spring 的 @Async 方法调用异步方法，return 立即向客户端发送一个 http 202 代码（已接受）。（异步作业很重，可能会导致超时）。所以实际上，在异步任务结束时，我向客户发送了一封电子邮件，告诉他请求的状态。

一切正常，但我在问自己，如果我的 server/jvm 崩溃或关闭，我该怎么办？我的客户会收到 202 代码，并且永远不会收到状态电子邮件。

有没有办法在数据库甚至文件中（实时）同步 ThreadPoolTaskExecutor，让服务器在启动时恢复，而无需我自己管理复杂的规则和演变状态？

这是我的执行器配置

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(4);
        executor.setMaxPoolSize(8);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("asyncTaskExecutor-");
        executor.setAwaitTerminationSeconds(120);
        executor.setKeepAliveSeconds(30);
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }

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

}

启动异步任务的控制器

@RequestMapping(value = "/testAsync", method = RequestMethod.GET)
public void testAsync() throws InterruptedException{
    businessService.doHeavyThings();
}

调用的异步方法：

@Async
public void doHeavyThings() throws InterruptedException {

    LOGGER.error("Start doHeavyThings with configured executor - " + Thread.currentThread().getName() + " at " + new Date());
    Thread.sleep(5000L);
    LOGGER.error("Stop doHeavyThings with configured executor - " + Thread.currentThread().getName() + " at " + new Date());
}

}

感谢

Answer 1

对于 Web 服务器关闭，java Web 应用程序中的应用程序生命周期将通知 ServletContextListener。如果您提供 ServletContextListener 的实现，您可以将 'what is already processed' 逻辑放在 contextDestroyed 方法中。

当 Web 服务器或应用程序再次启动时，侦听器可用于恢复并使用 contextInitialized 方法重新处理作业中未处理的项目。

另一种选择是使用 Spring destruction callbacks 并将逻辑放在此处。

HTH

在服务器 crashed/shut 关闭后恢复 Async ThreadPoolTaskexecutor

Recover an Asynch ThreadPoolTaskexecutor after server crashed/shut down

java

spring

asynchronous

executor

在服务器 crashed/shut 关闭后恢复 Async ThreadPoolTask​​executor

Recover an Asynch ThreadPoolTaskexecutor after server crashed/shut down

java

spring

asynchronous

executor

在服务器 crashed/shut 关闭后恢复 Async ThreadPoolTaskexecutor