WatchEventType.DELETE事件未触发，无法跟踪文件删除执行逻辑

我来帮你排查下这个文件删除事件没触发的问题～你遇到的情况大概率是配置环节的细节没到位，下面是几个关键的排查点和修复方案：

1. 确保显式配置了DELETE监听事件 #

默认情况下，FileReadingMessageSource只会监听CREATE和MODIFIED事件，必须手动添加DELETE到监听列表。不管你是自定义FileReadingMessageSourceBean，还是用Files.inboundAdapter，都要明确指定事件类型：

方式一：自定义FileReadingMessageSource #

@Bean
public FileReadingMessageSource fileReadingMessageSource() {
    FileReadingMessageSource source = new FileReadingMessageSource();
    source.setDirectory(new File("/你的目标文件夹路径"));
    // 关键：包含DELETE事件
    source.setWatchEventTypes(EnumSet.of(
        FileReadingMessageSource.WatchEventType.CREATE,
        FileReadingMessageSource.WatchEventType.MODIFY,
        FileReadingMessageSource.WatchEventType.DELETE
    ));
    return source;
}

// 集成流中使用自定义的source
@Bean
public IntegrationFlow integrationFlow(FileToMovieTransformer fileToMovieTransformer) {
    return IntegrationFlow.from(fileReadingMessageSource(), 
            e -> e.poller(Pollers.fixedDelay(1000))) // 必须配置轮询器，确保事件被轮询处理
        .transform(fileToMovieTransformer)
        .handle(message -> {
            // 从消息头获取事件类型
            WatchEvent.Kind<?> eventType = (WatchEvent.Kind<?>) message.getHeaders().get(FileHeaders.WATCH_EVENT_TYPE);
            File deletedFile = (File) message.getPayload();
            
            if (StandardWatchEventKinds.ENTRY_DELETE.equals(eventType)) {
                // 这里执行你的业务逻辑：提取文件ID、更新实体
                String targetId = extractIdFromFileName(deletedFile.getName());
                updateEntityById(targetId);
            }
        })
        .get();
}

方式二：直接用Files.inboundAdapter配置 #

@Bean
public IntegrationFlow integrationFlow(FileToMovieTransformer fileToMovieTransformer) {
    return IntegrationFlow.from(Files.inboundAdapter(new File("/你的目标文件夹路径"))
            .watchEventTypes(
                FileReadingMessageSource.WatchEventType.CREATE,
                FileReadingMessageSource.WatchEventType.MODIFY,
                FileReadingMessageSource.WatchEventType.DELETE),
            e -> e.poller(Pollers.fixedDelay(1000))) // 轮询器是必须的
        .transform(fileToMovieTransformer)
        .handle(...) // 处理DELETE事件的逻辑
        .get();
}

2. 检查轮询器配置 #

如果没有给集成流配置轮询器，FileReadingMessageSource可能无法正常触发事件处理。上面的代码里已经包含了Pollers.fixedDelay(1000)，这个配置确保系统每隔1秒检查一次文件事件，你可以根据业务调整间隔。

3. 注意DELETE事件的消息特性 #

当DELETE事件触发时，消息的payload是被删除的File对象，但此时文件已经不存在，所以不要调用file.exists()这类方法。要通过FileHeaders.WATCH_EVENT_TYPE消息头来判断事件类型，这个头的取值是StandardWatchEventKinds枚举（比如ENTRY_DELETE）。

4. 排查文件系统兼容性 #

Spring Integration的文件监听基于Java NIO的WatchService，部分文件系统（比如旧版本Windows、网络共享驱动器）对DELETE事件的支持可能有限。建议先在本地文件夹测试，确认功能正常后再迁移到目标环境。

5. 开启调试日志排查 #

如果还是没触发，可以开启Spring Integration的调试日志，查看事件监听的详细过程：

# application.properties
logging.level.org.springframework.integration=DEBUG
logging.level.org.springframework.integration.file=TRACE

日志里会显示是否监听到了DELETE事件，以及是否有处理环节的异常。

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