Java使用SFTP和FTP两种连接方式实现对服务器的上传下载 【转】

原文：https://www.cnblogs.com/libin6505/p/10583438.html

一、Java实现对SFTP服务器的文件的上传下载

1、添加maven依赖：

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

2、SFTPUtil工具类：

   import java.io.ByteArrayInputStream;  
    import java.io.File;  
    import java.io.FileInputStream;  
    import java.io.FileNotFoundException;  
    import java.io.FileOutputStream;  
    import java.io.IOException;  
    import java.io.InputStream;  
    import java.io.UnsupportedEncodingException;  
    import java.util.Properties;  
    import java.util.Vector;  
      
    import org.apache.commons.io.IOUtils;  
    import org.slf4j.Logger;  
    import org.slf4j.LoggerFactory;  
      
    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.SftpException;
    /**
    * 类说明 sftp工具类
    */
    public class SFTPUtil {
        private transient Logger log = LoggerFactory.getLogger(this.getClass());  
        
        private ChannelSftp sftp;  
            
        private Session session;  
        /** SFTP 登录用户名*/    
        private String username;
        /** SFTP 登录密码*/    
        private String password;  
        /** 私钥 */    
        private String privateKey;  
        /** SFTP 服务器地址IP地址*/    
        private String host;  
        /** SFTP 端口*/  
        private int port;  
            
        
        /**  
         * 构造基于密码认证的sftp对象  
         */    
        public SFTPUtil(String username, String password, String host, int port) {  
            this.username = username;  
            this.password = password;  
            this.host = host;  
            this.port = port;  
        }
        
        /**  
         * 构造基于秘钥认证的sftp对象
         */  
        public SFTPUtil(String username, String host, int port, String privateKey) {  
            this.username = username;  
            this.host = host;  
            this.port = port;  
            this.privateKey = privateKey;  
        }  
        
        public SFTPUtil(){}  
        
        
        /**
         * 连接sftp服务器
         */  
        public void login(){  
            try {  
                JSch jsch = new JSch();  
                if (privateKey != null) {  
                    jsch.addIdentity(privateKey);// 设置私钥  
                }  
        
                session = jsch.getSession(username, host, port);  
               
                if (password != null) {  
                    session.setPassword(password);    
                }  
                Properties config = new Properties();  
                config.put("StrictHostKeyChecking", "no");  
                    
                session.setConfig(config);  
                session.connect();  
                  
                Channel channel = session.openChannel("sftp");  
                channel.connect();  
        
                sftp = (ChannelSftp) channel;  
            } catch (JSchException e) {  
                e.printStackTrace();
            }  
        }    
        
        /**
         * 关闭连接 server  
         */  
        public void logout(){  
            if (sftp != null) {  
                if (sftp.isConnected()) {  
                    sftp.disconnect();  
                }  
            }  
            if (session != null) {  
                if (session.isConnected()) {  
                    session.disconnect();  
                }  
            }  
        }  
     
        
        /**  
         * 将输入流的数据上传到sftp作为文件。文件完整路径=basePath+directory
         * @param basePath  服务器的基础路径
         * @param directory  上传到该目录  
         * @param sftpFileName  sftp端文件名  
         * @param in   输入流  
         */  
        public void upload(String basePath,String directory, String sftpFileName, InputStream input) throws SftpException{  
            try {   
                sftp.cd(basePath);
                sftp.cd(directory);  
            } catch (SftpException e) {
                //目录不存在，则创建文件夹
                String [] dirs=directory.split("/");
                String tempPath=basePath;
                for(String dir:dirs){
                    if(null== dir || "".equals(dir)) continue;
                    tempPath+="/"+dir;
                    try{
                        sftp.cd(tempPath);
                    }catch(SftpException ex){
                        sftp.mkdir(tempPath);
                        sftp.cd(tempPath);
                    }
                }
            }  
            sftp.put(input, sftpFileName);  //上传文件
        }
        
     
        /**
         * 下载文件。
         * @param directory 下载目录  
         * @param downloadFile 下载的文件
         * @param saveFile 存在本地的路径
         */    
        public void download(String directory, String downloadFile, String saveFile) throws SftpException, FileNotFoundException{  
            if (directory != null && !"".equals(directory)) {  
                sftp.cd(directory);  
            }  
            File file = new File(saveFile);  
            sftp.get(downloadFile, new FileOutputStream(file));  
        }  
        
        /**  
         * 下载文件
         * @param directory 下载目录
         * @param downloadFile 下载的文件名
         * @return 字节数组
         */  
        public byte[] download(String directory, String downloadFile) throws SftpException, IOException{  
            if (directory != null && !"".equals(directory)) {  
                sftp.cd(directory);  
            }  
            InputStream is = sftp.get(downloadFile);  
              
            byte[] fileData = IOUtils.toByteArray(is);  
              
            return fileData;  
        }  
        
        
        /**
         * 删除文件
         * @param directory 要删除文件所在目录
         * @param deleteFile 要删除的文件
         */  
        public void delete(String directory, String deleteFile) throws SftpException{  
            sftp.cd(directory);  
            sftp.rm(deleteFile);  
        }  
        
        
        /**
         * 列出目录下的文件
         * @param directory 要列出的目录
         * @param sftp
         */  
        public Vector<?> listFiles(String directory) throws SftpException {  
            return sftp.ls(directory);  
        }  
          
        //上传文件测试
        public static void main(String[] args) throws SftpException, IOException {  
            SFTPUtil sftp = new SFTPUtil("用户名", "密码", "ip地址", 22);  
            sftp.login();  
            File file = new File("D:\图片\t0124dd095ceb042322.jpg");  
            InputStream is = new FileInputStream(file);  
              
            sftp.upload("基础路径","文件路径", "test_sftp.jpg", is);  
            sftp.logout();  
        }  
    }

 

