我想遞歸地列出遠(yuǎn)程目錄及其子目錄中的文件。我知道可以通過(guò)調(diào)用 ListGateway 的 listFiles 方法來(lái)做到這一點(diǎn)：列表列表 = listGateway.listFiles("/ussama/providers")@MessagingGatewaypublic interface ListGateway { @Gateway(requestChannel = "listSftpChannel") List<File> listFiles(String dir);}@Bean@ServiceActivator(inputChannel = "listSftpChannel")public MessageHandler handler() { SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(sftpSessionFactory(), "ls", "'/directory'"); return sftpOutboundGateway;}@Beanpublic IntegrationFlow sftpOutboundListFlow() { return IntegrationFlows.from("listSftpChannel") .handle(new SftpOutboundGateway(sftpSessionFactory(), "ls", "payload") ).get();}但我想每隔 x 分鐘做一次。有沒(méi)有辦法可以輪詢遠(yuǎn)程目錄以在每 x 分鐘后列出文件。請(qǐng)給java配置。
1 回答
紫衣仙女
TA貢獻(xiàn)1839條經(jīng)驗(yàn) 獲得超15個(gè)贊
輪詢目錄的簡(jiǎn)單 POJO 消息源并根據(jù)需要配置輪詢器...
@Bean
public IntegrationFlow pollLs(SessionFactory<LsEntry> sessionFactory) {
return IntegrationFlows.from(() -> "foo/bar", e -> e
.poller(Pollers.fixedDelay(5, TimeUnit.SECONDS)))
.handle(Sftp.outboundGateway(sessionFactory, Command.LS, "payload")
.options(Option.RECURSIVE))
.handle(System.out::println)
.get();
}
顯然，您將需要一些服務(wù).handle來(lái)接收List<LsEntry>結(jié)果。
順便說(shuō)一句，有一個(gè)工廠類Sftp可以方便地創(chuàng)建端點(diǎn)。
添加回答
舉報(bào)
0/150
提交
取消