[JAVA] Spring SSH sftp 파일 다운로드(apache.sshd)

jsch 구현된 코드가 안 되면서 최근 apache의 Mina-sshd 로 변환중이다.

sftp 파일 다운로드 코드.

 

 

Dependency

버전 맞춰줘야 오류 안 나는듯

implementation 'org.apache.sshd:sshd-core:2.12.0'
implementation 'org.apache.sshd:sshd-sftp:2.12.0'

 

 

Code

package com.aspnrpa.test;


import org.apache.sshd.client.SshClient;
import org.apache.sshd.client.session.ClientSession;
import org.apache.sshd.common.config.keys.FilePasswordProvider;
import org.apache.sshd.common.config.keys.loader.KeyPairResourceLoader;
import org.apache.sshd.common.util.security.SecurityUtils;
import org.apache.sshd.sftp.client.SftpClient;
import org.apache.sshd.sftp.client.SftpClientFactory;

import java.io.OutputStream;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.security.KeyPair;
import java.util.Collection;

public class TestService {

    public void download(String robotName,String localFilePath, String remoteFilePath) {

        String host = "ex:";
        int port = 22;
        String username = "ex:user";
        String privateKeyPath = "ex:C:\\Users\\User\\.ssh\\id_rsa";
        String password = null;

        
        try (SshClient client = SshClient.setUpDefaultClient()) {

            client.start();

            KeyPairResourceLoader loader = SecurityUtils.getKeyPairResourceParser();
            Path path = Paths.get(privateKeyPath);
            Collection<KeyPair> keys = loader.loadKeyPairs(null, path, FilePasswordProvider.of(password));

            try (ClientSession session = client.connect(username, host, port)
                    .verify(10000)
                    .getSession()) {
                session.addPublicKeyIdentity(keys.iterator().next());
                session.auth().verify(10000);

                try (SftpClient sftp = SftpClientFactory.instance().createSftpClient(session)) {
                    try (OutputStream os = Files.newOutputStream(Paths.get(localFilePath));
                         SftpClient.CloseableHandle handle = sftp.open(remoteFilePath)) {
                        byte[] buffer = new byte[8192];
                        long offset = 0;
                        while (true) {
                            int len = sftp.read(handle, offset, buffer, 0, buffer.length);
                            if (len == -1) {
                                break;
                            }
                            os.write(buffer, 0, len);
                            offset += len;
                        }
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("Download completed");
    }
}