Java 实现FTP服务实例详解

<!-- 文件上传组件 -->  <dependency>    <groupId>commons-fileupload</groupId>    <artifactId>commons-fileupload</artifactId>  </dependency> 

package testController;  import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; import org.chenzhengyou.common.util.FtpUtil; import org.junit.Test;  import java.io.File; import java.io.FileInputStream;  /**  * @auther 陈郑游  * @create 2016-11-23-19:27  * @功能描述 图片测试  * @公司地址  */  public class FtpController {    //主机地址 端口号   private String HOSTNAME = "127.0.0.1";   private Integer PORT = 21;   //本地图片路径   private String FilePackage = "F://Programming_Package//IMG_3733_1.JPG";    //用户名 密码   private String USERNAME = "czy";   private String PASSWORD = "czy";    /**    * 无工具类图片测试    * */   @Test   public void testFtp() throws Exception {     //创建一个FtpClient对象     FTPClient ftpClient = new FTPClient();     //创建ftp连接。默认是21端口     ftpClient.connect(HOSTNAME,PORT);     //登录ftp服务器，使用用户名和密码     ftpClient.login(USERNAME,PASSWORD);     //上传文件。     //读取本地文件     FileInputStream inputStream = new FileInputStream(new File(FilePackage));     //设置上传的路径     ftpClient.changeWorkingDirectory("/myftp/images");     //修改上传文件的格式     ftpClient.setFileType(FTP.BINARY_FILE_TYPE);     //第一个参数：服务器端文档名     //第二个参数：上传文档的inputStream     ftpClient.storeFile("hello.jpg", inputStream);     //关闭连接     ftpClient.logout();   } } 

package org.chenzhengyou.common.util;  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.*;  /**  * @auther 陈郑游  * @create 2016-11-23-19:27  * @功能描述 ftp工具类  * @公司地址  */ public class FtpUtil {    /**    * 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 输入流    * @return 成功返回true，否则返回false    */    public static boolean uploadFile(String host, int port, String username,                    String password, String basePath,       String filePath, String filename, InputStream input) {      boolean result = false;     FTPClient ftp = new FTPClient();     try {       int reply;       ftp.connect(host, port);// 连接FTP服务器       // 如果采用默认端口，可以使用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;   }      /**    * Description: 从FTP服务器下载文件    * @param host FTP服务器hostname    * @param port FTP服务器端口    * @param username FTP登录账号    * @param password FTP登录密码    * @param remotePath FTP服务器上的相对路径    * @param fileName 要下载的文件名    * @param localPath 下载后保存到本地的路径    * @return    */    public static boolean downloadFile(String host, int port, String username, String password, String remotePath,       String fileName, String localPath) {     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.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录       FTPFile[] fs = ftp.listFiles();       for (FTPFile ff : fs) {         if (ff.getName().equals(fileName)) {           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;   } } 

package testController;  import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; import org.chenzhengyou.common.util.FtpUtil; import org.junit.Test;  import java.io.File; import java.io.FileInputStream;  /**  * @auther 陈郑游  * @create 2016-11-23-19:27  * @功能描述 图片测试  * @公司地址  */  public class FtpController {    //主机地址 端口号   private String HOSTNAME = "127.0.0.1";   private Integer PORT = 21;   //本地图片路径   private String FilePackage = "F://Programming_Package//IMG_3733_1.JPG";    //用户名 密码   private String USERNAME = "czy";   private String PASSWORD = "czy";    /**    * 有工具类测试    * */   @Test   public void testUtil() throws Exception {     FileInputStream inputStream = new FileInputStream(new File("F://Programming_Package//IMG_3733_1.JPG"));     FtpUtil.uploadFile(HOSTNAME,PORT, USERNAME, PASSWORD, "/myftp/images", "/2016/11/24", "hello.jpg", inputStream);   } }