具有动态 FTP 属性的 Spring Integration 上传

Question

我有一个 Web 项目，我正在使用 Spring Integration 通过 FTP 在远程目录上上传文件。但是，FTP 属性是动态加载的（从数据库中），每个请求的属性可能不同。幼稚的做法：

初始创建DefaultFtpSessionFactory bean：

@Bean
public DefaultFtpSessionFactory defaultFtpSessionFactory() {
    return new DefaultFtpSessionFactory();
}

IntegrationFlow豆：

@Bean
public IntegrationFlow integrationFlow(DefaultFtpSessionFactory defaultFtpSessionFactory) {
    // Flow config
}

将此bean注入控制器并设置属性：

@Autowired
private DefaultFtpSessionFactory defaultFtpSessionFactory;

@Autowired
private FtpConfigService ftpConfigService;

@RequestMapping(value = "upload", method = RequestMethod.GET)
public RequestEntity<String> upload() {
    defaultFtpSessionFactory.setHost(ftpConfigService.getHost());
    // Set other properties
    // ... and upload file

   return new RequestEntity<>(HttpStatus.OK);
}

当然，这是一个坏主意，因为存在竞争条件（两个请求可以同时访问 DefaultFtpSessionFactory 单例）。那么，我怎样才能以安全的方式实现这一点呢？

Answer 1

动态注册流程的最后部分——见the blog introducing the feature；也许将这些流保存在缓存中。

查看dynamic-tcp-client 的示例，我们动态创建多个 tcp 客户端适配器并缓存输入通道；对 ftp 使用类似的技术 - dynamic-ftp 也有一个较旧的示例，它早于 DSL 和动态流注册。