如何在spring集成中动态创建ftp适配器？

Question

如何在我的项目中动态创建入站适配器以轮询和检索服务器中的文件？

Answer 1

如果允许您在项目中使用第三方库的非“通用可用性”(GA)版本（例如，版本候选(RC)或里程碑(M)，那么您可以使用Spring Integration的版本5.0.0.m2。这是最新出版的版本，截至2009年3月'17。

从5.0开始，Spring Integration包含Java DSL运行时流注册特性。它允许您像在标准bean中那样定义集成流（包括入站适配器），但它可以在任何运行时时刻完成。

您只需使用以下三个步骤：

null

  @Autowired
  public MyClass(IntegrationFlowContext flowContext) {
    this.flowContext = flowContext;
  }

  IntegrationFlowRegistration registration = flowContext
      .registration(IntegrationFlows   // this method accepts IntegrationFlow instance
                        .from(s -> s.ftp(ftpSessionFactory())
                                    .localFilter(localFileFilter())
                        //other actions
                        .get())        // standard end of DSL flow building process
      .autoStartup(true)               // not required but can be useful
      .register();                     // this makes the flow exist in the context

// retrieve registration ID from the object created above
String dynamicFlowRegistrationId = registration.getId();
// the following will also gracefully stop all the processes within the flow
flowContext.remove(dynamicFlowRegistrationId);