二、Java实现对FTP服务器的文件的上传下载


 

    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
     
    import org.apache.commons.net.ftp.FTP;
    import org.apache.commons.net.ftp.FTPClient;
    import org.apache.commons.net.ftp.FTPFile;
    import org.apache.commons.net.ftp.FTPReply;
     
    /**
     * ftp上传下载工具类
     */
    public class FtpUtil {
     
        /**
         * Description: 向FTP服务器上传文件
         * @param host FTP服务器hostname
         * @param port FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param basePath FTP服务器基础目录
         * @param filePath FTP服务器文件存放路径。文件的路径为basePath+filePath
         * @param filename 上传到FTP服务器上的文件名
         * @param input 输入流
         * @return 成功返回true，否则返回false
         */  
        public static boolean uploadFile(String host, int port, String username, String password, String basePath,
                String filePath, String filename, InputStream input) {
            boolean result = false;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);// 连接FTP服务器
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
                    return result;
                }
                //切换到上传目录
                if (!ftp.changeWorkingDirectory(basePath+filePath)) {
                    //如果目录不存在创建目录
                    String[] dirs = filePath.split("/");
                    String tempPath = basePath;
                    for (String dir : dirs) {
                        if (null == dir || "".equals(dir)) continue;
                        tempPath += "/" + dir;
                        if (!ftp.changeWorkingDirectory(tempPath)) {  //进不去目录，说明该目录不存在
                            if (!ftp.makeDirectory(tempPath)) { //创建目录
                                //如果创建文件目录失败，则返回
                                System.out.println("创建文件目录"+tempPath+"失败");
                                return result;
                            } else {
                                //目录存在，则直接进入该目录
                                ftp.changeWorkingDirectory(tempPath);    
                            }
                        }
                    }
                }
                //设置上传文件的类型为二进制类型
                ftp.setFileType(FTP.BINARY_FILE_TYPE);
                //上传文件
                if (!ftp.storeFile(filename, input)) {
                    return result;
                }
                input.close();
                ftp.logout();
                result = true;
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
        
        /**
         * Description: 从FTP服务器下载文件
         * @param host FTP服务器hostname
         * @param port FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param remotePath FTP服务器上的相对路径
         * @param fileName 要下载的文件名
         * @param localPath 下载后保存到本地的路径
         * @return
         */  
        public static boolean downloadFile(String host, int port, String username, String password, String remotePath,
                String fileName, String localPath) {
            boolean result = false;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
                    return result;
                }
                ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
                FTPFile[] fs = ftp.listFiles();
                for (FTPFile ff : fs) {
                    if (ff.getName().equals(fileName)) {
                        File localFile = new File(localPath + "/" + ff.getName());
     
                        OutputStream is = new FileOutputStream(localFile);
                        ftp.retrieveFile(ff.getName(), is);
                        is.close();
                    }
                }
     
                ftp.logout();
                result = true;
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
     
        //ftp上传文件测试main函数
        public static void main(String[] args) {
            try {  
                FileInputStream in=new FileInputStream(new File("D:\Tomcat 5.5\pictures\t0176ee418172932841.jpg"));  
                boolean flag = uploadFile("192.168.111.128", 21, "用户名", "密码", "/www/images","/2017/11/19", "hello.jpg", in);  
                System.out.println(flag);  
            } catch (FileNotFoundException e) {  
                e.printStackTrace();  
            }  
        }
    }

 
---------------------
作者：a745233700
来源：CSDN
原文：https://blog.csdn.net/a745233700/article/details/79322757
版权声明：本文为博主原创文章，转载请附上博文链接！

