Spring Batch Worker执行成功后抛出ApplicationContext已关闭异常求助
这个异常的核心原因是Spring Cloud Task在Spring Batch任务执行完成后提前关闭了应用上下文,但Spring Boot的生命周期流程还在继续触发ApplicationReadyEvent事件,此时上下文已关闭,尝试获取Bean就会抛出IllegalStateException。
针对你使用的Spring Boot 2.7.5、spring-cloud-task-core 2.4.4、Spring-Batch-Core 4.3.7版本组合,提供以下几种可行的解决方式:
1. 调整Spring Cloud Task的上下文关闭时机
在配置文件(application.yml或application.properties)中添加配置,禁用Spring Cloud Task自动关闭上下文的逻辑,交由Spring Boot自身生命周期管理:
spring: cloud: task: closecontext_enabled: false
如果使用properties格式:
spring.cloud.task.closecontext_enabled=false
2. 自定义Spring Cloud Task生命周期处理器
如果需要更精细的控制,可以自定义TaskLifecycleListener,确保所有Spring Boot生命周期事件完成后再关闭上下文:
import org.springframework.cloud.task.listener.TaskLifecycleListener; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationListener; import org.springframework.boot.context.event.ApplicationReadyEvent; public class CustomTaskLifecycleListener extends TaskLifecycleListener implements ApplicationListener<ApplicationReadyEvent> { private boolean readyEventReceived = false; public CustomTaskLifecycleListener(ApplicationContext applicationContext) { super(applicationContext); } @Override public void onApplicationEvent(ApplicationReadyEvent event) { readyEventReceived = true; if (super.isCloseContextEnabled()) { super.closeApplicationContext(); } } @Override protected void closeApplicationContext() { if (readyEventReceived) { super.closeApplicationContext(); } } }
然后在配置类中注册这个自定义监听器:
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.ApplicationContext; @Configuration public class TaskConfig { @Bean public CustomTaskLifecycleListener customTaskLifecycleListener(ApplicationContext applicationContext) { return new CustomTaskLifecycleListener(applicationContext); } }
3. 规范Batch任务启动方式
确保Worker节点通过Spring Cloud Task的标准方式启动,不要手动调用上下文关闭方法。主类示例如下:
@SpringBootApplication @EnableTask @EnableBatchProcessing public class ExampleBatchMainA { public static void main(String[] args) { SpringApplication.run(ExampleBatchMainA.class, args); } }
避免在任务执行完成后手动调用context.close(),这会打乱Spring Boot与Spring Cloud Task的协同逻辑。
应用上述配置后重新运行Worker节点,任务执行完成后应正常退出,不再抛出ApplicationContext has been closed already异常。可通过日志确认任务状态为COMPLETED,且无ERROR级别的异常日志输出。
内容的提问来源于stack exchange,提问作者Ashish Sharma

