PipedOutput/InputStream使用spring集成上传到sftp

import org.springframework.integration.file.remote.session.SessionFactory;
import org.springframework.integration.sftp.session.SftpRemoteFileTemplate;
import org.springframework.integration.sftp.session.SftpSession;
import org.springframework.integration.sftp.session.SftpSessionFactory;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class SftpUploader {
    public void uploadToSftp() throws IOException {
        PipedOutputStream pipedOutputStream = new PipedOutputStream();
        PipedInputStream pipedInputStream = new PipedInputStream(pipedOutputStream);

        // 配置SFTP连接信息
        SftpSessionFactory sessionFactory = new SftpSessionFactory();
        sessionFactory.setHost("sftp.example.com");
        sessionFactory.setPort(22);
        sessionFactory.setUser("username");
        sessionFactory.setPassword("password");

        // 创建SFTP会话
        SessionFactory<SftpSession> sftpSessionFactory = sessionFactory;
        SftpRemoteFileTemplate template = new SftpRemoteFileTemplate(sftpSessionFactory);

        // 在另一个线程中上传文件
        new Thread(() -> {
            try {
                template.put(pipedInputStream, "/remote/path/file.txt");
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();

        // 将文件数据写入PipedOutputStream
        try (PipedOutputStream outputStream = pipedOutputStream) {
            // 从文件或其他数据源读取数据
            byte[] data = readDataFromFile();

            // 将数据写入PipedOutputStream
            outputStream.write(data);
        }
    }

    private byte[] readDataFromFile() {
        // 从文件中读取数据并返回
        return new byte[0];
    }
}