Spring集成-逐行读取远程文件

Question

我正在尝试使用spring集成逐行读取远程文件。使用这里找到的spring文档，我已经设置了我的项目来轮询文件，并在找到文件时通过sftp传输它。我一直在思考如何一行一行地读取文件内容。

这是我的入站通道适配器设置，当前用于拉入文件。

<int-sftp:inbound-channel-adapter id="sftpAdapterAutoCreate"
        session-factory="sftpSessionFactory"
        channel="receiveChannel"
        filename-pattern="*.txt"
        remote-directory="/home/springftp"
        preserve-timestamp="true"
        local-directory="file:C:\sprintftp"
        auto-create-local-directory="true"
        temporary-file-suffix=".writing"
        delete-remote-files="false">
    <int:poller fixed-rate="1000" max-messages-per-poll="1"/>
</int-sftp:inbound-channel-adapter>

<int:channel id="receiveChannel"> 
    <int:queue/> 
</int:channel> 

编辑：为了澄清，我想一次从远程文件中检索一行，然后处理该行的内容，然后检索下一行。类似于为本地文件创建java.io.inputstream并逐行读取。

非常感谢您的帮助。非常感谢。

Answer 1

您可以使用

更新

我想一次从远程文件中检索一行，然后处理该行的内容，然后检索下一行。类似于为本地文件创建java.io.inputstream并逐行读取。

很遗憾，我们没有为此提供高级组件，但您可以尝试使用RemoteFileTemplate的功能：

RemoteFileTemplate<FTPFile> template = new RemoteFileTemplate<FTPFile>(this.ftpSessionFactory);
template.setFileNameExpression(new SpelExpressionParser().parseExpression("payload"));
template.setBeanFactory(mock(BeanFactory.class));
template.afterPropertiesSet();
final ByteArrayOutputStream baos1 = new ByteArrayOutputStream();
template.get(new GenericMessage<String>("ftpSource/ftpSource1.txt"), new InputStreamCallback() {

    @Override
    public void doWithInputStream(InputStream stream) throws IOException {
        FileCopyUtils.copy(stream, baos1);
    }
});

您可以将此代码连接到一些POJO服务，并将最后一个连接到