如何在JAVA项目中利用FTPClient工具类实现一个上传下载功能

如何在JAVA项目中利用FTPClient工具类实现一个上传下载功能？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

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服务器的次数      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;   }       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、导入包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);   }       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);       }     }   }       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();                        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) { } } } }

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注编程网行业资讯频道，感谢您对编程网的支持。