FTP 出站通道适配器不传输相同的文件

Question

我的应用程序中有以下配置。我正在将文件写入 ftp 文件夹并从 ftp 位置读取。

1. 我想从ftp位置获取文件并将其保存在动态决定的目录中。这是通过使用两个链式通道适配器完成的。ftp nbound 通道适配器选取文件，将其放入本地目录中，然后文件入站通道适配器选取文件并将其放入最终目标。我需要为此过程过滤旧文件。FTP 入站通道适配器自定义筛选器在筛选方法中为我提供了 FTPFile 对象。此对象提供上次修改日期，而不是文件放入筛选器的日期。由于此限制，我也不得不使用文件入站通道适配器。
2. 由于我不知道如何动态生成源目录，因此我正在使用纯java代码将所需的文件复制到本地目录，ftp出站通道从该目录拾取并将其放在ftp位置。

这是配置：

    <bean id="fileNameGenerator" class="com.polling.util.FileNameGenerator"/>   
    <int-file:inbound-channel-adapter id="filesIn" directory="file:${paths.root}" channel="abc" filter="compositeFilter"  >
        <int:poller id="poller" fixed-rate="500" />
    </int-file:inbound-channel-adapter>
    <int:channel id="abc"/>
    <bean id="compositeFilter" class="org.springframework.integration.file.filters.CompositeFileListFilter">
        <constructor-arg>
            <list>
                <!-- Ensures that the file is whole before processing it -->
                <bean class="com.polling.util.CustomFileFilter"/>
                <!-- Ensures files are picked up only once from the directory -->
                <bean class="org.springframework.integration.file.filters.AcceptOnceFileListFilter" />
            </list>
        </constructor-arg>
    </bean> 
    <int-file:outbound-channel-adapter channel="abc" id="filesOut"
        directory-expression="@outPathBean.getPath()"
        delete-source-files="true" filename-generator="fileNameGenerator" >
        <int-file:request-handler-advice-chain>
         <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="onSuccessExpression" value="payload.delete()" />
          </bean>
    </int-file:request-handler-advice-chain>
        </int-file:outbound-channel-adapter>
   <bean id="ftpClientFactory"
    class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
    <property name="host" value="${ftp.ip}"/>
    <property name="port" value="${ftp.port}"/>
    <property name="username" value="${ftp.username}"/>
    <property name="password" value="${ftp.password}"/>
    <property name="clientMode" value="0"/>
    <property name="fileType" value="2"/>
    <property name="bufferSize" value="100000"/>
</bean>
       <int:channel id="ftpChannel"/> 
<int-ftp:inbound-channel-adapter id="ftpInbound"
    channel="ftpChannel"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    local-directory="file:${paths.root}"
    delete-remote-files="true"
    temporary-file-suffix=".writing"
    remote-directory="${file.ftpfolder}"
    filter="compositeFilterRemote"
     preserve-timestamp="true"
     auto-startup="true">
    <int:poller fixed-rate="1000"/>
</int-ftp:inbound-channel-adapter>
<int-ftp:outbound-channel-adapter id="ftpOutbound"
    channel="ftpChannel"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    remote-file-separator="/"
    auto-create-directory="true"
    remote-directory="${file.ftpfolder}" 
    use-temporary-file-name="true"
     temporary-file-suffix=".writing">
    <int-ftp:request-handler-advice-chain>
         <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="onSuccessExpression" value="payload.delete()" />
          </bean>
    </int-ftp:request-handler-advice-chain>
  </int-ftp:outbound-channel-adapter>

使用 @Gary 答案中的建议，我在 ftp 入站通道过滤器属性中添加了一个自定义过滤器。这将检查文件名的正则表达式，如下所示

@Override
public List<FTPFile> filterFiles(FTPFile[] files)
{
    List<FTPFile> ret = new ArrayList<FTPFile>();
    Pattern pattern = Pattern.compile("~.*?~");
    Matcher matcher;
    for (FTPFile file : files) 
    {
        matcher = pattern.matcher(file.getName());
        if(matcher.matches())
        {
            ret.add(file);
        }
    }
    return ret;
}

因此，~something~文件被拾取并发送到最终目的地。

我的问题是：

