Spring Boot集成流应用启动后自动关闭问题求助

从你的日志和代码来看，问题的核心原因很明确：当禁用Web环境后，Spring Boot默认会在上下文初始化完成后自动退出，因为没有检测到需要保持JVM运行的活跃后台线程。

你的Spring Integration流基于DirectChannel（默认的通道类型）构建，对应的EventDrivenConsumer是同步处理消息的——它不会启动独立的后台线程来持续监听通道。当主线程完成应用启动的所有流程后，JVM中没有剩余的活跃非守护线程，因此会触发上下文关闭，也就是你看到的取消通道订阅、关闭流的操作。

下面提供几种实用的解决方案，你可以根据场景选择：

方案1：阻塞主线程（最简单直接） #

在main方法中使用CountDownLatch阻塞主线程，防止JVM退出，同时可以通过@PreDestroy实现优雅关闭：

@SpringBootApplication
public class Application {

    private static final CountDownLatch latch = new CountDownLatch(1);

    public static void main(String[] args) throws InterruptedException {
        SpringApplication.run(Application.class, args);
        latch.await(); // 阻塞主线程，保持应用运行
    }

    @PreDestroy
    public void onShutdown() {
        latch.countDown(); // 应用关闭时释放锁，允许主线程退出
    }
}

方案2：给Integration流添加轮询器 #

修改你的Integration流，添加轮询器配置，这样Spring Integration会启动一个后台轮询线程，持续监听通道并保持JVM活跃：

@Configuration
@EnableIntegration
public class FirestoreCommandIntegrationFlow {
    @Bean
    public StandardIntegrationFlow registerInboundAdapter() {
        return IntegrationFlows.from("input", 
                        e -> e.poller(Pollers.fixedDelay(1000))) // 添加轮询器，每隔1秒检查一次通道
                .transform("hello"::equals)
                .handle(m -> System.err.println("work"))
                .get();
    }
}

轮询器会复用Spring Boot自动配置的taskScheduler创建后台线程，只要这个线程在运行，JVM就不会退出。

方案3：启用调度并添加保活任务 #

通过@EnableScheduling启用Spring调度功能，添加一个长期休眠的空任务，让调度线程保持运行状态：

@SpringBootApplication
@EnableScheduling
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Scheduled(fixedDelay = Long.MAX_VALUE)
    public void keepApplicationAlive() {
        // 空任务，仅用于维持调度线程活跃，防止JVM退出
    }
}

额外配置建议 #

将你当前使用的旧版配置：

spring.main.web-environment=false

替换为更清晰的新版本配置：

spring.main.web-application-type=NONE

这样可以明确指定应用为非Web类型，避免版本兼容问题。

内容的提问来源于stack exchange，提问作者Luka Špoljarić