Spring Integration：修改FileInboundAdapter实现优先读旧文件并手动启动

要实现你的需求，我们需要对原有的FileInboundAdapter配置做两处关键调整：关闭自动启动以便后续手动触发，添加文件排序规则优先处理最旧文件。下面是完整的配置代码和详细说明：

@Bean
public IntegrationFlow fileInboundAdapterFlow() {
    return IntegrationFlows.from(
            Files.inboundAdapter(new File("tmp"))
                    .preventDuplicates(true)
                    // 关键：按文件最后修改时间升序排序，最旧的文件优先被读取
                    .sort(Comparator.comparingLong(File::lastModified)),
            e -> e.id("fileInboundAdapterEndpoint") // 给端点设置唯一ID，方便后续获取启动
                    .autoStartup(false) // 关闭自动启动，改为手动触发
                    .poller(Pollers.fixedDelay(1000, TimeUnit.MILLISECONDS))
    )
    .channel("fileInboundAdapterResultChannel")
    .get();
}

接下来是两种常用的手动启动适配器的方式：

方式1：通过端点ID直接启动 #

在需要触发启动的业务类中，注入IntegrationFlowContext来获取适配器实例并启动：

@Autowired
private IntegrationFlowContext flowContext;

// 手动启动适配器的方法
public void triggerFileAdapterStart() {
    IntegrationFlow targetFlow = flowContext.getFlow("fileInboundAdapterFlow");
    if (targetFlow != null) {
        MessageSourcePollingConsumer consumer = targetFlow.getComponentRegistration("fileInboundAdapterEndpoint")
                .getObject();
        if (!consumer.isRunning()) {
            consumer.start();
            System.out.println("文件适配器已手动启动，开始轮询读取文件");
        }
    }
}

方式2：通过生命周期管理类控制 #

如果需要更灵活的启停控制，可以定义一个专门的生命周期管理bean：

@Component
public class FileAdapterManager implements SmartLifecycle {

    private boolean isRunning = false;
    @Autowired
    private MessageSourcePollingConsumer fileInboundAdapterEndpoint;

    @Override
    public void start() {
        if (!isRunning) {
            fileInboundAdapterEndpoint.start();
            isRunning = true;
            System.out.println("文件适配器已启动");
        }
    }

    @Override
    public void stop() {
        if (isRunning) {
            fileInboundAdapterEndpoint.stop();
            isRunning = false;
            System.out.println("文件适配器已停止");
        }
    }

    @Override
    public boolean isRunning() {
        return isRunning;
    }

    // 以下为默认实现，保持即可
    @Override
    public boolean isAutoStartup() {
        return false;
    }

    @Override
    public void stop(Runnable callback) {
        stop();
        callback.run();
    }

    @Override
    public int getPhase() {
        return 0;
    }
}

关键改动说明： #

• 优先读取最旧文件：通过.sort(Comparator.comparingLong(File::lastModified))配置排序规则，让适配器轮询时优先处理最早创建/修改的文件。
• 手动启动控制：将autoStartup设为false，同时给端点设置明确ID，确保后续能精准获取到适配器实例，调用start()方法触发启动。

这样配置后，你的文件适配器不会在应用启动时自动运行，只有当你调用手动启动方法后才会开始轮询，并且始终优先处理目录中最旧的文件。

内容的提问来源于stack exchange，提问作者Ahmed Ali