通過彈簧集成發送成功的FTP文件上傳消息

Question

如何僅在成功的FTP文件傳輸時觸發將消息發送到JdbcOutboundGateway？

我有下面的IntegrationFlow。它可以根據需要上傳文件到FTP服務器。但是，我需要向DB寫入文件已成功上傳，或者如果FTP上載失敗，則更新記錄。我無法確定如何在文件傳輸成功時啓動數據庫更新。無論我在哪裏嘗試繼續流程，它都會拋出一個異常，指出它是「單向」的。

• ftpProps包含所有用於各種FTP設置
• outboundMessages的配置值是消息被放置到需要經由FTP要發送的信道
• ftpSessionFactoryFactory構建出從值的所有的各種FtpSessionFactory對象在配置文件中，所述路由器將隨後確定發送消息通過檢查報頭值

流其中之一：

@Bean 
public IntegrationFlow fromOutboundChannelToFtp(OutboundConfigurationProperties ftpProps, 
               @Qualifier(OUTBOUND_CHANNEL) MessageChannel outboundMessages, 
               @Qualifier(FTP_SESSION_FACTORY_FACTORY) FtpSessionFactoryFactory ftpSessionFactoryFactory) { 
    return IntegrationFlows.from(outboundMessages) 
      .route(RECEIVER_HEADER_SPEL, mapping -> { 
       for (String receiverId : ftpProps.getFtp().keySet()) { 
        mapping.subFlowMapping(receiverId, sf -> { 
         sf.handleWithAdapter(adapter -> 
          adapter.ftp(ftpSessionFactoryFactory.getFactory(receiverId)) 
          .fileNameExpression(FILENAME_HEADER_SPEL) 
          .autoCreateDirectory(true) 
          .remoteDirectory(ftpProps.getValue(receiverId, FtpProp.DIRECTORY)) 
         ); 
        }); 
       } 
      }) 
      .get(); 
} 

Answer 1

使outboundMessages成爲發佈/訂閱通道並使用JDBC適配器訂閱第二個流。在路由器和jdbc適配器使用者上設置order屬性，以確保它們按正確的順序調用。

默認情況下，如果第一個使用者失敗，則不會調用第二個使用者。

在流入口點（通道的上游）使用錯誤通道來處理故障。

備選地，添加ExpressionEvaluatingMessageHandlerAdvice到ftp適配器和添加對success通道JDBC適配器流動並在failure信道不同的更新流程。