提供动态目录和文件名到FTP站网关(Dynamically provide directory an

我们有一个FTP客户端的要求下载其名称和目录在运行时提供的文件。 因此，FTP客户端可能会被要求下载从foo1 / foo2的目录路径FILE1.TXT在远程服务器上。

我们确实有使用Spring集成FTP站网关的解决方案。 有了这个解决方案，使其动态：

1. 创建用于网关的ApplicationContext
2. 该网关属性开始使用的文件名和远程目录路径设置
3. 文件下载
4. 在ApplicationContext被关闭。

我们现在不是高兴的是，ApplicationContext的创建和关闭每一个这显然会影响性能的时间。 有没有办法来动态传递文件名和目录路径到网关无需重新加载每次应用项目语境？

对你的帮助表示感谢。

这里的主代码和配置：

package com.cvc.ipcdservice.ftp;

import java.util.List;
import java.util.Properties;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.core.env.PropertiesPropertySource;
import org.springframework.core.env.StandardEnvironment;

public class DynamicFtpClient {
    private static final Logger LOGGER = LoggerFactory
            .getLogger(DynamicFtpClient.class);

    public void download(final FtpMetaData ftpMetaData) {
        final ConfigurableApplicationContext ctx = new ClassPathXmlApplicationContext(
                new String[] { "/META-INF/spring/integration/FtpOutboundGateway-context.xml" },
                false);

        setEnvironment(ctx, ftpMetaData);
        ctx.refresh();

        final ToFtpFlowGateway toFtpFlow = ctx.getBean(ToFtpFlowGateway.class);

        // execute the flow (mget to download from FTP server)
        final List<Boolean> downloadResults = toFtpFlow.mGetFiles("/");

        LOGGER.info(
                "Completed downloading from remote FTP server. ftpMetaData:{}, downloadResults.size:{} ",
                ftpMetaData, downloadResults.size());

        ctx.close();
    }

    /**
     * Populate {@code ConfigurableApplicationContext} with Provider-specific
     * FTP properties.
     *
     * @param ctx
     * @param customer
     */
    private void setEnvironment(final ConfigurableApplicationContext ctx,
            final FtpMetaData ftpMetaData) {
        final StandardEnvironment env = new StandardEnvironment();
        final Properties props = new Properties();
        // populate properties for customer
        props.setProperty("ftp.host", ftpMetaData.getHost());
        props.setProperty("ftp.port", ftpMetaData.getPort());
        props.setProperty("ftp.userid", ftpMetaData.getUserName());
        props.setProperty("ftp.password", ftpMetaData.getPassword());
        // props.setProperty("remote.directory", "/");
        // WARNING: the file name pattern has to be surrounded by single-quotes
        props.setProperty("ftp.remote.filename.pattern",
                "'" + ftpMetaData.getFileNamePattern() + "'");
        props.setProperty("ftp.local.dir", ftpMetaData.getLocalDirectory());

        final PropertiesPropertySource pps = new PropertiesPropertySource(
                "ftpprops", props);
        env.getPropertySources().addLast(pps);
        ctx.setEnvironment(env);
    }
}



 <?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/>

    <int:gateway id="gw" service-interface="com.cvc.ipcdservice.ftp.ToFtpFlowGateway"
        default-request-channel="inbound"/>

    <bean id="ftpSessionFactory"
        class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
        <property name="host" value="${ftp.host}"/>
        <property name="port" value="${ftp.port}"/>
        <property name="username" value="${ftp.userid}"/>
        <property name="password" value="${ftp.password}"/>
    </bean>

    <int-ftp:outbound-gateway id="gatewayGET"
        local-directory="${ftp.local.dir}"
        session-factory="ftpSessionFactory"
        request-channel="inbound"       
        command="mget"
        command-options="-P"
        expression="${ftp.remote.filename.pattern}"/>

</beans>

Answer 1:

有没有必要为每个请求创建上下文。

代替使用一个字面的表达：

props.setProperty("ftp.remote.filename.pattern",
            "'" + ftpMetaData.getFileNamePattern() + "'");

使用基于该请求的表达; 例如

props.setProperty("ftp.remote.filename.pattern",
            "payload");

然后直接将所需的路径在你的网关的电话...

final List<Boolean> downloadResults = toFtpFlow.mGetFiles("/some/path/*.txt");

文章来源: Dynamically provide directory and file name to ftp outbound gateway