====================

【】注意：用上面的FTP上传文件方法，如果上传的文件名称为中文，会出现乱码，解决方法为：

将上传文件中文件名相关那行

• //上传文件

  if (!ftp.storeFile(filename, input)) {
  return result;
  }

改为：

//上传文件            

 if (!ftp.storeFile(new String(filename.getBytes("GBK"),"iso-8859-1"), input)) {
        return result;
 }

因为FTP上传时，中文名默认为 iso-8859-1 编码，而我们在编辑器中写的中文字符串默认为 GBK 编码。

这是一般情况，如果  领导要求：所有 FTP上传的文件（文件名）都要用 UTF-8 编码，那么就需要将上面代码中的 GBK 改成 UTF-8 ，也就是改成如下：

改为：

//上传文件            

 if (!ftp.storeFile(new String(filename.getBytes("utf-8"),"iso-8859-1"), input)) {
        return result;
 }

还要注意，如果修改了上述的 文件名称编码，那么，对应的 从FTP 取文件的 download 方法中的从FTP读取到的文件名称也要做对应的转换，才能得到我们上传的文件名称，同样，我们用 各种 图形化 工具时也要设置成对应的编码，才能正确显示FTP上的文件名。

-------------

FTP针对UTF-8优化版本：

下面是针对 统一约定用 UTF-8 编码存储文件的优化版本，上传、校验是否存在、下载都没有问题，可以直接使用：

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
     
    /**
     * ftp上传下载工具类lb
     */
    public class FtpUtil3 {
     
        /**
         * Description: 向FTP服务器上传文件
         * @param host FTP服务器hostname
         * @param port FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param basePath FTP服务器基础目录
         * @param filePath FTP服务器文件存放路径。文件的路径为basePath+filePath
         * @param filename 上传到FTP服务器上的文件名
         * @param input 输入流
         * @return 成功返回true，否则返回false
         */  
        public static boolean uploadFile(String host, int port, String username, String password, String basePath,
                String filePath, String filename, InputStream input) {
            boolean result = false;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);// 连接FTP服务器
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
                    return result;
                }
                //切换到上传目录
                if (!ftp.changeWorkingDirectory(basePath+filePath)) {
                    //如果目录不存在创建目录
                    String[] dirs = filePath.split("/");
                    String tempPath = basePath;
                    for (String dir : dirs) {
                        if (null == dir || "".equals(dir)) continue;
                        tempPath += "/" + dir;
                        if (!ftp.changeWorkingDirectory(tempPath)) {  //进不去目录，说明该目录不存在
                            if (!ftp.makeDirectory(tempPath)) { //创建目录
                                //如果创建文件目录失败，则返回
                                System.out.println("创建文件目录"+tempPath+"失败");
                                return result;
                            } else {
                                //目录存在，则直接进入该目录
                                ftp.changeWorkingDirectory(tempPath);    
                            }
                        }
                    }
                }
                //被动模式（可以提高针对不同FTP服务器的兼容性）
                ftp.enterLocalPassiveMode();
                //设置上传文件的类型为二进制类型
                ftp.setFileType(FTP.BINARY_FILE_TYPE);
                //上传文件
