在此之前，在项目中加上FTP的架包
第一步：配置FTP服务器的相关配置
FtpConfig.java 实体类（配置类）
1 package com.sxd.ftp; 2 3 public class FtpConfig { 4 //主机ip 5 private String FtpHost = "192.168.18.252"; 6 //端口号 7 private int FtpPort = 21; 8 //ftp用户名 9 private String FtpUser = "ftp"; 10 //ftp密码 11 private String FtpPassword = "agenbiology"; 12 //ftp中的目录 这里先指定的根目录 13 private String FtpPath = "/"; 14 15 16 17 public String getFtpHost() { 18 return FtpHost; 19 } 20 public void setFtpHost(String ftpHost) { 21 FtpHost = ftpHost; 22 } 23 public int getFtpPort() { 24 return FtpPort; 25 } 26 public void setFtpPort(int ftpPort) { 27 FtpPort = ftpPort; 28 } 29 public String getFtpUser() { 30 return FtpUser; 31 } 32 public void setFtpUser(String ftpUser) { 33 FtpUser = ftpUser; 34 } 35 public String getFtpPassword() { 36 return FtpPassword; 37 } 38 public void setFtpPassword(String ftpPassword) { 39 FtpPassword = ftpPassword; 40 } 41 public String getFtpPath() { 42 return FtpPath; 43 } 44 public void setFtpPath(String ftpPath) { 45 FtpPath = ftpPath; 46 } 47 48 49 50 }
第二步：
FtpUtils.java 实现简单的上传下载
1 package com.sxd.ftp; 2 3 import java.io.File; 4 import java.io.FileInputStream; 5 import java.io.FileOutputStream; 6 import java.io.IOException; 7 import java.io.InputStream; 8 import java.io.OutputStream; 9 10 import org.apache.commons.net.ftp.FTPClient; 11 import org.junit.Test; 12 13 14 15 public class FtpUtils { 16 17 /** 18 * 获取FTP连接 19 * @return 20 */ 21 public FTPClient getFTPClient() { 22 FtpConfig config = new FtpConfig(); 23 FTPClient ftpClient = new FTPClient(); 24 boolean result = true; 25 try { 26 //连接FTP服务器 27 ftpClient.connect(config.getFtpHost(), config.getFtpPort()); 28 //如果连接 29 if (ftpClient.isConnected()) { 30 //提供用户名/密码登录FTP服务器 31 boolean flag = ftpClient.login(config.getFtpUser(), config.getFtpPassword()); 32 //如果登录成功 33 if (flag) { 34 //设置编码类型为UTF-8 35 ftpClient.setControlEncoding("UTF-8"); 36 //设置文件类型为二进制文件类型 37 ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); 38 } else { 39 result = false; 40 } 41 } else { 42 result = false; 43 } 44 //成功连接并 登陆成功 返回连接 45 if (result) { 46 return ftpClient; 47 } else { 48 return null; 49 } 50 } catch (Exception e) { 51 e.printStackTrace(); 52 return null; 53 } 54 } 55 56 57 58 /** 59 * 60 * @param localPath本地路径 61 * @param fileName文件名 62 * @param newPath上传至FTP的新位置 63 * @return 64 */ 65 public boolean testUpload(String localPath,String fileName,String newPath) { 66 boolean result = true; 67 FileInputStream in = null; 68 FTPClient ftpClient = getFTPClient(); 69 if (null == ftpClient) { 70 System.out.println("FTP服务器未连接成功!!!"); 71 return false; 72 } 73 try { 74 //当前上传的文件 75 File file = new File(localPath+fileName); 76 in = new FileInputStream(file); 77 //上传至FTP服务器的新位置 78 ftpClient.changeWorkingDirectory(newPath); 79 //上传 80 ftpClient.storeFile(fileName, in); 81 System.out.println(ftpClient.printWorkingDirectory()); 82 return result; 83 } catch (IOException e) { 84 e.printStackTrace(); 85 return false; 86 } finally { 87 close(in, null, ftpClient); 88 } 89 } 90 91 /** 92 * FTP下载 93 * @param fileName 文件名 94 * @param localPath 95 * @param remotePath 96 * @return 97 */ 98 public boolean testDownload(String localPath,String fileName, String remotePath) { 99 boolean result = true; 100 FileOutputStream out = null; 101 FTPClient ftpClient = getFTPClient(); 102 if (null == ftpClient) { 103 System.out.println("FTP服务器未连接成功!!!"); 104 return false; 105 } 106 try { 107 //要写到本地的位置 108 File file = new File(localPath + fileName); 109 out = new FileOutputStream(file); 110 //文件存储在FTP的位置 111 ftpClient.changeWorkingDirectory(remotePath); 112 //下载文件 113 ftpClient.retrieveFile(fileName, out); 114 System.out.println(ftpClient.printWorkingDirectory()); 115 return result; 116 } catch (IOException e) { 117 e.printStackTrace(); 118 return false; 119 } finally { 120 close(null, out, ftpClient); 121 } 122 } 123 124 125 /** 126 * 关闭 输入流或输出流 127 * @param in 128 * @param out 129 * @param ftpClient 130 */ 131 public static void close(InputStream in, OutputStream out,FTPClient ftpClient) { 132 if (null != in) { 133 try { 134 in.close(); 135 } catch (IOException e) { 136 e.printStackTrace(); 137 System.out.println("输入流关闭失败"); 138 } 139 } 140 if (null != out) { 141 try { 142 out.close(); 143 } catch (IOException e) { 144 e.printStackTrace(); 145 System.out.println("输出流关闭失败"); 146 } 147 } 148 if (null != ftpClient) { 149 try { 150 ftpClient.logout(); 151 ftpClient.disconnect(); 152 } catch (IOException e) { 153 e.printStackTrace(); 154 System.out.println("Ftp服务关闭失败!"); 155 } 156 } 157 } 158 159 160 @Test 161 public void test(){ 162 FtpConfig config = new FtpConfig(); 163 //上传文件 164 // testUpload("D:/","new4.txt" , config.getFtpPath()); 165 //下载 166 testDownload("D:/develop/", "new4.txt", config.getFtpPath()); 167 168 169 170 } 171 }
