Java如何使用Sftp和Ftp实现对文件的上传和下载

这篇文章将为大家详细讲解有关Java如何使用Sftp和Ftp实现对文件的上传和下载，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

第一步，导入Maven依赖

<!-- FTP依赖包 --><dependency>  <groupId>commons-net</groupId>  <artifactId>commons-net</artifactId>  <version>3.6</version></dependency><!-- SFTP依赖包 --><dependency>  <groupId>com.jcraft</groupId>  <artifactId>jsch</artifactId>  <version>0.1.55</version></dependency><dependency>  <groupId>commons-io</groupId>  <artifactId>commons-io</artifactId>  <version>2.6</version></dependency>

第二步，创建并编写SftpUtils类，运行main方法查看效果，如下

import com.jcraft.jsch.*;import lombok.extern.slf4j.Slf4j;import org.apache.commons.io.IOUtils;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.util.Properties;import java.util.Vector;@Slf4jpublic class SftpUtils {  public static void main(String[] args) throws Exception {    log.info("测试开始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");    // 1    File file = new File("E:\\2.xlsx");    InputStream inputStream = new FileInputStream(file);    SftpUtils.uploadFile("", "", "", 22, "/usr/local",        "/testfile/", "test.xlsx", null, inputStream);    // 2    SftpUtils.downloadFile("", "", "", 22,null,        "/usr/local/testfile/", "test.csv","/Users/ao/Desktop/test.csv");    // 3    SftpUtils.deleteFile("", "", "", 22,null,        "/usr/local/testfile/", "test.xlsx");    // 4    Vector<?> fileList = SftpUtils.getFileList("", "", "",        22, null,"/usr/local/testfile/");    log.info(fileList.toString());    log.info("测试结束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");  }    public static void uploadFile(String userName, String passWord, String host, int port, String basePath,                   String filePath, String filename, String privateKey, InputStream input) throws Exception {    Session session = null;    ChannelSftp sftp = null;    // 连接sftp服务器    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();    }    // 将输入流的数据上传到sftp作为文件    try {      sftp.cd(basePath);      sftp.cd(filePath);    } catch (SftpException e) {      //目录不存在，则创建文件夹      String [] dirs=filePath.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, filename);    //关闭连接 server    if (sftp != null) {      if (sftp.isConnected()) {        sftp.disconnect();      }    }    //关闭连接 server    if (session != null) {      if (session.isConnected()) {        session.disconnect();      }    }  }    public static void downloadFile(String userName, String password, String host, int port, String privateKey, String directory,                String downloadFile, String saveFile) throws Exception{    Session session = null;    ChannelSftp sftp = null;    // 连接sftp服务器    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();    }    if (directory != null && !"".equals(directory)) {      sftp.cd(directory);    }    File file = new File(saveFile);    sftp.get(downloadFile, new FileOutputStream(file));  }    public static byte[] downloadFile(String userName, String password, String host, int port, String privateKey,                 String directory, String downloadFile) throws Exception{    Session session = null;    ChannelSftp sftp = null;    // 连接sftp服务器    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();    }    if (directory != null && !"".equals(directory)) {      sftp.cd(directory);    }    InputStream is = sftp.get(downloadFile);    byte[] fileData = IOUtils.toByteArray(is);    return fileData;  }    public static void deleteFile(String userName, String password, String host, int port, String privateKey,               String directory, String deleteFile) throws Exception{    Session session = null;    ChannelSftp sftp = null;    // 连接sftp服务器    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();    }    sftp.cd(directory);    sftp.rm(deleteFile);  }    public static Vector<?> getFileList(String userName, String password, String host, int port, String privateKey,                   String directory) throws Exception {    Session session = null;    ChannelSftp sftp = null;    // 连接sftp服务器    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();    }    return sftp.ls(directory);  }}

第三步，创建并编写FtpUtils类，运行main方法查看效果，如下

import lombok.extern.slf4j.Slf4j;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;import java.io.*;@Slf4jpublic class FtpUtils {  public static void main(String[] args) throws Exception {    log.info("测试开始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");    // 1    File file = new File("E:\\2.xlsx");    InputStream inputStream = new FileInputStream(file);    FtpUtils.uploadFile("", 21, "", "", "/usr/local",        "/testfile/", "test.xlsx", inputStream);    // 2    FtpUtils.downloadFile("", 21, "", "","/usr/local/testfile/",        "test.csv", "/Users/ao/Desktop/test.csv");    log.info("测试结束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");  }    public static boolean uploadFile(String host, int port, String userName, String password, String basePath,                   String filePath, String filename, InputStream input) throws Exception{    boolean result = false;    FTPClient ftp = new FTPClient();    try {      int reply;      // 连接FTP服务器      ftp.connect(host, port);      // 如果采用默认端口，可以使用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)) {              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;  }    public static boolean downloadFile(String host, int port, String userName, String password, String remotePath,                    String fileName, String localPath) throws Exception {    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服务器目录      ftp.changeWorkingDirectory(remotePath);      FTPFile[] fs = ftp.listFiles();      for (FTPFile ff : fs) {        if (ff.getName().equals(fileName)) {          java.io.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;  }  }

关于“Java如何使用Sftp和Ftp实现对文件的上传和下载”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。