//                if (!ftp.storeFile(filename, input)) {
                if (!ftp.storeFile(new String(filename.getBytes("UTF-8"), "iso-8859-1"), input)) {
                    return result;
                }
                input.close();
                ftp.logout();
                result = true;
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
        
        /**
         * Description: 从FTP服务器下载文件
         * @param host FTP服务器hostname
         * @param port FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param remotePath FTP服务器上的相对路径
         * @param fileName 要下载的文件名
         * @param localPath 下载后保存到本地的路径
         * @return
         */  
        public static boolean downloadFile(String host, int port, String username, String password, String remotePath,
                String fileName, String localPath) {
            boolean result = false;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
                    return result;
                }
                ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
                ftp.setControlEncoding("UTF-8");
                //被动模式（可以提高针对不同FTP服务器的兼容性）
                ftp.enterLocalPassiveMode();
                FTPFile[] fs = ftp.listFiles();
                for (FTPFile ff : fs) {
                    if (ff.getName().equals(fileName)) {
                        File localFile = new File(localPath + "/" + ff.getName());
     
                        OutputStream is = new FileOutputStream(localFile);
                        // ftp需使用ISO-8859-1编码格式
                        String realName = new String(ff.getName().getBytes("UTF-8"), "ISO-8859-1");
//                        ftp.retrieveFile(ff.getName(), is);
                        ftp.retrieveFile(realName, is);
                        is.close();
                    }
                }
     
                ftp.logout();
                result = true;
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
        
        /**
         * 直接将远程文件下载到流中【注意：使用完要记住关闭返回的InputStream流】
         * @param host
         * @param port
         * @param username
         * @param password
         * @param remotePath
         * @param fileName
         * @return 直接将远程文件下载到流中
         */
        public static InputStream downloadFile(String host, int port, String username, String password, String remotePath,
                String fileName) {
            InputStream result = null;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
                    return result;
                }
                ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
                ftp.setControlEncoding("UTF-8");
                  //被动模式（可以提高针对不同FTP服务器的兼容性）
                ftp.enterLocalPassiveMode();
                // ftp需使用ISO-8859-1编码格式
                String realName = new String(fileName.getBytes("UTF-8"), "ISO-8859-1");
                result = ftp.retrieveFileStream(realName);
                ftp.logout();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
        
        /**
         * Description: 判断指定名称的文件在FTP服务器上是否存在
         * @param host FTP服务器hostname
         * @param port FTP服务器端口
         * @param username FTP登录账号
         * @param password FTP登录密码
         * @param remotePath FTP服务器上的相对路径
         * @param fileName 要下载的文件名
         * @param localPath 下载后保存到本地的路径
         * @return true：存在   false：不存在/或者方法出现错误
         * @throws Exception 
         */  
        public static boolean isExistInFTP(String host, int port, String username, String password, String remotePath,
                String fileName){
            boolean result = false;
            FTPClient ftp = new FTPClient();
            try {
                int reply;
                ftp.connect(host, port);
                // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
                ftp.login(username, password);// 登录
                reply = ftp.getReplyCode();
                if (!FTPReply.isPositiveCompletion(reply)) {
                    ftp.disconnect();
//                    return result;
                    throw new RuntimeException("FTP连接异常。。。");
                }
                ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
                //这一行一定要有，否则取到的文件名会乱码，无法和参数 fileName 匹配
                ftp.setControlEncoding("UTF-8");
                  //被动模式（可以提高针对不同FTP服务器的兼容性）
                ftp.enterLocalPassiveMode();
                FTPFile[] fs = ftp.listFiles();
                for (FTPFile ff : fs) {
                    String name = ff.getName();
                    if (name.equals(fileName)) {
                        result = true;
                        break;
//                        OutputStream is = new FileOutputStream(localFile);
//                        ftp.retrieveFile(ff.getName(), is);
//                        is.close();
                    }
                }
                ftp.logout();
            } catch (Exception e) {
                System.out.println("------------查询FTP上文件是否存在时出现异常，直接返回：不存在------------");
                e.printStackTrace();
            } finally {
                if (ftp.isConnected()) {
                    try {
                        ftp.disconnect();
                    } catch (IOException ioe) {
                    }
                }
            }
            return result;
        }
     
//        ftp上传文件测试main函数
        public static void main(String[] args) {
            try {  
//                FileInputStream in=new FileInputStream(new File("D:\Tomcat 5.5\pictures\t0176ee418172932841.jpg"));  
//                boolean flag = uploadFile("192.168.111.128", 21, "用户名", "密码", "/www/images","/2017/11/19", "hello.jpg", in);  
                
//                FileInputStream in=new FileInputStream(new File("D:/副本2.txt"));

                boolean flag = false;
//                boolean flag = uploadFile("10.18.90.13", 21, "root", "root", "/crm/fileUpload/Account/test","", "副本291195.txt", in); 
//                flag =uploadFile("10.12.9.163",21,"aps","aps","/crm/fileUpload/Account/test","","副本291195.txt",in);
//                String name = "zhicai-beijing-00000385-20190624.txt";
                String name = "记录.txt";
//                String name = "asgagh2.txt";
//                flag =downloadFile("10.12.9.163", 21, "apps","apps", "/crm/fileUpload/Account/test", name, "D:/a/b/f");
                InputStream input = downloadFile("10.12.9.163", 21, "apps","apps", "/crm/fileUpload/Account/test", name);
                byte[] buffer = new byte[input.available()];
                input.read(buffer);
                FileOutputStream out;
                out = new FileOutputStream("D:/a/b/f/1.txt");
                out.write(buffer);
                out.close();
//                        loadFile("10.12.9.163",21,"apps","apps","/crm/fileUpload/Account/test","","副本291195.txt",in);
//                System.out.println(flag);
//                flag =uploadFile("10.12.4.159",2121,"ji","Y349#","/jitiles/excel","","副本291195.txt",in);
                System.out.println(flag); 
                
//                boolean existInFTP = FtpUtil3.isExistInFTP("10.18.90.13",21,"root","root","/fileUpload/Account/test6","副本291195.txt");
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }
        
    }