使用没有轮询器的 Spring Integration FTP 客户端

Question

希望有人能帮我解决这个问题...

我们有以下用例：根据请求，连接到远程 FTP 服务器，尝试最多 3 次下载文件（其名称和路径由调用者提供）。断开与远程 FTP 服务器的连接。等待下一个请求。

由于 Spring 框架不提供 FTP 客户端解决方案，我们为此使用 Spring Integration。我们遇到的问题是 FTP 入站通道适配器需要设置轮询器，它会不断地轮询远程服务器。在我们的例子中，我们只需要轮询 3 次然后断开连接。然后等待下一个请求等等。

有没有办法通过 Spring Integration 做到这一点？我们还有哪些其他选择？

Answer 1

Spring Integration FTP 模块为您的案例提供了<int-ftp:outbound-gateway> 和GET 命令。另外，在<request-handler-advice-chain> 和RequestHandlerRetryAdvice 面前，还有一个开箱即用的retry 支持。

请参阅 Spring Integration 参考手册了解更多信息。

Answer 2

感谢 Artem 为我指明了正确的方向。发现这个link 很有帮助。

这是从从 FTP 服务器下载 a.txt 文件的链接中获取的修改后的 FtpOutboundGatewaySample-context.xml。请注意，出于性能原因，它不执行 LS 和 RM 命令（仅 MGET）：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:context="http://www.springframework.org/schema/context"
        xmlns:int="http://www.springframework.org/schema/integration"
        xmlns:int-ftp="http://www.springframework.org/schema/integration/ftp"
        xsi:schemaLocation="http://www.springframework.org/schema/integration/ftp http://www.springframework.org/schema/integration/ftp/spring-integration-ftp.xsd
            http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
        <context:property-placeholder location="classpath:user.properties"/>
        <int:gateway id="gw" service-interface="org.springframework.integration.samples.ftp.ToFtpFlowGateway"
            default-request-channel="inbound"/>
        <bean id="ftpSessionFactory"
        class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
            <property name="host" value="${host}"/>
            <property name="port" value="${availableServerPort}"/>
            <property name="username" value="${userid}"/>
            <property name="password" value="${password}"/>
        </bean>
        <int-ftp:outbound-gateway id="gatewayGET"
            local-directory="#{ T(org.springframework.integration.samples.ftp.TestSuite).LOCAL_FTP_TEMP_DIR}/gatewayGET"
            session-factory="ftpSessionFactory"
            request-channel="inbound"       
            command="mget"
            command-options="-P"
            expression="'a.txt'"/>
    </beans>