欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解JAVA中使用FTPClient工具類上傳下載

 更新時間：2017年08月02日 14:24:02   作者：快樂的燕子會飛  
這篇文章主要介紹了JAVA中使用FTPClient工具類上傳下載的相關(guān)資料,java 使用FTP服務(wù)器上傳文件、下載文件，需要的朋友可以參考下

詳解JAVA中使用FTPClient工具類上傳下載

在Java程序中，經(jīng)常需要和FTP打交道，比如向FTP服務(wù)器上傳文件、下載文件。本文簡單介紹如何利用jakarta commons中的FTPClient（在commons-net包中）實現(xiàn)上傳下載文件。

1、寫一個javabean文件，描述ftp上傳或下載的信息

實例代碼：

public class FtpUseBean { 
  private String host; 
  private Integer port; 
  private String userName; 
  private String password; 
  private String ftpSeperator; 
  private String ftpPath=""; 
  private int repeatTime = 0;//連接ftp服務(wù)器的次數(shù) 
   
  public String getHost() { 
    return host; 
  } 
   
  public void setHost(String host) { 
    this.host = host; 
  } 
 
  public Integer getPort() { 
    return port; 
  } 
  public void setPort(Integer port) { 
    this.port = port; 
  } 
   
   
  public String getUserName() { 
    return userName; 
  } 
   
  public void setUserName(String userName) { 
    this.userName = userName; 
  } 
   
  public String getPassword() { 
    return password; 
  } 
   
  public void setPassword(String password) { 
    this.password = password; 
  } 
 
  public void setFtpSeperator(String ftpSeperator) { 
    this.ftpSeperator = ftpSeperator; 
  } 
 
  public String getFtpSeperator() { 
    return ftpSeperator; 
  } 
 
  public void setFtpPath(String ftpPath) { 
    if(ftpPath!=null) 
      this.ftpPath = ftpPath; 
  } 
 
  public String getFtpPath() { 
    return ftpPath; 
  } 
 
  public void setRepeatTime(int repeatTime) { 
    if (repeatTime > 0) 
      this.repeatTime = repeatTime; 
  } 
 
  public int getRepeatTime() { 
    return repeatTime; 
  } 
 
  /** 
   * take an example:<br> 
   * ftp://userName:password@ip:port/ftpPath/ 
   * @return 
   */ 
  public String getFTPURL() { 
    StringBuffer buf = new StringBuffer(); 
    buf.append("ftp://"); 
    buf.append(getUserName()); 
    buf.append(":"); 
    buf.append(getPassword()); 
    buf.append("@"); 
    buf.append(getHost()); 
    buf.append(":"); 
    buf.append(getPort()); 
    buf.append("/"); 
    buf.append(getFtpPath()); 
      
    return buf.toString(); 
  } 
}

2、導(dǎo)入包commons-net-1.4.1.jar  

package com.util; 
 
import java.io.BufferedReader; 
import java.io.ByteArrayOutputStream; 
import java.io.DataOutputStream; 
import java.io.File; 
import java.io.FileOutputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.io.OutputStream; 
import java.net.SocketException; 
import java.net.URL; 
import java.net.URLConnection; 
 
import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
import org.apache.commons.net.ftp.FTP; 
import org.apache.commons.net.ftp.FTPClient; 
import org.apache.commons.net.ftp.FTPClientConfig; 
import org.apache.commons.net.ftp.FTPFile; 
 
import com.bean.FtpUseBean; 
 
public class FtpUtil extends FTPClient { 
 
  private static Log log = LogFactory.getLog(FtpUtil.class); 
  private FtpUseBean ftpUseBean; 
  //獲取目標路徑下的文件屬性信息，主要是獲取文件的size 
  private FTPFile[] files; 
     
  public FtpUseBean getFtpUseBean() { 
    return ftpUseBean; 
  } 
 
 
  public FtpUtil(){ 
    super(); 
  } 
   
   
  public void setFtpUseBean(FtpUseBean ftpUseBean) { 
    this.ftpUseBean = ftpUseBean; 
  } 
   
