在 Spring 集成中将过滤器应用于入站 ftp 适配器的顺序

Question

我正在使用 spring 集成入站通道适配器，如下所示

inboundAdapter(csf).preserveTimestamp(true)//
              .remoteDirectory(feed.getRemoteDirectory())//
              .regexFilter(feed.getRegexFilter())// regex expression
              .filter(ftpRemoteFileFilter)// remote filter
              .deleteRemoteFiles(feed.getDeleteRemoteF

所以我使用了远程过滤器和开箱即用的正则表达式过滤器。我想知道应用正则表达式过滤器和远程过滤器的顺序是什么。从最初的分析看起来像正则表达式过滤器是第一位的，有人可以告诉我这个决定是在哪里做出的，这样我就可以确定了。

如果无法知道唯一的其他选择是使用 CompositeFileListFilter.

Answer 1

您要查找的代码位于 FtpInboundChannelAdapterSpec 中，如下所示：

@Override
public FtpInboundChannelAdapterSpec regexFilter(String regex) {
    return filter(composeFilters(new FtpRegexPatternFileListFilter(regex)));
}

@SuppressWarnings("unchecked")
private CompositeFileListFilter<FTPFile> composeFilters(FileListFilter<FTPFile> fileListFilter) {
    CompositeFileListFilter<FTPFile> compositeFileListFilter = new CompositeFileListFilter<>();
    compositeFileListFilter.addFilters(fileListFilter,
            new FtpPersistentAcceptOnceFileListFilter(new SimpleMetadataStore(), "ftpMessageSource"));
    return compositeFileListFilter;
}

所以，正如您在声明 regexFilter 时看到的那样，它与 FtpPersistentAcceptOnceFileListFilter 一起组成了 CompositeFileListFilter，其中 regexFilter 绝对是第一个。首先是因为FtpPersistentAcceptOnceFileListFilter 是持久性，这对于存储之后可能与正则表达式不匹配的文件并不好。

如果你需要一些更复杂的逻辑，你真的应该去CompositeFileListFilter 方式并且只通过filter() 选项注入它。我的意思是你必须将你的regexpFilter 合并到CompositeFileListFilter 而不是regexFilter()。

注意：在 5.0 中将 Java DSL 移入 Core 后，.filter() 选项如下所示：

public S filter(FileListFilter<F> filter) {
    this.synchronizer.setFilter(filter);
    return _this();
}

它会覆盖任何以前提供的过滤器，包括regexp。这样做是为了避免混淆 .filter() 链，而支持外部配置的 CompositeFileListFilter 或 ChainFileListFilter。