From feb5b850ff08a38eb9e6bf1eefc16cafaaa78148 Mon Sep 17 00:00:00 2001
From: DOHA <dohae243@gmail.com>
Date: Thu, 18 Jul 2019 00:23:38 +0300
Subject: [PATCH] sftp file transfer

---
 core-java-modules/core-java-io/pom.xml        |  24 +++-
 .../io/remote/SftpFileTransferLiveTest.java   | 106 ++++++++++++++++++
 2 files changed, 129 insertions(+), 1 deletion(-)
 create mode 100644 core-java-modules/core-java-io/src/test/java/org/baeldung/java/io/remote/SftpFileTransferLiveTest.java

diff --git a/core-java-modules/core-java-io/pom.xml b/core-java-modules/core-java-io/pom.xml
index 44c703ee68..e263512512 100644
--- a/core-java-modules/core-java-io/pom.xml
+++ b/core-java-modules/core-java-io/pom.xml
@@ -171,6 +171,24 @@
             <artifactId>jmimemagic</artifactId>
             <version>${jmime-magic.version}</version>
         </dependency>
+        <!-- sftp file transfer -->
+        <dependency>
+            <groupId>com.jcraft</groupId>
+            <artifactId>jsch</artifactId>
+            <version>${jsch.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.hierynomus</groupId>
+            <artifactId>sshj</artifactId>
+            <version>${sshj.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-vfs2</artifactId>
+            <version>${vfs.version}</version>
+        </dependency>
+        
+        
     </dependencies>
 
     <build>
@@ -249,7 +267,7 @@
 
         <!-- util -->
         <commons-lang3.version>3.5</commons-lang3.version>
-        <bouncycastle.version>1.55</bouncycastle.version>
+        <bouncycastle.version>1.60</bouncycastle.version>
         <commons-codec.version>1.10</commons-codec.version>
         <commons-math3.version>3.6.1</commons-math3.version>
         <decimal4j.version>1.0.3</decimal4j.version>
@@ -262,6 +280,10 @@
         <streamex.version>0.6.5</streamex.version>
         <vavr.version>0.9.0</vavr.version>
         <opencsv.version>4.1</opencsv.version>
+        <!-- sftp -->
+        <jsch.version>0.1.55</jsch.version>
+        <sshj.version>0.27.0</sshj.version>
+        <vfs.version>2.3</vfs.version>        
         <!-- testing -->
         <assertj.version>3.6.1</assertj.version>
         <avaitility.version>1.7.0</avaitility.version>
diff --git a/core-java-modules/core-java-io/src/test/java/org/baeldung/java/io/remote/SftpFileTransferLiveTest.java b/core-java-modules/core-java-io/src/test/java/org/baeldung/java/io/remote/SftpFileTransferLiveTest.java
new file mode 100644
index 0000000000..192153bc90
--- /dev/null
+++ b/core-java-modules/core-java-io/src/test/java/org/baeldung/java/io/remote/SftpFileTransferLiveTest.java
@@ -0,0 +1,106 @@
+package org.baeldung.java.io.remote;
+
+import java.io.IOException;
+
+import org.apache.commons.vfs2.FileObject;
+import org.apache.commons.vfs2.FileSystemManager;
+import org.apache.commons.vfs2.Selectors;
+import org.apache.commons.vfs2.VFS;
+import org.junit.Test;
+
+import com.jcraft.jsch.ChannelSftp;
+import com.jcraft.jsch.JSch;
+import com.jcraft.jsch.JSchException;
+import com.jcraft.jsch.Session;
+import com.jcraft.jsch.SftpException;
+
+import net.schmizz.sshj.SSHClient;
+import net.schmizz.sshj.sftp.SFTPClient;
+import net.schmizz.sshj.transport.verification.PromiscuousVerifier;
+
+public class SftpFileTransferLiveTest {
+
+    private String remoteHost = "HOST_NAME_HERE";
+    private String username = "USERNAME_HERE";
+    private String password = "PASSWORD_HERE";
+    private String localFile = "src/main/resources/input.txt";
+    private String remoteFile = "welcome.txt";
+    private String localDir = "src/main/resources/";
+    private String remoteDir = "remote_sftp_test/";
+    private String knownHostsFileLoc = "/Users/USERNAME/known_hosts_sample";
+
+    @Test
+    public void whenUploadFileUsingJsch_thenSuccess() throws JSchException, SftpException {
+        ChannelSftp channelSftp = setupJsch();
+        channelSftp.connect();
+        channelSftp.put(localFile, remoteDir + "jschFile.txt");
+        channelSftp.exit();
+    }
+
+    @Test
+    public void whenDownloadFileUsingJsch_thenSuccess() throws JSchException, SftpException {
+        ChannelSftp channelSftp = setupJsch();
+        channelSftp.connect();
+        channelSftp.get(remoteFile, localDir + "jschFile.txt");
+        channelSftp.exit();
+    }
+
+    @Test
+    public void whenUploadFileUsingSshj_thenSuccess() throws IOException {
+        SSHClient sshClient = setupSshj();
+        SFTPClient sftpClient = sshClient.newSFTPClient();
+        sftpClient.put(localFile, remoteDir + "sshjFile.txt");
+        sftpClient.close();
+        sshClient.disconnect();
+    }
+
+    @Test
+    public void whenDownloadFileUsingSshj_thenSuccess() throws IOException {
+        SSHClient sshClient = setupSshj();
+        SFTPClient sftpClient = sshClient.newSFTPClient();
+        sftpClient.get(remoteFile, localDir + "sshjFile.txt");
+        sftpClient.close();
+        sshClient.disconnect();
+    }
+
+    @Test
+    public void whenUploadFileUsingApacheVfs_thenSuccess() throws IOException {
+        FileSystemManager manager = VFS.getManager();
+        FileObject local = manager.resolveFile(System.getProperty("user.dir") + "/" + localFile);
+        FileObject remote = manager.resolveFile("sftp://" + username + ":" + password + "@" + remoteHost + "/" + remoteDir + "vfsFile.txt");
+        remote.copyFrom(local, Selectors.SELECT_SELF);
+        local.close();
+        remote.close();
+    }
+
+    @Test
+    public void whenDownloadFileUsingApacheVfs_thenSuccess() throws IOException {
+        FileSystemManager manager = VFS.getManager();
+        FileObject local = manager.resolveFile(System.getProperty("user.dir") + "/" + localDir + "vfsFile.txt");
+        FileObject remote = manager.resolveFile("sftp://" + username + ":" + password + "@" + remoteHost + "/" + remoteFile);
+        local.copyFrom(remote, Selectors.SELECT_SELF);
+        local.close();
+        remote.close();
+    }
+
+    // ====== ssh-keyscan -H -t rsa remoteHost >> known_hosts_sample
+
+    private ChannelSftp setupJsch() throws JSchException {
+        JSch jsch = new JSch();
+        jsch.setKnownHosts(knownHostsFileLoc);
+        Session jschSession = jsch.getSession(username, remoteHost);
+        jschSession.setPassword(password);
+        //jschSession.setConfig("StrictHostKeyChecking", "no");
+        jschSession.connect();
+        return (ChannelSftp) jschSession.openChannel("sftp");
+    }
+
+    private SSHClient setupSshj() throws IOException {
+        SSHClient client = new SSHClient();
+        client.addHostKeyVerifier(new PromiscuousVerifier());
+        client.connect(remoteHost);
+        client.authPassword(username, password);
+        return client;
+    }
+
+}