package com.hai.linux;

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.SCPClient;
import ch.ethz.ssh2.SCPOutputStream;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

public class scpConnection {

    public static void main(String[] args) {

        Connection connection = new Connection("xxx.xxx.xxx.xx",22);
        String filePath1 ="testlinux/aa1.txt" ;
        File f = new File(filePath1);

        try(FileInputStream fis = new FileInputStream(f)){
            connection.connect();

            boolean isAuthenticated = connection.authenticateWithPassword("root","xxx");
            if(!isAuthenticated){
                System.out.println("连接建立失败");
                return ;
            }
            SCPClient scpClient = new SCPClient(connection);
            String remoteTargetDirectory = "/data5";
//            SFTPv3Client sftpv3Client = new SFTPv3Client(connection);
            SCPOutputStream os = scpClient.put(f.getName(),f.length(),remoteTargetDirectory,null);
            byte[] b = new byte[4096];
            int i;
            while ((i = fis.read(b)) != -1) {
                os.write(b, 0, i);
            }
//            scpClient.put("testlinux/aa1.txt","/data5");

            os.flush();
            fis.close();
            os.close();
            connection.close();
            System.out.println("upload ok");

        }catch (IOException e) {
        e.printStackTrace();
        }
    }
}