  public boolean ftpLogin() { 
    boolean isLogined = false; 
    try { 
      log.debug("ftp login start ..."); 
      int repeatTime = ftpUseBean.getRepeatTime(); 
      for (int i = 0; i < repeatTime; i++) { 
        super.connect(ftpUseBean.getHost(), ftpUseBean.getPort()); 
        isLogined = super.login(ftpUseBean.getUserName(), ftpUseBean.getPassword()); 
        if (isLogined) 
          break; 
      } 
      if(isLogined) 
        log.debug("ftp login successfully ..."); 
      else 
        log.debug("ftp login failed ..."); 
      return isLogined; 
    } catch (SocketException e) { 
      log.error("", e); 
      return false; 
    } catch (IOException e) { 
      log.error("", e); 
      return false; 
    } catch (RuntimeException e) { 
      log.error("", e); 
      return false; 
    } 
  } 
 
  public void setFtpToUtf8() throws IOException { 
 
    FTPClientConfig conf = new FTPClientConfig(); 
    super.configure(conf); 
    super.setFileType(FTP.IMAGE_FILE_TYPE); 
    int reply = super.sendCommand("OPTS UTF8 ON"); 
    if (reply == 200) { // UTF8 Command 
      super.setControlEncoding("UTF-8"); 
    } 
 
  } 
 
  public void close() { 
    if (super.isConnected()) { 
      try { 
        super.logout(); 
        super.disconnect(); 
        log.debug("ftp logout ...."); 
      } catch (Exception e) { 
        log.error(e.getMessage()); 
        throw new RuntimeException(e.toString()); 
      } 
    } 
  } 
 
  public void uploadFileToFtpByIS(InputStream inputStream, String fileName) throws IOException { 
    super.storeFile(ftpUseBean.getFtpPath()+fileName, inputStream); 
  } 
 
  public File downFtpFile(String fileName, String localFileName) throws IOException { 
    File outfile = new File(localFileName); 
    OutputStream oStream = null; 
    try { 
      oStream = new FileOutputStream(outfile); 
      super.retrieveFile(ftpUseBean.getFtpPath()+fileName, oStream); 
      return outfile; 
    } finally { 
      if (oStream != null) 
        oStream.close(); 
    } 
  } 
 
 
  public FTPFile[] listFtpFiles() throws IOException { 
    return super.listFiles(ftpUseBean.getFtpPath()); 
  } 
 
  public void deleteFtpFiles(FTPFile[] ftpFiles) throws IOException { 
    String path = ftpUseBean.getFtpPath(); 
    for (FTPFile ff : ftpFiles) { 
      if (ff.isFile()) { 
        if (!super.deleteFile(path + ff.getName())) 
          throw new RuntimeException("delete File" + ff.getName() + " is n't seccess"); 
      } 
    } 
  } 
 
  public void deleteFtpFile(String fileName) throws IOException { 
    if (!super.deleteFile(ftpUseBean.getFtpPath() +fileName)) 
      throw new RuntimeException("delete File" + ftpUseBean.getFtpPath() +fileName + " is n't seccess"); 
  } 
 
  public InputStream downFtpFile(String fileName) throws IOException { 
    return super.retrieveFileStream(ftpUseBean.getFtpPath()+fileName); 
  } 
 
  /** 
   * 
   * @return 
   * @return StringBuffer 
   * @description 下載ftp服務(wù)器上的文件,addr為帶用戶名和密碼的URL 
   */ 
  public StringBuffer downloadBufferByURL(String addr) { 
    BufferedReader in = null; 
    try { 
      URL url = new URL(addr); 
      URLConnection conn = url.openConnection(); 
      in = new BufferedReader(new InputStreamReader(conn.getInputStream())); 
      String line; 
      StringBuffer ret = new StringBuffer(); 
      while ((line = in.readLine()) != null) 
        ret.append(line); 
       
      return ret; 
    } catch (Exception e) { 
      log.error(e); 
      return null; 
    } finally { 
      try { 
        if (null != in) 
          in.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
        log.error(e); 
      } 
    } 
  } 
 
