스프링 통합에서 자바 설정을 사용하여 SFTP에서 파일 복사 및 이동

Question

저는 스프링 통합을 처음 사용합니다. 먼저/files 폴더에서 SFTP 위치의/process 폴더로 파일을 이동 한 다음 해당 파일을 로컬로 복사해야합니다. 게이트웨이를 사용하도록 제안되었으며 구성은 Java를 사용하여 주석을 사용해야합니다. 나는 stackoverflow에 대한 답변을 찾고 여기 시도했지만 관련성이 뭔가를 찾을 수 없습니다. 그러나 @InboundChannelAdapter를 사용하여 파일을 복사하고 다른 빈을 구성 할 수있었습니다. 다음은

는 지금까지

구성을 공용 클래스 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

오른쪽, 당신은 로컬 디렉토리에 원격 /process 폴더에서 파일을 다운로드 할 수 SftpInboundFileSynchronizingMessageSource에 대한 @InboundChannelAdapter와 @Bean를 사용해야합니다. 이는 폴러 단위로 수행되며 별도의 프로세스로 이동 작업과는 완전히 관련이 없습니다. 즉, 이동 로직 당신은 MV 명령을 FtpOutboundGateway을 통해 수행 할 수 있습니다

MV 명령은 옵션이 없습니다.

식 속성은 "에서"경로와 바꾸기 표현을 정의 속성이 "행"의 경로를 정의한다. 기본적으로 이름 바꾸기 식은 headers['file_renameTo']입니다. 이 표현식은 null로 평가되거나 비어있는 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'"); 
}