Java 实现FTP服务实例详解

Java 实现FTP服务实例详解

1、FTP简介

        FTP 是File Transfer Protocol（文件传输协议）的英文简称，而中文简称为“文传协议”。用于Internet上的控制文件的双向传输。同时，它也是一个应用程序（Application）。基于不同的操作系统有不同的FTP应用程序，而所有这些应用程序都遵守同一种协议以传输文件。在FTP的使用当中，用户经常遇到两个概念："下载"（Download）和"上传"（Upload）。"下载"文件就是从远程主机拷贝文件至自己的计算机上；"上传"文件就是将文件从自己的计算机中拷贝至远程主机上。用Internet语言来说，用户可通过客户机程序向（从）远程主机上传（下载）文件。

2、实例

2.1、添加依赖

 
  
   commons-fileupload 
   commons-fileupload 
  

2.2测试类

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; 
 
 
 
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(); 
  } 
} 

2.3、FTP工具类上传图片

工具类

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.*; 
 
 
public class FtpUtil { 
 
    
  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; 
  } 
   
    
  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; 
 
 
 
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); 
  } 
} 

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！