相同的文件在spring-ftp中被一次又一次地提取，但名称不同

Question

我有一个Spring输入通道，定义如下

<file:inbound-channel-adapter prevent-duplicates="false" id="inpChannel" directory="file:/Users/abhisheksingh/req" auto-startup="true">
        <int:poller id="poller" fixed-delay="1000" />
</file:inbound-channel-adapter>

<int:service-activator input-channel="inpChannel" ref="inpHandler" />

文件名示例为test.sqq。SQQ是客户端用于将文件放在FTP中的文件格式。但是，我看到spring ftp适配器一次又一次地使用不同的文件名获取相同的文件。所以第一次是test.sqq。然后下一次是test.sqq-20170204.pqq，然后下一次是test.sqq-20170204.pqq.20170304.pqq。这种情况还在继续。我在我的一端有一个过滤器，它检查已经处理的文件的名称。但是，由于每次轮询的文件名不同，所有这些文件都被选中进行处理。

这是我的ftp适配器-

<int-ftp:inbound-channel-adapter id="sqqFtpInbound"
    channel="ftpChannel"
    session-factory="sqqFtpClientFactory"
    auto-create-local-directory="true"
    delete-remote-files="false"
    local-filter="acceptAllFileListFilter"
    local-directory="file:/Users/abhisheksingh/ddrive/everge_ws/sqqReq" auto-startup="true" >
    <int:poller id="poller" fixed-delay="1000" />
</int-ftp:inbound-channel-adapter>

我不明白为什么同一个文件被一次又一次地拿起。我会感谢你的帮助！

这是我的文件列表筛选器代码。

public class TestFileListFilter<F> extends AbstractFileListFilter<F> {

    private static final Logger log = LoggerFactory.getLogger(EvergeFileListFilter.class);

    @Override
    protected boolean accept(F file) {
        File f = (File) file;
        if(f.getAbsolutePath().contains(".PQQ")) {

            String newDir = "/Users/abhisheksingh/ddrive/sample/pqqReq/";

            String archiveLocation = "/Users/abhisheksingh/ddrive/sample/pqqArchive/";
            String fullName = archiveLocation + f.getName();
            log.info("Check if the file has already been processed " + fullName);

            File fl = new File(fullName);
            final File dir = new File(archiveLocation);
            for (final File child : dir.listFiles()) {

                String archiveName = FilenameUtils.getBaseName(child.getName());
                String inputName = FilenameUtils.getBaseName(fl.getName());
                log.info("Archive file name is " + archiveName);
                log.info("Input file name is " + inputName);
                if(inputName.contains(archiveName)) {
                    log.info("The file is already processed "+inputName);
                }

            }

            if(fl.exists()) {
                log.error("PQQ file has already been processed.");
                removeFile(f);
                return false;
            }else{
                log.info("PQQ File received " + f.getAbsolutePath());
            }
            moveFile(f, newDir);
            return true;
        }
    }

Answer 1

我认为您的自定义local-filter存在一些漏洞，可以依赖不存在的事实来等待来自远程存储的唯一文件。

您应该确保该功能，因为它在默认情况下是不切换的。

为此，考虑将filter选项添加到 作为对acceptoncefilelistfilter或ftpppersistentacceptoncefilelistfilter的引用。

我们在这件事上有一个JIRA。

请确认这正是您的问题，我们可能会修改该票的优先级，并将很快修复它。