欢迎来到小生的博客，各种工具类，常用知识点、技巧持续更新中。。。。。。。
感谢大家点赞关注，希望大家能够给小生更多的支持。
祝您阅读愉快！
有任何疑问可以加小生QQ群咨询：107680366
前段时间，项目中使用到了上传文件到FTP服务器，再此略作整理，形成一个util工具,方便日后使用。
项目代码已上传至github:https://github.com/hack-feng/ftpdemo.git
点击直接前往
其中部分生成规则可以根据实际业务进行修改，删除
首先定义一个FTP服务器和上传文件的基础信息
封装一个FtpBean.java实体类
public class FtpBean { /** * 部分信息如果传空的话，默认赋值，根据业务需求修改 */ //FTP服务器地址 private String address; //FTP服务器端口号 private String port; //FTP服务器用户名 private String username; //FTP服务器密码 private String password; //上传文件名称 private String fileName; //基本路径 private String basepath; //文件输入流 private InputStream inputStream; //保存文件方式 默认：1-覆盖；2-文件名称后面+(递增数据) private Integer saveFileType; //省略get,set方法，详情可查询github上的源码
创建FTP上传工具类 FtpUtil.java：
public class FtpUtil { public static boolean uploadFile(FtpBean ftpBean) { boolean result = false; FTPClient ftp = new FTPClient(); try { int reply; ftp.connect(ftpBean.getAddress(), Integer.valueOf(ftpBean.getPort()));// 连接FTP服务器 // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器 ftp.login(ftpBean.getUsername(), ftpBean.getPassword());// 登录 reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftp.disconnect(); return result; } String tempPath = ftpBean.getBasepath(); String fileName = ftpBean.getFileName(); if (!ftp.changeWorkingDirectory(ftpBean.getBasepath())) { //判断目录是否存在，如果目录不存在创建目录，目录存在则跳转到此目录下 String []tempPathList = tempPath.split("/"); for (String dir : tempPathList) { if(dir != null && dir != ""){ if (!ftp.changeWorkingDirectory(dir)) { if (!ftp.makeDirectory(dir)) { return result; } else { ftp.changeWorkingDirectory(dir); } } } } } //保存文件方式 默认：1-覆盖；2-文件名称后面+(递增数据) if(ftpBean.getSaveFileType() == 2){ FTPFile[]file = ftp.listFiles(); Integer i = 1; //采用递归，文件名重复自动加(i) fileName = aaa(file, i, fileName, fileName); } //设置上传文件的类型为二进制类型 ftp.setFileType(FTP.BINARY_FILE_TYPE); //设置模式很重要 ftp.enterLocalActiveMode(); //上传文件 result = ftp.storeFile(fileName, ftpBean.getInputStream()); if(!result){ return result; } ftpBean.getInputStream().close(); ftp.logout(); result = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException ioe) { } } } return result; } //递归重命名去重复 public static String aaa(FTPFile[] file, int i, String fileName, String nameFlag){ boolean isOk = true; for (FTPFile file2 : file) { String flag = file2.getName(); if(nameFlag.equals(flag)){ String []fileNames = fileName.split("\\."); if(fileNames.length > 0){ nameFlag = ""; } for (int j = 0; j < fileNames.length; j++) { if(j == fileNames.length-1){ nameFlag = nameFlag+"("+i+")."+fileNames[j]; }else if(j == fileNames.length-2){ nameFlag = nameFlag + fileNames[j]; }else{ nameFlag = nameFlag + fileNames[j] + "."; } } i += 1; isOk = false; }else{ isOk = true; } } if(isOk == false){ nameFlag = aaa(file, i, fileName, nameFlag); } return nameFlag; } }
