Java 利用Apache Commons Net 实现 FTP文件上传下载 [转]
1 package woxingwosu; 2 3 import java.io.BufferedInputStream; 4 import java.io.BufferedOutputStream; 5 import java.io.FileInputStream; 6 import java.io.FileOutputStream; 7 import java.io.IOException; 8 import java.text.SimpleDateFormat; 9 import java.util.Comparator; 10 import java.util.Properties; 11 import java.util.TreeSet; 12 import org.apache.commons.io.FileUtils; 13 import org.apache.commons.net.ftp.FTP; 14 import org.apache.commons.net.ftp.FTPClient; 15 import org.apache.commons.net.ftp.FTPClientConfig; 16 import org.apache.commons.net.ftp.FTPFile; 17 import org.apache.commons.net.ftp.FTPReply; 18 19 /** 20 * 其实JDK里面也有支持FTP操作的包【jre/lib下的rt.jar】，但是SUN的DOC里面并没有提供相应文档， 21 * 因为这里面的包，不被官方支持，建议不要使用。我们可以使用第三方提供的包apache.commons。 22 * apache.commons的包，都有文档，方便使用 23 * 另外IBM也有提供一个ftp包，我没有用过，有兴趣的可以去研究一下 24 * @commons-net：http://apache.mirror.phpchina.com/commons/net/binaries/commons-net-1.4.1.zip 25 * @jakarta-oro：http://mirror.vmmatrix.net/apache/jakarta/oro/source/jakarta-oro-2.0.8.zip 26 * @commons-io：http://apache.mirror.phpchina.com/commons/io/binaries/commons-io-1.3.2-bin.zip 27 * @author 我行我素 28 * @2007-08-03 29 */ 30 public class MiniFtp { 31 private static String username; 32 private static String password; 33 private static String ip; 34 private static int port; 35 private static Properties property=null;//配置 36 private static String configFile;//配置文件的路径名 37 38 private static FTPClient ftpClient=null; 39 private static SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy-MM-dd hh:mm"); 40 41 private static final String [] FILE_TYPES={"文件","目录","符号链接","未知类型"}; 42 43 public static void main(String[] args) { 44 setConfigFile("woxingwosu.properties");//设置配置文件路径 45 connectServer(); 46 listAllRemoteFiles();//列出所有文件和目录 47 changeWorkingDirectory("webroot");//进入文件夹webroot 48 listRemoteFiles("*.jsp");//列出webroot目录下所有jsp文件 49 setFileType(FTP.BINARY_FILE_TYPE);//设置传输二进制文件 50 uploadFile("woxingwosu.xml","myfile.xml");//上传文件woxingwosu.xml，重新命名为myfile.xml 51 renameFile("viewDetail.jsp", "newName.jsp");//将文件viewDetail.jsp改名为newName.jsp 52 deleteFile("UpdateData.class");//删除文件UpdateData.class 53 loadFile("UpdateData.java","loadFile.java");//下载文件UpdateData.java，并且重新命名为loadFile.java 54 closeConnect();//关闭连接 55 } 56 57 /** 58 * 上传文件 59 * @param localFilePath--本地文件路径 60 * @param newFileName--新的文件名 61 */ 62 public static void uploadFile(String localFilePath,String newFileName){ 63 connectServer(); 64 //上传文件 65 BufferedInputStream buffIn=null; 66 try{ 67 buffIn=new BufferedInputStream(new FileInputStream(localFilePath)); 68 ftpClient.storeFile(newFileName, buffIn); 69 }catch(Exception e){ 70 e.printStackTrace(); 71 }finally{ 72 try{ 73 if(buffIn!=null) 74 buffIn.close(); 75 }catch(Exception e){ 76 e.printStackTrace(); 77 } 78 } 79 } 80 81 /** 82 * 下载文件 83 * @param remoteFileName --服务器上的文件名 84 * @param localFileName--本地文件名 85 */ 86 public static void loadFile(String remoteFileName,String localFileName){ 87 connectServer(); 88 //下载文件 89 BufferedOutputStream buffOut=null; 90 try{ 91 buffOut=new BufferedOutputStream(new FileOutputStream(localFileName)); 92 ftpClient.retrieveFile(remoteFileName, buffOut); 93 }catch(Exception e){ 94 e.printStackTrace(); 95 }finally{ 96 try{ 97 if(buffOut!=null) 98 buffOut.close(); 99 }catch(Exception e){ 100 e.printStackTrace(); 101 } 102 } 103 } 104 105 /** 106 * 列出服务器上所有文件及目录 107 */ 108 public static void listAllRemoteFiles(){ 109 listRemoteFiles("*"); 110 } 111 112 /** 113 * 列出服务器上文件和目录 114 * @param regStr --匹配的正则表达式 115 */ 116 @SuppressWarnings("unchecked") 117 public static void listRemoteFiles(String regStr){ 118 connectServer(); 119 try{ 120 FTPFile[] files=ftpClient.listFiles(regStr); 121 if(files==null||files.length==0) 122 System.out.println("There has not any file!"); 123 else{ 124 TreeSet<FTPFile> fileTree=new TreeSet( 125 new Comparator(){ 126 //先按照文件的类型排序(倒排)，然后按文件名顺序排序 127 public int compare(Object objFile1,Object objFile2){ 128 if(objFile1==null) 129 return -1; 130 else if(objFile2==null) 131 return 1; 132 else{ 133 FTPFile file1=(FTPFile)objFile1; 134 FTPFile file2=(FTPFile)objFile2; 135 if(file1.getType()!=file2.getType()) 136 return file2.getType()-file1.getType(); 137 else 138 return file1.getName().compareTo(file2.getName()); 139 } 140 } 141 } 142 ); 143 for(FTPFile file:files) 144 fileTree.add(file); 145 System.out.printf("%-35s%-10s%15s%15s\n","名称","类型","修改日期","大小"); 146 for(FTPFile file:fileTree){ 147 System.out.printf("%-35s%-10s%15s%15s\n",iso8859togbk(file.getName()),FILE_TYPES[file.getType()] 148 ,dateFormat.format(file.getTimestamp().getTime()),FileUtils.byteCountToDisplaySize(file.getSize())); 149 } 150 } 151 }catch(Exception e){ 152 e.printStackTrace(); 153 } 154 } 155 156 /** 157 * 关闭连接 158 */ 159 public static void closeConnect(){ 160 try{ 161 if(ftpClient!=null){ 162 ftpClient.logout(); 163 ftpClient.disconnect(); 164 } 165 }catch(Exception e){ 166 e.printStackTrace(); 167 } 168 } 169 170 /** 171 * 设置配置文件 172 * @param configFile 173 */ 174 public static void setConfigFile(String configFile) { 175 MiniFtp.configFile = configFile; 176 } 177 178 /** 179 * 设置传输文件的类型[文本文件或者二进制文件] 180 * @param fileType--BINARY_FILE_TYPE、ASCII_FILE_TYPE 181 */ 182 public static void setFileType(int fileType){ 183 try{ 184 connectServer(); 185 ftpClient.setFileType(fileType); 186 }catch(Exception e){ 187 e.printStackTrace(); 188 } 189 } 190 191 /** 192 * 扩展使用 193 * @return 194 */ 195 protected static FTPClient getFtpClient(){ 196 connectServer(); 197 return ftpClient; 198 } 199 200 /** 201 * 设置参数 202 * @param configFile --参数的配置文件 203 */ 204 private static void setArg(String configFile){ 205 property=new Properties(); 206 BufferedInputStream inBuff=null; 207 try{ 208 inBuff=new BufferedInputStream(new FileInputStream(configFile)); 209 property.load(inBuff); 210 username=property.getProperty("username"); 211 password=property.getProperty("password"); 212 ip=property.getProperty("ip"); 213 port=Integer.parseInt(property.getProperty("port")); 214 }catch(Exception e){ 215 e.printStackTrace(); 216 }finally{ 217 try{ 218 if(inBuff!=null) 219 inBuff.close(); 220 }catch(Exception e){ 221 e.printStackTrace(); 222 } 223 } 224 } 225 226 /** 227 * 连接到服务器 228 */ 229 public static void connectServer() { 230 if (ftpClient == null) { 231 int reply; 232 try { 233 setArg(configFile); 234 ftpClient=new FTPClient(); 235 ftpClient.setDefaultPort(port); 236 ftpClient.configure(getFtpConfig()); 237 ftpClient.connect(ip); 238 ftpClient.login(username, password); 239 ftpClient.setDefaultPort(port); 240 System.out.print(ftpClient.getReplyString()); 241 reply = ftpClient.getReplyCode(); 242 243 if (!FTPReply.isPositiveCompletion(reply)) { 244 ftpClient.disconnect(); 245 System.err.println("FTP server refused connection."); 246 } 247 } catch (Exception e) { 248 System.err.println("登录ftp服务器【"+ip+"】失败"); 249 e.printStackTrace(); 250 } 251 } 252 } 253 254 /** 255 * 进入到服务器的某个目录下 256 * @param directory 257 */ 258 public static void changeWorkingDirectory(String directory){ 259 try{ 260 connectServer(); 261 ftpClient.changeWorkingDirectory(directory); 262 }catch(IOException ioe){ 263 ioe.printStackTrace(); 264 } 265 } 266 267 /** 268 * 返回到上一层目录 269 */ 270 public static void changeToParentDirectory(){ 271 try{ 272 connectServer(); 273 ftpClient.changeToParentDirectory(); 274 }catch(IOException ioe){ 275 ioe.printStackTrace(); 276 } 277 } 278 279 /** 280 * 删除文件 281 */ 282 public static void deleteFile(String filename){ 283 try{ 284 connectServer(); 285 ftpClient.deleteFile(filename); 286 }catch(IOException ioe){ 287 ioe.printStackTrace(); 288 } 289 } 290 291 /** 292 * 重命名文件 293 * @param oldFileName --原文件名 294 * @param newFileName --新文件名 295 */ 296 public static void renameFile(String oldFileName,String newFileName){ 297 try{ 298 connectServer(); 299 ftpClient.rename(oldFileName, newFileName); 300 }catch(IOException ioe){ 301 ioe.printStackTrace(); 302 } 303 } 304 305 /** 306 * 设置FTP客服端的配置--一般可以不设置 307 * @return 308 */ 309 private static FTPClientConfig getFtpConfig(){ 310 FTPClientConfig ftpConfig=new FTPClientConfig(FTPClientConfig.SYST_UNIX); 311 ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING); 312 return ftpConfig; 313 } 314 315 /** 316 * 转码[ISO-8859-1 -> GBK] 317 *不同的平台需要不同的转码 318 * @param obj 319 * @return 320 */ 321 private static String iso8859togbk(Object obj){ 322 try{ 323 if(obj==null) 324 return ""; 325 else 326 return new String(obj.toString().getBytes("iso-8859-1"),"GBK"); 327 }catch(Exception e){ 328 return ""; 329 } 330 } 331 }