真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

SpringFTP如何實現(xiàn)上傳下載工具類

這篇文章給大家分享的是有關(guān)Spring FTP如何實現(xiàn)上傳下載工具類的內(nèi)容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。

目前累計服務客戶成百上千家,積累了豐富的產(chǎn)品開發(fā)及服務經(jīng)驗。以網(wǎng)站設計水平和技術(shù)實力,樹立企業(yè)形象,為客戶提供成都網(wǎng)站設計、網(wǎng)站建設、網(wǎng)站策劃、網(wǎng)頁設計、網(wǎng)絡營銷、VI設計、網(wǎng)站改版、漏洞修補等服務。成都創(chuàng)新互聯(lián)始終以務實、誠信為根本,不斷創(chuàng)新和提高建站品質(zhì),通過對領(lǐng)先技術(shù)的掌握、對創(chuàng)意設計的研究、對客戶形象的視覺傳遞、對應用系統(tǒng)的結(jié)合,為客戶提供更好的一站式互聯(lián)網(wǎng)解決方案,攜手廣大客戶,共同發(fā)展進步。

最近在項目中需要和ftp服務器進行交互,在網(wǎng)上找了一下關(guān)于ftp上傳下載的工具類,大致有兩種。

第一種是單例模式的類。

第二種是另外定義一個Service,直接通過Service來實現(xiàn)ftp的上傳下載。

這兩種感覺都有利弊。

第一種實現(xiàn)了代碼復用,但是配置信息全需要寫在類中,維護比較復雜。

第二種如果是spring框架,可以通過propertis文件,動態(tài)的注入配置信息,但是又不能代碼復用。

所以我打算自己實現(xiàn)一個工具類,來把上面的兩種優(yōu)點進行整合。順便把一些上傳過程中一些常見的問題也給解決了。

因為我使用的是spring框架,如果把工具類聲明為bean給spring管理,他默認就是單例的,所以不需要我再實現(xiàn)單例。并且因為是bean,所以我可以把properties文件的屬性注入bean的屬性中,實現(xiàn)解耦,下面是具體代碼:

package com.cky.util;
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;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
//使用spring自動生成單例對象,
//@Component
public class FtpUtil {
  //通過properties文件自動注入
  @Value("${ftp.host}")
  private String host;  //ftp服務器ip
  @Value("${ftp.port}")
  private int port;    //ftp服務器端口
  @Value("${ftp.username}")
  private String username;//用戶名
  @Value("${ftp.password}")
  private String password;//密碼
  @Value("${ftp.basePath}")
  private String basePath;//存放文件的基本路徑
  //測試的時候把這個構(gòu)造函數(shù)打開,設置你的初始值,然后在代碼后面的main方法運行測試
  /*public FtpUtil() {
    //System.out.println(this.toString());
    host="192.168.100.77";
    port=21;
    username="ftpuser";
    password="ftp54321";
    basePath="/home/ftpuser/";
  }*/
  /**
   * 
   * @param path    上傳文件存放在服務器的路徑
   * @param filename  上傳文件名
   * @param input    輸入流
   * @return
   */
  public boolean fileUpload(String path,String filename,InputStream input) {
    FTPClient ftp=new FTPClient();
    try {
      ftp.connect(host, port);
      ftp.login(username, password);
      //設置文件編碼格式
      ftp.setControlEncoding("UTF-8");
      //ftp通信有兩種模式
        //PORT(主動模式)客戶端開通一個新端口(>1024)并通過這個端口發(fā)送命令或傳輸數(shù)據(jù),期間服務端只使用他開通的一個端口,例如21
        //PASV(被動模式)客戶端向服務端發(fā)送一個PASV命令,服務端開啟一個新端口(>1024),并使用這個端口與客戶端的21端口傳輸數(shù)據(jù)
        //由于客戶端不可控,防火墻等原因,所以需要由服務端開啟端口,需要設置被動模式
      ftp.enterLocalPassiveMode();
      //設置傳輸方式為流方式
      ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
      //獲取狀態(tài)碼,判斷是否連接成功
      if(!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
        throw new RuntimeException("FTP服務器拒絕連接");
      }
      //轉(zhuǎn)到上傳文件的根目錄
      if(!ftp.changeWorkingDirectory(basePath)) {
        throw new RuntimeException("根目錄不存在,需要創(chuàng)建");
      }
      //判斷是否存在目錄
      if(!ftp.changeWorkingDirectory(path)) {
        String[] dirs=path.split("/");
        //創(chuàng)建目錄
        for (String dir : dirs) {
          if(null==dir||"".equals(dir)) continue;
          //判斷是否存在目錄
          if(!ftp.changeWorkingDirectory(dir)) {
            //不存在則創(chuàng)建
            if(!ftp.makeDirectory(dir)) {
              throw new RuntimeException("子目錄創(chuàng)建失敗");
            }
            //進入新創(chuàng)建的目錄
            ftp.changeWorkingDirectory(dir);
          }
        }
        //設置上傳文件的類型為二進制類型
        ftp.setFileType(FTP.BINARY_FILE_TYPE);
        //上傳文件
        if(!ftp.storeFile(filename, input)) {
          return false;
        }
        input.close();
        ftp.logout();
        return true;
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }finally {
      if(ftp.isConnected()) {
        try {
          ftp.disconnect();
        } catch (IOException e) {
          throw new RuntimeException(e);
        }
      }
    }
    return false;
  }
  /**
   * 
   * @param filename  文件名,注意!此處文件名為加路徑文件名,如:/2015/06/04/aa.jpg
   * @param localPath  存放到本地第地址
   * @return    
   */
  public boolean downloadFile(String filename,String localPath) {
    FTPClient ftp=new FTPClient();
    try {
      ftp.connect(host, port);
      ftp.login(username, password);
      //設置文件編碼格式
      ftp.setControlEncoding("UTF-8");
      //ftp通信有兩種模式
        //PORT(主動模式)客戶端開通一個新端口(>1024)并通過這個端口發(fā)送命令或傳輸數(shù)據(jù),期間服務端只使用他開通的一個端口,例如21
        //PASV(被動模式)客戶端向服務端發(fā)送一個PASV命令,服務端開啟一個新端口(>1024),并使用這個端口與客戶端的21端口傳輸數(shù)據(jù)
        //由于客戶端不可控,防火墻等原因,所以需要由服務端開啟端口,需要設置被動模式
      ftp.enterLocalPassiveMode();
      //設置傳輸方式為流方式
      ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);
      //獲取狀態(tài)碼,判斷是否連接成功
      if(!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
        throw new RuntimeException("FTP服務器拒絕連接");
      }
      int index=filename.lastIndexOf("/");
      //獲取文件的路徑
      String path=filename.substring(0, index);
      //獲取文件名
      String name=filename.substring(index+1);
      //判斷是否存在目錄
      if(!ftp.changeWorkingDirectory(basePath+path)) {
        throw new RuntimeException("文件路徑不存在:"+basePath+path);
      }
      //獲取該目錄所有文件
      FTPFile[] files=ftp.listFiles();
      for (FTPFile file : files) {
        //判斷是否有目標文件
        //System.out.println("文件名"+file.getName()+"---"+name);
        if(file.getName().equals(name)) {
          //System.out.println("找到文件");
          //如果找到,將目標文件復制到本地
          File localFile =new File(localPath+"/"+file.getName());
          OutputStream out=new FileOutputStream(localFile);
          ftp.retrieveFile(file.getName(), out);
          out.close();
        }
      }
      ftp.logout();
      return true;
    } catch (Exception e) {
      throw new RuntimeException(e);
    }finally {
      if(ftp.isConnected()) {
        try {
          ftp.disconnect();
        } catch (IOException e) {
          throw new RuntimeException(e);
        }
      }
    }
  }
  //兩個功能其中一個使用的話另一個需要注釋
  public static void main(String []args) {
    //上傳測試-----------------------------------
    /*FileInputStream in;
    try {
      in=new FileInputStream(new File("C:\\Users\\Administrator\\Desktop\\json.png"));
      FtpUtil ftputil=new FtpUtil();
      boolean flag=ftputil.fileUpload("/2015/06/04", "aa.jpg", in);
      System.out.println(flag);
    }catch (Exception e) {
      e.printStackTrace();
    }finally {
    }*/
    //下載測試--------------------------------------
    String filename="/2015/06/04/aa.jpg";
    String localPath="F:\\";
    FtpUtil ftputil=new FtpUtil();
    ftputil.downloadFile(filename, localPath);
  }
  //get set方法自己添加
  //..............
}

具體使用

第一步:配置spring加載properties文件

applicationContext.xml


  ftp.properties
ftp.host=192.168.100.77
ftp.port=21
ftp.username=ftpuser
ftp.password=ftp54321
ftp.basePath=/home/ftpuser/

第二步:將工具類聲明為bean

xml方式


    
    
    
    
    
  

注解方式,組件掃描

第三部:注入使用

@Autowired
  private FtpUtil ftpUtil;

感謝各位的閱讀!關(guān)于“Spring FTP如何實現(xiàn)上傳下載工具類”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!


名稱欄目:SpringFTP如何實現(xiàn)上傳下載工具類
URL地址:http://weahome.cn/article/iiceoj.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部