SFTP下载文件并显示进度

在解决从远程服务器上下载文件是时候，我遇到了好多方法，也许不能解决我的问题，但也是一个知识点嘛！如jsch直接读取文件再保存，SCPClient和本篇要介绍的SFTP等方法均可实现。

SFTP是Secure File Transfer Protocol的缩写，安全文件传送协议。可以为传输文件提供一种安全的加密方法。sftp 与 ftp 有着几乎一样的语法和功能。SFTP 为 SSH的一部分，是一种传输档案至 Blogger 伺服器的安全方式。其实在SSH软件包中，已经包含了一个叫作SFTP(Secure File Transfer Protocol)的安全文件传输子系统，SFTP本身没有单独的守护进程，它必须使用sshd守护进程（端口号默认是22）来完成相应的连接操作，所以从某种意义上来说，SFTP并不像一个服务器程序，而更像是一个客户端程序。SFTP同样是使用加密传输认证信息和传输的数据，所以，使用SFTP是非常安全的。但是，由于这种传输方式使用了加密/解密技术，所以传输效率比普通的FTP要低得多，如果您对网络安全性要求更高时，可以使用SFTP代替FTP。

而我们可以使用SFTP从远程机器上下载文件，示例代码如下：

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.HashMap;

import java.util.Map;

 

import com.jcraft.jsch.Channel;

import com.jcraft.jsch.ChannelSftp;

import com.jcraft.jsch.JSch;

import com.jcraft.jsch.JSchException;

import com.jcraft.jsch.Session;

import com.jcraft.jsch.SftpATTRS;

 

import qataskclient.MyProgressMonitor;

 

public class DownFile {

  

private static JSch jsch;

private static Session session;

static String userName = "********";

static String password = "********";

//创建连接

public static void connect(String host) throws JSchException {

     jsch = new JSch();

     session = jsch.getSession(userName, host, 22);

     session.setPassword(password);

     java.util.Properties config = new java.util.Properties();

     config.put("StrictHostKeyChecking", "no");

     session.setConfig(config);

     session.connect();

}

 

    public static void main(String[] args) throws Exception {

     Channel channel = null;

     connect("XXX.XXX.XXX.XXX");

        Map sftpDetails = new HashMap();

        // 设置主机ip，端口，用户名，密码

        channel = session.openChannel("sftp"); // 打开SFTP通道

        channel.connect(); // 建立SFTP通道的连接

        ChannelSftp chSftp =(ChannelSftp) channel;

       

        String filename = "/opt/web/usdt_infolist_sale/logs/catalina.out";//需要下载的文件

        SftpATTRS attr = chSftp.stat(filename);

        long fileSize = attr.getSize();

       

        String dst = "E:\KuGou\catalina.out";//存储到本地的文件

        OutputStream out = new FileOutputStream(dst);

        try {

           

            chSftp.get(filename, dst); //下载文件

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            chSftp.quit();

        session.disconnect();

        }

    }

}

通过上面的方法，我们就可以从远程服务器上以安全的方式下载文件。当然有的时候，我们下载文件时希望看到下载进度，此时需要另外加一个回调函数来显示进度。回调函数，显示进度的代码如下：

import com.jcraft.jsch.SftpProgressMonitor;

public class MyProgressMonitor implements SftpProgressMonitor {

private long transfered;

@Override

    public boolean count(long count) {

        transfered = transfered + count;

        if(transfered<1024)

        {

               System.out.println("Currently transferred total size: " + transfered + " bytes");

        }

        if ((transfered> 1024) && (transfered<1048576))

        {

               System.out.println("Currently transferred total size: " + (transfered/1024) + "K bytes");

        }

        else

        {

               System.out.println("Currently transferred total size: " +( transfered/1024/1024) + "M bytes");

        }

        return true;

    }

 

    @Override

    public void end() {

        System.out.println("Transferring done.");

    }

 

    @Override

    public void init(int op, String src, String dest, long max) {

        System.out.println("Transferring begin.");

    }

}

使用SftpProgressMonitor来监控下载的进度，当然我也要修改一下下载文件的部分，具体代码如下：

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.HashMap;

import java.util.Map;

 

import com.jcraft.jsch.Channel;

import com.jcraft.jsch.ChannelSftp;

import com.jcraft.jsch.JSch;

import com.jcraft.jsch.JSchException;

import com.jcraft.jsch.Session;

import com.jcraft.jsch.SftpATTRS;

 

import qataskclient.MyProgressMonitor;

 

public class DownFile {

  

    private static JSch jsch;

    private static Session session;

    static String userName = "********";

    static String password = "********";

    //连接到远程服务器

    public static void connect(String host) throws JSchException {

        jsch = new JSch();

        session = jsch.getSession(userName, host, 22);

        session.setPassword(password);

        java.util.Properties config = new java.util.Properties();

        config.put("StrictHostKeyChecking", "no");

        session.setConfig(config);

        session.connect();

    }

   

    public static void main(String[] args) throws Exception {

         Channel channel = null;

         connect("XXX.XXX.XXX.XXX");

        Map sftpDetails = new HashMap();

        // 设置主机ip，端口，用户名，密码

        channel = session.openChannel("sftp"); // 打开SFTP通道

        channel.connect(); // 建立SFTP通道的连接

        ChannelSftp chSftp =(ChannelSftp) channel;

       

        String filename = "/opt/web/usdt_infolist_sale/logs/catalina.out";

        SftpATTRS attr = chSftp.stat(filename);

        long fileSize = attr.getSize();

       

        String dst = "E:\KuGou\catalina.out";

        OutputStream out = new FileOutputStream(dst);

        try {

            //添加回调函数监控进度

            InputStream is = chSftp.get(filename,  new MyProgressMonitor());

            byte[] buff = new byte[1024 * 2];

            int read;

            if (is != null) {

                System.out.println("Start to read input stream");

                do {

                    read = is.read(buff, 0, buff.length);

                    if (read > 0) {

                        out.write(buff, 0, read);

                    }

                    out.flush();

                } while (read >= 0);

                System.out.println("input stream read done.");

            }

       

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            chSftp.quit();

            session.disconnect();

        }

    }

}

 当我们再次才能这段代码时，就能实时显示出下载进度，并且能根据下载量的大小，转化成以K，M为单位的显示。