在Spring集成中使用Java配置文件從SFTP複製和移動文件

Question

我是Spring集成的新手。我有這樣的要求，首先將文件從/ files文件夾移動到SFTP位置中的/ process文件夾，然後將該文件複製到本地。 我建議使用網關和配置必須在Java中使用註釋。 我已經嘗試尋找這裏的答案在stackoverflow但找不到相關的東西。 但是我能夠使用@InboundChannelAdapter和配置其他bean來複制文件。

下面是我寫到目前爲止

配置 公共類SftpConfiguration {

@Value("${ftp.file.host}") 
private String host; 

@Value("${ftp.file.port") 
private int port; 

@Value("${ftp.file.user") 
private String user; 

@Value("${ftp.file.password") 
private String password; 

@Value("${directorry.file.remote") 
private String remoteDir; 

@Value("${directorry.file.in.pollerDelay") 
final private String pollerDelay = "1000"; 

@Value("${directory.file.remote.move}") 
private String toMoveDirectory; 

@Bean 
public SessionFactory<LsEntry> sftpSessionFactory() { 
    DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); 
    factory.setHost(host); 
    factory.setPort(port); 
    factory.setUser(user); 
    factory.setPassword(password); 
    factory.setAllowUnknownKeys(true); 
    return new CachingSessionFactory<LsEntry>(factory); 
} 

@Bean 
public SftpInboundFileSynchronizer sftpInboundFileSynchronizer() { 
    SftpInboundFileSynchronizer fileSynchronizer = new SftpInboundFileSynchronizer(sftpSessionFactory()); 
    fileSynchronizer.setDeleteRemoteFiles(false); 
    fileSynchronizer.setRemoteDirectory(remoteDir); 
    fileSynchronizer.setFilter(new SftpSimplePatternFileListFilter("*.xlsx")); 
    return fileSynchronizer; 
} 

@Bean 
@InboundChannelAdapter(channel = "sftpChannel", poller = @Poller(fixedDelay = pollerDelay)) 
public MessageSource<File> sftpMessageSource() { 
    SftpInboundFileSynchronizingMessageSource source = new SftpInboundFileSynchronizingMessageSource(
      sftpInboundFileSynchronizer()); 
    source.setLocalDirectory(new File("ftp-inbound")); 
    source.setAutoCreateLocalDirectory(true); 
    source.setLocalFilter(new AcceptOnceFileListFilter<File>()); 

    return source; 
} 

@Bean 
@ServiceActivator(inputChannel = "sftpChannel") 
public MessageHandler handler() { 
    return new MessageHandler() { 

     @Override 
     public void handleMessage(Message<?> message) throws MessagingException { 
      try { 
       new FtpOrderRequestHandler().handle((File) message.getPayload()); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 

    }; 
} 

@Bean 
@ServiceActivator(inputChannel = "sftpChannel") 
public MessageHandler handlerOut() { 
    return new SftpOutboundGateway(sftpSessionFactory(), "mv", toMoveDirectory); 
} 

}

我會感謝任何提示或建議的代碼。 謝謝。

Answer 1

對，您需要使用@Bean和@InboundChannelAdapter爲SftpInboundFileSynchronizingMessageSource將文件從遠程/process文件夾下載到本地目錄。這是在poller基礎上完成的，並且是一個單獨的過程，完全與移動操作無關。此舉的邏輯，你可以通過FtpOutboundGateway與MV命令執行：

的MV命令沒有選項。

的表達屬性定義了「從」路徑和重命名表達屬性定義「到」路徑。 默認情況下，重命名錶達式是headers['file_renameTo']。 此表達式不能計算爲空或者爲空String。 如有必要，將創建所需的任何遠程目錄。 結果消息的有效載荷是Boolean.TRUE。 在file_remoteDirectory標題中提供了原始遠程目錄，並且在file_remoteFile標題中提供了文件名。 新路徑位於file_renameTo標題中。

這一個，你必須通過使用方法：

@Bean 
@ServiceActivator(inputChannel = "sftpChannel") 
public MessageHandler handler() { 
    return new SftpOutboundGateway(ftpSessionFactory(), "mv", "'my_remote_dir/my_file'"); 
}