之前用的sun的ftp包，在java7 下面，过时了，不能用，无法引入。觉得还是用Apache的吧。
下载了一个commons-net-3.0.0.jar的包搞了一通以后，发现上传的文件为0大小，郁闷啊。
在百度里翻了半天别人问的这个问题，无正确回答
最后跑google翻出去看外国人说是包有毛病，得用3.0.1的，于是跑去下载个commons-net-3.0.1.jar，就成功了。
伟大的google啊。（真是百度一根毛也找不到）
顺便提供一份commons-net-3.0.1.jar包下载（我快翻遍了百度google，才找到这个。CSDN要积分，我积分消耗完毕了。）
下载jar包, 网盘
链接:https://pan.baidu.com/s/1d04G9XA8rZ4xjjxHm8UK8w 密码:ead2
package com.javaer.commcon; 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.FTPReply; import java.io.*; import java.net.SocketException; import java.text.SimpleDateFormat; public class AFtp { private static String userName; // FTP 登录用户名 private static String password; // FTP 登录密码 private static String ip; // FTP 服务器地址IP地址 private static int port; // FTP 端口 private static FTPClient ftpClient = null; // FTP 客户端代理 // FTP状态码 public static int i = 1; public static void main(String[] args) { setArg("db2","123455","122.111.1.23",21); connectServer(); uploadFile("/a.html" , "/b.html"); closeConnect();// 关闭连接 } /** * 设置参数 * * @param configFile * --参数的配置文件 */ public static void setArg(String user,String pwd,String IP,int PORT) { // property = new Properties(); userName = user; password = pwd; ip = IP; port = PORT; } /** * 上传单个文件，并重命名 * * @param localFile * --本地文件路径 * @param distFolder * --新的文件名,可以命名为空"" * @return true 上传成功，false 上传失败 */ public static boolean uploadFile(String local, final String dist) { boolean flag = true; try { connectServer(); ftpClient.setFileType(FTP.BINARY_FILE_TYPE); ftpClient.enterLocalPassiveMode(); ftpClient.setFileTransferMode(FTP.STREAM_TRANSFER_MODE); ftpClient.setBufferSize(1024 * 2); ftpClient.setDataTimeout(2000); File localFile= new File(local); InputStream input = new FileInputStream(localFile); BufferedInputStream inStream = null; inStream = new BufferedInputStream(input); System.out.println("本地文件名字" + localFile.getName() + " size:" + localFile.length()); flag = ftpClient.storeFile(dist, inStream); inStream.close(); if (flag) { System.out.println("上传文件成功！"); } else { System.out.println("上传文件失败！"); } input.close(); } catch (IOException e) { e.printStackTrace(); System.out.println("本地文件上传失败！"); } catch (Exception e) { e.printStackTrace(); } return flag; } /** * 删除一个文件 */ public static boolean deleteFile(String filename) { boolean flag = true; try { connectServer(); flag = ftpClient.deleteFile(filename); if (flag) { System.out.println("删除文件成功！"); } else { System.out.println("删除文件失败！"); } } catch (IOException ioe) { ioe.printStackTrace(); } return flag; } /** * 列出服务器上文件和目录 * * @param regStr * --匹配的正则表达式 */ public static void listRemoteFiles(String regStr) { connectServer(); try { String files[] = ftpClient.listNames(regStr); if (files == null || files.length == 0) System.out.println("没有任何文件!"); else { for (int i = 0; i < files.length; i++) { System.out.println(files[i]); } } } catch (Exception e) { e.printStackTrace(); } } /** * 关闭连接 */ public static void closeConnect() { try { if (ftpClient != null) { ftpClient.logout(); ftpClient.disconnect(); } } catch (Exception e) { e.printStackTrace(); } } /** * 设置传输文件的类型[文本文件或者二进制文件] * * @param fileType * --BINARY_FILE_TYPE、ASCII_FILE_TYPE * */ public static void setFileType(int fileType) { try { connectServer(); ftpClient.setFileType(fileType); } catch (Exception e) { e.printStackTrace(); } } /** * 扩展使用 * * @return ftpClient */ protected static FTPClient getFtpClient() { connectServer(); return ftpClient; } /** * 连接到服务器 * * @return true 连接服务器成功，false 连接服务器失败 */ public static boolean connectServer() { boolean flag = true; if (ftpClient == null) { int reply; try { ftpClient = new FTPClient(); ftpClient.setControlEncoding("GBK"); ftpClient.setDefaultPort(port); ftpClient.configure(getFtpConfig()); ftpClient.connect(ip); ftpClient.login(userName, password); ftpClient.setDefaultPort(port); System.out.print(ftpClient.getReplyString()); reply = ftpClient.getReplyCode(); ftpClient.setDataTimeout(120000); if (!FTPReply.isPositiveCompletion(reply)) { ftpClient.disconnect(); System.err.println("FTP server refused connection."); // System.out.println("FTP 服务拒绝连接！"); flag = false; } // System.out.println(i); i++; } catch (SocketException e) { flag = false; e.printStackTrace(); System.err.println("登录ftp服务器 " + ip + " 失败,连接超时！"); } catch (IOException e) { flag = false; e.printStackTrace(); System.err.println("登录ftp服务器 " + ip + " 失败，FTP服务器无法打开！"); } } return flag; } /** * 进入到服务器的某个目录下 * * @param directory */ public static void changeWorkingDirectory(String directory) { try { connectServer(); ftpClient.changeWorkingDirectory(directory); } catch (IOException ioe) { ioe.printStackTrace(); } } /** * 返回到上一层目录 */ public static void changeToParentDirectory() { try { connectServer(); ftpClient.changeToParentDirectory(); } catch (IOException ioe) { ioe.printStackTrace(); } } /** * 重命名文件 * * @param oldFileName * --原文件名 * @param newFileName * --新文件名 */ public static void renameFile(String oldFileName, String newFileName) { try { connectServer(); ftpClient.rename(oldFileName, newFileName); } catch (IOException ioe) { ioe.printStackTrace(); } } /** * 设置FTP客服端的配置--一般可以不设置 * * @return ftpConfig */ private static FTPClientConfig getFtpConfig() { FTPClientConfig ftpConfig = new FTPClientConfig( FTPClientConfig.SYST_UNIX); ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING); return ftpConfig; } /** * 转码[ISO-8859-1 -> GBK] 不同的平台需要不同的转码 * * @param obj * @return "" */ private static String iso8859togbk(Object obj) { try { if (obj == null) return ""; else return new String(obj.toString().getBytes("iso-8859-1"), "GBK"); } catch (Exception e) { return ""; } } /** * 在服务器上创建一个文件夹 * * @param dir * 文件夹名称，不能含有特殊字符，如 \ 、/ 、: 、* 、?、 "、 <、>... */ public static boolean makeDirectory(String dir) { connectServer(); boolean flag = true; try { flag = ftpClient.makeDirectory(dir); if (flag) { System.out.println("make Directory " + dir + " succeed"); } else { System.out.println("make Directory " + dir + " false"); } } catch (Exception e) { e.printStackTrace(); } return flag; } } |