  /** 
   * 
   * @return 
   * @return byte[] 
   * @description 下載ftp服務(wù)器上的文件,addr為帶用戶名和密碼的URL 
   */ 
  public byte[] downloadByteByURL(String addr) { 
     
    FTPClient ftp = null; 
     
    try { 
       
      URL url = new URL(addr); 
       
      int port = url.getPort()!=-1?url.getPort():21; 
      log.info("HOST:"+url.getHost()); 
      log.info("Port:"+port); 
      log.info("USERINFO:"+url.getUserInfo()); 
      log.info("PATH:"+url.getPath()); 
       
      ftp = new FTPClient(); 
       
      ftp.setDataTimeout(30000); 
      ftp.setDefaultTimeout(30000); 
      ftp.setReaderThread(false); 
      ftp.connect(url.getHost(), port); 
      ftp.login(url.getUserInfo().split(":")[0], url.getUserInfo().split(":")[1]); 
      FTPClientConfig conf = new FTPClientConfig("UNIX");   
           ftp.configure(conf);  
      log.info(ftp.getReplyString()); 
       
      ftp.enterLocalPassiveMode(); //ftp.enterRemotePassiveMode()  
      ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);  
 
      int reply = ftp.sendCommand("OPTS UTF8 ON");// try to 
       
      log.debug("alter to utf-8 encoding - reply:" + reply); 
      if (reply == 200) { // UTF8 Command 
        ftp.setControlEncoding("UTF-8"); 
      } 
      ftp.setFileType(FTPClient.BINARY_FILE_TYPE); 
 
      log.info(ftp.getReplyString()); 
       
      ByteArrayOutputStream out=new ByteArrayOutputStream(); 
           DataOutputStream o=new DataOutputStream(out); 
           String remotePath = url.getPath(); 
           /** 
           * Fixed:if doen't remove the first "/" at the head of url, 
            * the file can't be retrieved. 
           */ 
           if(remotePath.indexOf("/")==0) { 
             remotePath = url.getPath().replaceFirst("/", ""); 
           } 
           ftp.retrieveFile(remotePath, o);       
      byte[] ret = out.toByteArray(); 
      o.close(); 
       
      String filepath = url.getPath(); 
      ftp.changeWorkingDirectory(filepath.substring(0,filepath.lastIndexOf("/"))); 
      files = ftp.listFiles(); 
       
      return ret; 
        } catch (Exception ex) { 
      log.error("Failed to download file from ["+addr+"]!"+ex); 
       } finally { 
      try { 
        if (null!=ftp) 
          ftp.disconnect(); 
      } catch (Exception e) { 
        // 
      } 
    } 
    return null; 
//   StringBuffer buffer = downloadBufferByURL(addr); 
//   return null == buffer ? null : buffer.toString().getBytes(); 
  } 
   
   
   
   
  public FTPFile[] getFiles() { 
    return files; 
  } 
 
 
  public void setFiles(FTPFile[] files) { 
    this.files = files; 
  } 
 
 
// public static void getftpfilesize(String addr){ 
//    
//   FTPClient ftp = null; 
//    
//   try { 
//      
//     URL url = new URL(addr); 
//      
//     int port = url.getPort()!=-1?url.getPort():21; 
//     log.info("HOST:"+url.getHost()); 
//     log.info("Port:"+port); 
//     log.info("USERINFO:"+url.getUserInfo()); 
//     log.info("PATH:"+url.getPath()); 
//      
//     ftp = new FTPClient(); 
//      
//     ftp.setDataTimeout(30000); 
//     ftp.setDefaultTimeout(30000); 
//     ftp.setReaderThread(false); 
//     ftp.connect(url.getHost(), port); 
//     ftp.login(url.getUserInfo().split(":")[0], url.getUserInfo().split(":")[1]); 
//     FTPClientConfig conf = new FTPClientConfig("UNIX");   
//     ftp.configure(conf);  
//     log.info(ftp.getReplyString()); 
//      
//     ftp.enterLocalPassiveMode(); //ftp.enterRemotePassiveMode()  
//     ftp.setFileTransferMode(FTP.STREAM_TRANSFER_MODE);  
// 
//     int reply = ftp.sendCommand("OPTS UTF8 ON");// try to 
//      
//     log.debug("alter to utf-8 encoding - reply:" + reply); 
//     if (reply == 200) { // UTF8 Command 
//       ftp.setControlEncoding("UTF-8"); 
//     } 
//     ftp.setFileType(FTPClient.BINARY_FILE_TYPE); 
//     ftp.changeWorkingDirectory(url.getPath()); 
//     FTPFile[] files = ftp.listFiles(); 
//     for (FTPFile flie : files){ 
//       System.out.println(new String(flie.getName().getBytes("gbk"),"ISO8859-1")); 
//       System.out.println(flie.getSize()); 
//     } 
//      
// 
//   } catch (Exception ex) { 
//     log.error("Failed to download file from ["+addr+"]!"+ex); 
//   } finally { 
//     try {<pre class="java" name="code">     if (null!=ftp) 
//     ftp.disconnect(); 
 //     } catch (Exception e) { 
} 
} 
} 
}

