JSch教程使用sftp協(xié)議實(shí)現(xiàn)服務(wù)器文件載操作

更新時(shí)間：2022年03月07日 17:16:57 作者：kl

這篇文章主要為大家介紹了JSch如何使用sftp協(xié)議實(shí)現(xiàn)服務(wù)器文件上傳下載操作，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步

Jsch是什么？

JSch 是SSH2的一個(gè)純Java實(shí)現(xiàn)。它允許你連接到一個(gè)sshd 服務(wù)器，使用端口轉(zhuǎn)發(fā)，X11轉(zhuǎn)發(fā)，文件傳輸?shù)鹊取Ｄ憧梢詫⑺墓δ芗傻侥阕约旱?程序中。同時(shí)該項(xiàng)目也提供一個(gè)J2ME版本用來(lái)在手機(jī)上直連SSHD服務(wù)器

Jsch功能很強(qiáng)大，博主這里主要用來(lái)做文件操作

怎么使用？

添加jar依賴

<dependency>
 <groupId>com.jcraft</groupId>
 <artifactId>jsch</artifactId>
 <version>0.1.53</version>
</dependency>

我把我的SftpUtil貼下面了，注釋還算清楚

/**
 * Content ：sftp協(xié)議文件上傳下載
 * Created by kl on 2016/5/6.
 */
public class SftpUtil {
    /**
     * 上傳文件到指定服務(wù)器
     * @param ip 連接ip
     * @param user 用戶名
     * @param psw 密碼
     * @param port 端口 <=0 為默認(rèn)端口
     * @param fielPath 上傳的服務(wù)器路徑
     * @param serverFileName 服務(wù)器保存的文件名
     * @param instream 要上傳的文件流
     * @throws Exception
     */
    public static void sftpFileUpload(String ip,int port, String user, String psw, String fielPath,String serverFileName,InputStream instream) throws Exception {
        Session session =getSession( ip,  user,  psw,  port);
        Channel channel = null;
        try {
            //創(chuàng)建sftp通信通道
            channel = (Channel) session.openChannel("sftp");
            channel.connect(1000);
            ChannelSftp sftp = (ChannelSftp) channel;
            //進(jìn)入服務(wù)器指定的文件夾
            sftp.cd(fielPath);
            OutputStream outstream = sftp.put(serverFileName);
            byte b[] = new byte[1024*200];//每次傳輸200k
            int n;
            while ((n = instream.read(b)) != -1) {
                outstream.write(b, 0, n);
            }
            outstream.flush();
            outstream.close();
            instream.close();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.disconnect();
            if (channel!=null)channel.disconnect();
        }
    }
    /**
     * 從指定服務(wù)器下載文件到本地
     * @param ip 連接ip
     * @param user 用戶名
     * @param psw 密碼
     * @param port 端口 <=0 為默認(rèn)端口
     * @param fielPath 服務(wù)器文件路徑
     * @param serverFileName 要下載的文件名
     * @param outputStream 輸出到本地的文件流
     * @throws Exception
     */
    public static void sftpFileDownload(String ip,int port, String user, String psw, String fielPath,String serverFileName,OutputStream outputStream) throws Exception {
        Session session =getSession( ip,  user,  psw,  port);
        Channel channel = null;
        try {
            //創(chuàng)建sftp通信通道
            channel = (Channel) session.openChannel("sftp");
            channel.connect(1000);
            ChannelSftp sftp = (ChannelSftp) channel;
            //進(jìn)入服務(wù)器指定的文件夾
            sftp.cd(fielPath);
            sftp.get(serverFileName,outputStream);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.disconnect();
            if (channel!=null)channel.disconnect();
        }
    }
    /**
     * 刪除服務(wù)器指定文件
     * @param ip 連接ip
     * @param user 用戶名
     * @param psw 密碼
     * @param port 端口 <=0 為默認(rèn)端口
     * @param fielPath 服務(wù)器文件路徑
     * @param serverFileName 要?jiǎng)h除的文件名
     * @throws Exception
     */
    public static void sftpFileDelete(String ip,int port, String user, String psw, String fielPath,String serverFileName) throws Exception {
        Session session =getSession( ip,  user,  psw,  port);
        Channel channel = null;
        try {
            //創(chuàng)建sftp通信通道
            channel = (Channel) session.openChannel("sftp");
            channel.connect(1000);
            ChannelSftp sftp = (ChannelSftp) channel;
            //進(jìn)入服務(wù)器指定的文件夾
            sftp.cd(fielPath);
            sftp.rm(serverFileName);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.disconnect();
            if (channel!=null)channel.disconnect();
        }
    }
    /**
     * 查看指定目錄所有文件
     * @param ip
     * @param user
     * @param psw
     * @param port
     * @param fielPath
     * @throws Exception
     */
    public static Vector  seeServerFileList(String ip, int port,String user, String psw,  String fielPath)throws Exception{
        Session session =getSession( ip,  user,  psw,  port);
        Channel channel = null;
        Vector v=null;
        try {
            //創(chuàng)建sftp通信通道
            channel = (Channel) session.openChannel("sftp");
            channel.connect(1000);
            ChannelSftp sftp = (ChannelSftp) channel;
            //進(jìn)入服務(wù)器指定的文件夾
            sftp.cd(fielPath);
            //列出服務(wù)器指定的文件列表
             v = sftp.ls(fielPath);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.disconnect();
            if (channel!=null)channel.disconnect();
        }
        return  v;
    }
    /**
     * 連接服務(wù)器
     * @param ip 服務(wù)器地址
     * @param user 用戶名
     * @param psw  密碼
     * @param port  連接端口
     * @return
     * @throws Exception
     */
    public static Session getSession(String ip, String user, String psw, int port)throws Exception{
        Session session = null;
        JSch jsch = new JSch();
        if (port <= 0) {
            //連接服務(wù)器，采用默認(rèn)端口
            session = jsch.getSession(user, ip);
        } else {
            session = jsch.getSession(user, ip, port);
        }
        //如果服務(wù)器連接不上，則拋出異常
        if (session == null) {
            throw new Exception("sftp session is null");
        }
        session.setPassword(psw);//設(shè)置密碼
        //設(shè)置登陸超時(shí)時(shí)間
        session.connect(30000);//30s
        return  session;
    }
}

以上就是JSch教程使用sftp協(xié)議實(shí)現(xiàn)服務(wù)器文件上傳下載操作的詳細(xì)內(nèi)容，更多關(guān)于JSch sftp協(xié)議服務(wù)器文件上傳下載的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: