SSH2純Java實現—JSch介紹和使用

介紹：

JSch 是SSH2的一個純Java實現。它允許你連接到一個sshd 服務器，使用端口轉發，X11轉發，文件傳輸等等。你可以將它的功能集成到你自己的 程序中。同時該項目也提供一個J2ME版本用來在手機上直連SSHD服務器。

 

使用：

pom.xml文件引入相關依賴

<dependency>
    <groupId>commons-io</groupId>
    <artifactId>commons-io</artifactId>
    <version>2.6</version>
</dependency>
<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.55</version>
</dependency>

代碼實現

package cn.zxj.gkxt.core.util;


import com.jcraft.jsch.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.*;


/**
* JSch(Java Secure Channel)
* SSH2純Java實現
* 連接至SSH服務器
*/
public class JschUtils {
    private static final Logger LOG = LoggerFactory.getLogger(JschUtils.class.getName());


    /**
     * main方法
     * 本地開發
     * @param args 輸入參數
     */
    public static void main(String[] args) {
        String userName = System.getProperty("user.name");

        ChannelSftp sftp = connect("10.194.61.92", 22, "tomcat", "Gzyqzxj092@tomcatlinserver");

        
        // 上傳文件至SFTP指定目錄
        if (1 == 1) {
            upload("/home/tomcat/gkxt/static/sftpLibrary", "C:\\Users\\" + userName + "\\Documents\\demo.jpg", sftp);
        }
    }


    /**
     * 連接SFTP服務器
     * @param host 主機
     * @param port 端口
     * @param username 用戶名
     * @param password 密碼
     * @return ChannelSftp
     */
    public static ChannelSftp connect(String host, int port, String username,
                                      String password) {
        ChannelSftp sftp = null;


        try {
            // 初始化JCsh對象
            JSch jsch = new JSch();
            // 由用戶名 | 主機ip | 端口號獲取單個Session對象
            Session sshSession = jsch.getSession(username, host, port);
            LOG.info("Session created.");


            // 設置登錄密碼
            sshSession.setPassword(password);


            // 初始化Properties對象
            Properties sshConfig = new Properties();
            sshConfig.put("StrictHostKeyChecking", "no");


            // 為Session對象設置properties
            sshSession.setConfig(sshConfig);
            // 設置timeout
            sshSession.setTimeout(5000);
            sshSession.connect();
            LOG.info("Session connected.");
            LOG.info("Opening Channel.");


            // 指定獲取Channel連接方式
            Channel channel = sshSession.openChannel("sftp");
            channel.connect();
            sftp = (ChannelSftp) channel;
            LOG.info("Connected to " + host + ".");
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return sftp;
    }


    /**
     * 上傳文件
     * @param directory 上傳的目錄
     * @param uploadFile 要上傳的文件
     * @param sftp ChannelSftp
     */
    public static void upload(String directory, String uploadFile, ChannelSftp sftp) {
        mkDir(directory, sftp);
        InputStream in = null;
        try {
            sftp.cd(directory);
            File file = new File(uploadFile);
            in = new FileInputStream(file);
            sftp.put(new FileInputStream(file), file.getName());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                assert in != null;
                in.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }


    /**
     * 下載文件
     * @param directory 目錄
     * @param downloadFile 下載的文件
     * @param sftp ChannelSftp
     */
    public static InputStream download(String directory, String downloadFile,
                                       ChannelSftp sftp) {
        InputStream in = null;
        try {
            sftp.cd(directory);
            in = sftp.get(downloadFile);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return in;
    }


    /**
     * 刪除文件
     * @param directory 文件所在目錄
     * @param deleteFile 要刪除的文件
     * @param sftp ChannelSftp
     */
    public static void delete(String directory, String deleteFile, ChannelSftp sftp) {
        try {
            sftp.cd(directory);
            sftp.rm(deleteFile);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }


    /**
     * 列出目錄下的文件
     * @param directory 要列出的目錄
     * @param sftp ChannelSftp
     * @return Vector(動態數組)
     * @throws SftpException Sftp異常
     */
    public static Vector listFiles(String directory, ChannelSftp sftp) throws SftpException {
        return sftp.ls(directory);
    }



    /**
     * 獲取目錄名稱
     * @param ls 目錄數組
     * @return 目錄名稱集合
     */
    public static List<String> buildFiles(Vector ls) {
        if (ls != null) {
            List<String> list = new ArrayList<>();
            for (Object l : ls) {
                ChannelSftp.LsEntry f = (ChannelSftp.LsEntry) l;
                String nm = f.getFilename();
                if (".".equals(nm) || "..".equals(nm)) {
                    continue;
                }
                list.add(nm);
            }


            return list;
        }


        return null;
    }


    /**
     * 打開指定目錄
     * @param directory 目錄
     * @return boolean
     */
    public static boolean openDir(String directory, ChannelSftp sftp) {
        try {
            sftp.cd(directory);
            return true;
        } catch (SftpException e) {
            return false;
        }
    }


    /**
     * 按指定路徑創建文件夾
     * @param dirName 文件夾路徑
     * @param sftp ChannelSftp
     */
    public static void mkDir(String dirName, ChannelSftp sftp) {
        String[] dirs = dirName.split("/");
        try {
            String now = sftp.pwd();
            sftp.cd("/");
            for (String dir : dirs) {
                if (StringUtils.isNotEmpty(dir)) {
                    boolean dirExists = openDir(dir, sftp);
                    if (!dirExists) {
                        sftp.mkdir(dir);
                        sftp.cd(dir);
                    }
                }
            }
            sftp.cd(now);
        } catch (SftpException e) {
            e.printStackTrace();
        }
    }
}