以上就是JAVA FTPClient工具類的上傳和下載的實例詳解，如有疑問請留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

相關(guān)文章

  • Java實現(xiàn)二叉樹的建立、計算高度與遞歸輸出操作示例

    Java實現(xiàn)二叉樹的建立、計算高度與遞歸輸出操作示例

    這篇文章主要介紹了Java實現(xiàn)二叉樹的建立、計算高度與遞歸輸出操作,結(jié)合實例形式分析了Java二叉樹的創(chuàng)建、遍歷、計算等相關(guān)算法實現(xiàn)技巧,需要的朋友可以參考下
    2019-03-03
  • Spring?MVC中的Controller進行單元測試的實現(xiàn)

    Spring?MVC中的Controller進行單元測試的實現(xiàn)

    本文主要介紹了如何對Spring?MVC中的Controller進行單元測試的實現(xiàn)，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-02-02
  • Java多線程之條件對象Condition

    Java多線程之條件對象Condition

    這篇文章主要介紹了Java多線程之條件對象Condition，Condition中的await()方法相當于Object的wait()方法，Condition中的signal()方法相當于Object的notify()方法，Condition中的signalAll()相當于Object的notifyAll()方法，接下來和小編一起進入文章了解更具體的內(nèi)容
    2021-10-10
  • Mybatis-Plus 映射匹配兼容性的問題解決

    Mybatis-Plus 映射匹配兼容性的問題解決

    本文主要介紹了Mybatis-Plus 映射匹配兼容性的問題解決，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-01-01
  • JAVA Swing實現(xiàn)窗口添加課程信息過程解析

    JAVA Swing實現(xiàn)窗口添加課程信息過程解析

    這篇文章主要介紹了JAVA Swing實現(xiàn)窗口添加課程信息過程解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-10-10
  • 詳解Java正則表達式語法

    詳解Java正則表達式語法

    這篇文章主要介紹了Java正則表達式語法，包括常用正則表達式、匹配驗證-驗證Email是否正確以及字符串中查詢字符或者字符串，感興趣的小伙伴們可以參考一下
    2015-12-12
  • SpringMVC五大組件與執(zhí)行原理分析總結(jié)

    SpringMVC五大組件與執(zhí)行原理分析總結(jié)

    這篇文章主要介紹了SpringMVC五大組件與執(zhí)行原理分析總結(jié)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧
    2023-01-01
  • 關(guān)于@Scheduled注解的任務(wù)為什么不執(zhí)行的問題

    關(guān)于@Scheduled注解的任務(wù)為什么不執(zhí)行的問題

    這篇文章主要介紹了關(guān)于@Scheduled注解的任務(wù)為什么不執(zhí)行的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2022-09-09
  • Spring Boot接收單個String入?yún)⒌慕鉀Q方法

    Spring Boot接收單個String入?yún)⒌慕鉀Q方法

    這篇文章主要給大家介紹了關(guān)于Spring Boot接收單個String入?yún)⒌慕鉀Q方法，文中通過示例代碼介紹的非常詳細，對大家學(xué)習(xí)或者使用spring boot具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2018-11-11
  • Java基于socket實現(xiàn)簡易聊天室實例

    Java基于socket實現(xiàn)簡易聊天室實例

    這篇文章主要介紹了Java基于socket實現(xiàn)簡易聊天室的方法,實例分析了java基于socket實現(xiàn)聊天室服務(wù)端與客戶端的相關(guān)技巧,需要的朋友可以參考下
    2015-05-05

最新評論