자바 는 Sftp 와 Ftp 를 사용 하여 파일 업로드 와 다운 로드 를 실현 합 니 다.

17358 단어 JavaSftpFtp업로드
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;

/**
 * @Description: sftp       
 * @Author: jinhaoxun
 * @Date: 2020/1/16 16:13
 * @Version: 1.0.0
 */
@Slf4j
public 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("    !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
  }

  /**
   * @Author: jinhaoxun
   * @Description:     
   * @param userName    
   * @param password   
   * @param host ip
   * @param port   
   * @param basePath    
   * @param filePath     (     )
   * @param filename    
   * @param privateKey   
   * @param input    
   * @Date: 2020/1/16 21:23
   * @Return: void
   * @Throws: Exception
   */
  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();
      }
    }
  }

  /**
   * @Author: jinhaoxun
   * @Description:     
   * @param userName    
   * @param password   
   * @param host ip
   * @param port   
   * @param privateKey   
   * @param directory     
   * @param downloadFile    
   * @param saveFile        
   * @Date: 2020/1/16 21:22
   * @Return: void
   * @Throws: Exception
   */
  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));
  }

  /**
   * @Author: jinhaoxun
   * @Description:     
   * @param userName    
   * @param password   
   * @param host ip
   * @param port   
   * @param privateKey   
   * @param directory     
   * @param downloadFile    
   * @Date: 2020/1/16 21:21
   * @Return: byte[]
   * @Throws: Exception
   */
  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;
  }

  /**
   * @Author: jinhaoxun
   * @Description:     
   * @param userName    
   * @param password   
   * @param host ip
   * @param port   
   * @param privateKey   
   * @param directory     
   * @param deleteFile    
   * @Date: 2020/1/16 21:24
   * @Return: void
   * @Throws: Exception
   */
  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);
  }

  /**
   * @Author: jinhaoxun
   * @Description:         
   * @param userName    
   * @param password   
   * @param host ip
   * @param port   
   * @param privateKey   
   * @param directory       
   * @Date: 2020/1/16 21:25
   * @Return: java.util.Vector<?>
   * @Throws: Exception
   */
  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.*;

/**
 * @Description: ftp       
 * @Author: jinhaoxun
 * @Date: 2020/1/16 15:46
 * @Version: 1.0.0
 */
@Slf4j
public 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("    !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
  }

  /**
   * @Author: jinhaoxun
   * @Description:  FTP       
   * @param host FTP   hostname
   * @param port FTP     
   * @param userName FTP    
   * @param password FTP    
   * @param basePath FTP       
   * @param filePath FTP         。       :/2015/01/01。      basePath+filePath
   * @param filename    FTP        
   * @param input              
   * @Date: 2020/1/16 19:31
   * @Return: boolean
   * @Throws: Exception
   */
  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;
  }

  /**
   * @Author: jinhaoxun
   * @Description:  FTP       
   * @param host FTP   hostname
   * @param port FTP     
   * @param userName FTP    
   * @param password FTP    
   * @param remotePath FTP         
   * @param fileName        
   * @param localPath            
   * @Date: 2020/1/16 19:34
   * @Return: boolean
   * @Throws: Exception
   */
  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;
  }  
}
전체 코드 주소:https://github.com/luoyusoft/java-demo
주:이 프로젝트 는 여러 개의 패 키 지 를 포함 하고 있 습 니 다.FtpUtils 코드 는 모두 com.luoyu.java.ftp 패키지 에 있 습 니 다.
주:이 프로젝트 는 여러 개의 가방 을 포함 하고 있 습 니 다.SftpUtils 코드 는 모두 com.luoyu.java.sftp 패키지 에 있 습 니 다.
자바 가 Sftp 와 Ftp 를 사용 하여 파일 업로드 와 다운 로드 를 실현 하 는 것 에 관 한 이 글 은 여기까지 소개 되 었 습 니 다.더 많은 자바 가 Sftp 와 Ftp 파일 을 사용 하여 업로드 와 다운로드 내용 은 우리 의 이전 글 을 검색 하거나 아래 의 관련 글 을 계속 조회 하 시기 바 랍 니 다.앞으로 도 많은 지원 바 랍 니 다!

좋은 웹페이지 즐겨찾기