Spring Integration实现目录无文件时优雅停止应用的方案咨询

嗨，我完全get到你的需求啦——这个每天启动一次的文件轮询应用，就是想在目录里彻底没文件可处理的时候自动停下来，别白白占用资源对吧？结合你贴出来的Spring Integration配置代码，我给你整理一个很实用的实现方案：

核心思路 #

我们可以给文件轮询的逻辑加一个空轮询监控的增强器（Advice），每次轮询后检查有没有获取到文件：如果连续几次都没拿到文件，就触发Spring应用上下文的优雅关闭，这样应用就会自动停止啦。

具体代码修改步骤 #

1. 自定义空轮询监控增强器

先写一个自定义的Advice类，用来监控轮询结果，触发关闭逻辑：

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.integration.aop.AbstractMessageSourceAdvice;
import org.springframework.integration.core.MessageSource;
import org.springframework.stereotype.Component;
import org.springframework.boot.SpringApplication;

@Component("shutdownAdvice")
public class ShutdownOnEmptyPollAdvice extends AbstractMessageSourceAdvice {

    private static final Logger LOGGER = LoggerFactory.getLogger(ShutdownOnEmptyPollAdvice.class);
    
    private final ApplicationContext applicationContext;
    private int emptyPollCounter = 0;
    
    // 可配置：连续多少次空轮询后触发关闭，这里默认设为2次，避免临时无文件的误判
    @Value("${app.shutdown.empty-poll-threshold:2}")
    private int emptyPollThreshold;

    public ShutdownOnEmptyPollAdvice(ApplicationContext applicationContext) {
        this.applicationContext = applicationContext;
    }

    @Override
    public Object afterReceive(Object result, MessageSource<?> source) {
        if (result == null) {
            emptyPollCounter++;
            LOGGER.info("第{}次空轮询，未发现待处理文件", emptyPollCounter);
            if (emptyPollCounter >= emptyPollThreshold) {
                LOGGER.info("已连续{}次空轮询，准备优雅关闭应用", emptyPollThreshold);
                // 触发Spring应用优雅关闭
                SpringApplication.exit(applicationContext, () -> 0);
            }
        } else {
            // 有文件被正常获取，重置空轮询计数器
            emptyPollCounter = 0;
        }
        return result;
    }
}

2. 修改文件入站通道适配器的轮询配置

把上面的Advice关联到你的@InboundChannelAdapter的Poller上，让每次轮询都走这个监控逻辑：

@Bean
@InboundChannelAdapter(value = "fileInboundChannel", 
                       poller = @Poller(fixedDelay = "1000", advice = "shutdownAdvice")) // 这里加上advice配置
MessageSource<File> fileReadingMessageSource(DirectoryScanner directoryScanner, CreConfiguration creConfiguration) {
    FileReadingMessageSource source = new FileReadingMessageSource();
    source.setDirectory(new File(creConfiguration.getInputDir()));
    source.setScanner(directoryScanner);
    return source;
}

额外说明 #

• 为什么要设置连续空轮询阈值？比如设为2次，是为了避免因为文件正在被写入（还没完全落地到目录）导致的单次空轮询误判，确保确实没有待处理文件了才关闭。
• 你的DirectoryScanner已经用了AcceptOnceFileListFilter，会自动跳过已经处理过的文件，所以不用担心重复处理的问题，当所有文件都处理完后，后续轮询就会返回null，触发关闭逻辑。
• SpringApplication.exit()方法会触发Spring应用的优雅关闭流程，所有的Bean都会正常销毁，资源也会被释放，完全符合你的“避免资源浪费”的需求。

备注：内容来源于stack exchange，提问作者Ares