詳解springboot通過集成ftp實(shí)現(xiàn)文件上傳的方法

package io.renren.modules.oss.utils;


import org.apache.commons.net.ftp.FTPClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.io.IOException;
import java.io.InputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class FileUtil {

  //ftp服務(wù)器ip地址
  @Value("${custom.config.file-server.ip}") // 相關(guān)配置放在application.properties 中
    String FTP_ADDRESS;
  //端口號(hào)
  @Value("${custom.config.file-server.port}")
  Integer FTP_PORT;
  //用戶名
  @Value("${custom.config.file-ftp-user}")
  String FTP_USERNAME;
  //密碼
  @Value("${custom.config.file-ftp-password}")
  String FTP_PASSWORD;
  //圖片路徑
  @Value("${custom.config.file-savepath}")
  String FTP_BASEPATH;

  //根據(jù)當(dāng)前文件生成 文件夾
  private static String getTimePath() {
    Date now = new Date();

    DateFormat format = new SimpleDateFormat("yyyy/MM/dd/");
    return format.format(now);
  }


  public String upload(InputStream inputStream, String originName) {

    StringBuilder url = new StringBuilder();

    FTPClient ftp = new FTPClient();
    ftp.setControlEncoding("GBK");
    try {
      int reply;
      ftp.connect(FTP_ADDRESS, FTP_PORT);// 連接FTP服務(wù)器
      ftp.login(FTP_USERNAME, FTP_PASSWORD);// 登錄
      reply = ftp.getReplyCode();
      System.out.println("reply:" + reply);

      ftp.enterLocalPassiveMode();//開啟被動(dòng)模式，否則文件上傳不成功，也不報(bào)錯(cuò)

      String timePath = getTimePath();
      String saveDir = FTP_BASEPATH + timePath;
      url.append(saveDir);

      ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
      createDir(ftp, saveDir);
      //ftp.makeDirectory(saveDir);
      //   ftp.changeWorkingDirectory(FTP_BASEPATH);
      originName= System.currentTimeMillis()+originName.substring(originName.lastIndexOf('.'));
      url.append(originName);
      ftp.storeFile(originName, inputStream);
      inputStream.close();
      ftp.logout();

    } catch (IOException e) {
      throw new RuntimeException("文件上傳失敗");
    } finally {
      if (ftp.isConnected()) {
        try {
          ftp.disconnect();
        } catch (IOException ioe) {
        }
      }
    }

    return url.toString();
  }

  // 創(chuàng)建文件夾，并切換到該文件夾
  // 比如： hello/test
  //最終會(huì)切換到test 文件夾返回
  private void createDir(FTPClient client, String path) throws IOException {
    String[] dirs = path.split("/");
    for (String dir : dirs) {
      if (StringUtils.isEmpty(dir)) {
        continue;
      }
      if (!client.changeWorkingDirectory(dir)) {
        client.makeDirectory(dir);
      }
      client.changeWorkingDirectory(dir);
    }
  }

}

#//ftp服務(wù)器ip地址
custom.config.file-server.ip=111.229.65.208
#String FTP_ADDRESS;
#//端口號(hào)
custom.config.file-server.port=21
#Integer FTP_PORT;
#//用戶名
custom.config.file-ftp-user=root
#String FTP_USERNAME;
#//密碼
custom.config.file-ftp-password=123456
#String FTP_PASSWORD;
#//圖片路徑
custom.config.file-savepath=/upload
#String FTP_BASEPATH;

 /**
  * 上傳文件
  */
String fileUrl = fileUtil.upload(file.getInputStream(), file.getOriginalFilename());