1. 从最终目的地发送到ftp位置的文件具有不同的模式，我不知道该放在哪里(something@something@something(。
2. 有时，ftp文件夹可能会被篡改并删除文件。如果是这样，我希望 spring 重写文件。相同的文件再次写入<ftp:inbound-channel-adapter>中提到的本地目录中。但是 ftp 出站通道适配器不会拾取文件并将其放在 ftp 位置。根据@Gary的回答，我需要为入站通道适配器配置过滤器，以避免接受一次过滤器。
3. 这是否意味着我应该创建两个单独的通道和两个不同的流，一个用于返回，一个用于前？这是满足我要求的正确方法吗？

感谢您的帮助

编辑：：

我尝试实施两个不同的过程。一个使用模式 ~something~ 从 remotedir 获取文件，另一个从具有模式 something@something@something 的本地目录中获取文件。尽管基本功能正常工作，但如果删除远程目录中的文件，我将无法再次执行第二个流。正如加里所说，需要设置"全部接受"过滤器，但我不知道如何使用自定义过滤器和"全部接受"过滤器。

任何建议不胜感激

Answer 1

默认情况下

配置AcceptOnceFileListFilter。使用入站适配器上的local-filter使用其他过滤器(如AcceptAllFileListFilter (。请参阅文档。

也就是说，您的应用程序看起来很奇怪 - 您似乎正在获取文件并简单地将它们发回。

Answer 2

这就是有效的

我继续这两个流，并更改了我的 bean 配置以包含全部接受过滤器。

这是现在的配置。

      <bean id="fileNameGenerator" class="com.polling.util.FileNameGenerator"/>   
    <int-file:inbound-channel-adapter id="filesIn" directory="file:${paths.root}" channel="abc" filter="compositeFilter"  >
        <int:poller id="poller" fixed-rate="500" />
    </int-file:inbound-channel-adapter>
    <int:channel id="abc"/>
    <bean id="compositeFilter" class="org.springframework.integration.file.filters.CompositeFileListFilter">
        <constructor-arg>
            <list>
                <!-- Ensures that the file is whole before processing it -->
                <bean class="com.polling.util.CustomFileFilter"/>
                <!-- Ensures files are picked up only once from the directory -->
                <bean class="org.springframework.integration.file.filters.AcceptOnceFileListFilter" />
            </list>
        </constructor-arg>
    </bean> 
    <int-file:outbound-channel-adapter channel="abc" id="filesOut"
        directory-expression="@outPathBean.getPath()"
        delete-source-files="true" filename-generator="fileNameGenerator" >
        <int-file:request-handler-advice-chain>
         <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="onSuccessExpression" value="payload.delete()" />
          </bean>
    </int-file:request-handler-advice-chain>
        </int-file:outbound-channel-adapter>
   <bean id="ftpClientFactory"
    class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
    <property name="host" value="${ftp.ip}"/>
    <property name="port" value="${ftp.port}"/>
    <property name="username" value="${ftp.username}"/>
    <property name="password" value="${ftp.password}"/>
    <property name="clientMode" value="0"/>
    <property name="fileType" value="2"/>
    <property name="bufferSize" value="100000"/>
</bean>
     <int:channel id="ftpChannel1"/> 
 <int-ftp:inbound-channel-adapter id="ftpInbound1"
    channel="ftpChannel1"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    local-directory="file:${paths.root}"
    delete-remote-files="true"
    temporary-file-suffix=".writing"
    remote-directory="."
    preserve-timestamp="true"
     auto-startup="true" 
     local-filter="compositeFilterLocal">
    <int:poller fixed-rate="1000"/>
</int-ftp:inbound-channel-adapter>
  <int-ftp:outbound-channel-adapter id="ftpOutbound1"
    channel="ftpChannel1"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    remote-file-separator="/"
    auto-create-directory="true"
     remote-directory="${file.ftpfolder}" 
    use-temporary-file-name="true"
     temporary-file-suffix=".writing">
    <int-ftp:request-handler-advice-chain>
         <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="onSuccessExpression" value="payload.delete()" />
          </bean>
    </int-ftp:request-handler-advice-chain>
</int-ftp:outbound-channel-adapter>

   <int:channel id="ftpChannel"/> 
<int-ftp:inbound-channel-adapter id="ftpInbound"
    channel="ftpChannel"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    local-directory="file:${paths.root}"
    delete-remote-files="true"
    temporary-file-suffix=".writing"
    remote-directory="${file.ftpfolder}"
    filter="compositeFilterRemote"
     preserve-timestamp="true"
     auto-startup="true">
    <int:poller fixed-rate="1000"/>
</int-ftp:inbound-channel-adapter>
<int-ftp:outbound-channel-adapter id="ftpOutbound"
    channel="ftpChannel"
    session-factory="ftpClientFactory"
    charset="UTF-8"
    remote-file-separator="/"
    auto-create-directory="true"
    remote-directory="${file.ftpfolder}" 
    use-temporary-file-name="true"
     temporary-file-suffix=".writing">
    <int-ftp:request-handler-advice-chain>
         <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="onSuccessExpression" value="payload.delete()" />
          </bean>
    </int-ftp:request-handler-advice-chain>
  </int-ftp:outbound-channel-adapter>
<bean id="acceptAllFilter" class="org.springframework.integration.file.filters.AcceptAllFileListFilter" />
 <bean id="compositeFilterLocal" class="org.springframework.integration.file.filters.CompositeFileListFilter">
        <constructor-arg>
            <list>
                <!-- Ensures that the file is whole before processing it -->
                <bean class="com.polling.util.CustomFileFilterLocal"/>
                <!-- Ensures files are picked up only once from the directory -->
                <bean class="org.springframework.integration.file.filters.AcceptAllFileListFilter" />
            </list>
        </constructor-arg>
    </bean>
    <bean id="compositeFilterRemote" class="org.springframework.integration.file.filters.CompositeFileListFilter">
        <constructor-arg>
            <list>
                <!-- Ensures that the file is whole before processing it -->
                <bean class="com.polling.util.CustomFileFilterRemote"/>
                <!-- Ensures files are picked up only once from the directory -->
                <bean class="org.springframework.integration.file.filters.AcceptOnceFileListFilter" />
            </list>
        </constructor-arg>
    </bean>

如果有人有任何建议来提高效率，请告诉我。到目前为止，我可以反复下载文件。所以我继续这个..

谢谢