BAEL-4465 (#9954)

* initial commit * fixed indent * removed unused dependencies * some minor code changes and unit tests * fixed file names
2020-09-01 17:23:00 +02:00
parent 2dc6089b10
commit 8d2c467e2b
5 changed files with 201 additions and 5 deletions
@@ -0,0 +1,64 @@
+package com.baeldung.ssh.apachesshd;
+
+import java.io.ByteArrayOutputStream;
+import java.io.OutputStream;
+import java.util.EnumSet;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.sshd.client.SshClient;
+import org.apache.sshd.client.channel.ClientChannel;
+import org.apache.sshd.client.channel.ClientChannelEvent;
+import org.apache.sshd.client.session.ClientSession;
+import org.apache.sshd.common.channel.Channel;
+
+public class SshdDemo {
+
+    public static void main(String[] args) throws Exception {
+        String username = "demo";
+        String password = "password";
+        String host = "test.rebex.net";
+        int port = 22;
+        long defaultTimeoutSeconds = 10l;
+        String command = "ls\n";
+        
+        listFolderStructure(username, password, host, port, defaultTimeoutSeconds, command);
+    }
+
+    public static String listFolderStructure(String username, String password, String host, int port, long defaultTimeoutSeconds, String command) throws Exception {
+        SshClient client = SshClient.setUpDefaultClient();
+        client.start();
+        try (ClientSession session = client.connect(username, host, port)
+          .verify(defaultTimeoutSeconds, TimeUnit.SECONDS)
+            .getSession()) {
+            session.addPasswordIdentity(password);
+            session.auth()
+              .verify(5L, TimeUnit.SECONDS);
+            try (ByteArrayOutputStream responseStream = new ByteArrayOutputStream();
+                 ByteArrayOutputStream errorResponseStream = new ByteArrayOutputStream();
+                 ClientChannel channel = session.createChannel(Channel.CHANNEL_SHELL)) {
+                channel.setOut(responseStream);
+                channel.setErr(errorResponseStream);
+                try {
+                    channel.open()
+                      .verify(defaultTimeoutSeconds, TimeUnit.SECONDS);
+                    try (OutputStream pipedIn = channel.getInvertedIn()) {
+                        pipedIn.write(command.getBytes());
+                        pipedIn.flush();
+                    }
+                    channel.waitFor(EnumSet.of(ClientChannelEvent.CLOSED), TimeUnit.SECONDS.toMillis(defaultTimeoutSeconds));
+                    String errorString = new String(errorResponseStream.toByteArray());
+                    if(!errorString.isEmpty()) {
+                        throw new Exception(errorString);
+                    }
+                    String responseString = new String(responseStream.toByteArray());
+                    return responseString;
+                } finally {
+                    channel.close(false);
+                }
+            }
+        } finally {
+            client.stop();
+        }
+    }
+
+}
@@ -0,0 +1,52 @@
+package com.baeldung.ssh.jsch;
+
+import java.io.ByteArrayOutputStream;
+
+import com.jcraft.jsch.ChannelExec;
+import com.jcraft.jsch.JSch;
+import com.jcraft.jsch.Session;
+
+public class JschDemo {
+
+    public static void main(String args[]) throws Exception {
+        String username = "demo";
+        String password = "password";
+        String host = "test.rebex.net";
+        int port = 22;
+        String command = "ls";
+        listFolderStructure(username, password, host, port, command);
+    }
+
+    public static String listFolderStructure(String username, String password, String host, int port, String command) throws Exception {
+        Session session = null;
+        ChannelExec channel = null;
+        String response = null;
+        try {
+            session = new JSch().getSession(username, host, port);
+            session.setPassword(password);
+            session.setConfig("StrictHostKeyChecking", "no");
+            session.connect();
+            channel = (ChannelExec) session.openChannel("exec");
+            channel.setCommand(command);
+            ByteArrayOutputStream responseStream = new ByteArrayOutputStream();
+            ByteArrayOutputStream errorResponseStream = new ByteArrayOutputStream();
+            channel.setOutputStream(responseStream);
+            channel.setErrStream(errorResponseStream);
+            channel.connect();
+            while (channel.isConnected()) {
+                Thread.sleep(100);
+            }
+            String errorResponse = new String(errorResponseStream.toByteArray());
+            response = new String(responseStream.toByteArray());
+            if(!errorResponse.isEmpty()) {
+                throw new Exception(errorResponse);
+            }
+        } finally {
+            if (session != null)
+                session.disconnect();
+            if (channel != null)
+                channel.disconnect();
+        }
+        return response;
+    }
+}