今天通过FTPClient上传文件时出现，虽然无错误出现但是上传到服务器端的文件大小为0。
如图：
之前的代码：
//FTP文件上传 public static boolean upload(String hostname, int port, String username, String password, String targetPath, String fileName, InputStream inputStream) throws SocketException, IOException { //实例化ftpClient FTPClient ftpClient = new FTPClient(); //设置登陆超时时间,默认是20s ftpClient.setDataTimeout(12000); //1.连接服务器 ftpClient.connect(hostname, port); //2.登录（指定用户名和密码） boolean b = ftpClient.login(username, password); if (!b) { log.info("ftp登陸超時"); if (ftpClient.isConnected()) { // 断开连接 ftpClient.disconnect(); } } log.info("ftp登陸成功"); // 设置字符编码 ftpClient.setControlEncoding("UTF-8"); //基本路径，一定存在 String[] pathArray = targetPath.split("/"); for (String path : pathArray) { if (path.equals("")) { continue; } //3.指定目录 返回布尔类型 true表示该目录存在 boolean dirExsists = ftpClient.changeWorkingDirectory(path); //4.如果指定的目录不存在，则创建目录 if (!dirExsists) { //此方式，每次，只能创建一级目录 boolean flag = ftpClient.makeDirectory(path); if (!flag) { System.out.println("文件目录创建失败！"); return false; } ftpClient.changeWorkingDirectory(path); } } log.info("重新指定上传文件的路径：" + targetPath); //重新指定上传文件的路径 // ftpClient.changeWorkingDirectory(targetPath); //5.设置上传文件的方式 ftpClient.setBufferSize(1024 * 1024 * 10); ftpClient.setFileType(FTP.BINARY_FILE_TYPE); ftpClient.enterLocalPassiveMode(); /** * 6.执行上传 * remote 上传服务后，文件的名称 * local 文件输入流 * 上传文件时，如果已经存在同名文件，会被覆盖 */ boolean uploadFlag = false; try { uploadFlag = ftpClient.storeFile(fileName, inputStream); } catch (Exception e) { e.printStackTrace(); } finally { ftpClient.logout(); ftpClient.disconnect(); } if (uploadFlag) { System.out.println("上传成功！"); return true; } return false; }
打上断点debug，当运行到
uploadFlag = ftpClient.storeFile(fileName, inputStream);
就卡着不到，也不报错。
百度到很多都说要设置为被动模式，要加：
ftpClient.enterLocalPassiveMode();
但是我明明已经加了还是不行。
于是各种找方法，终于知道问题在哪里了，原来 ftpClient.enterLocalPassiveMode();加的地方不对，要加在建立连接和登录之间才可以。
现在的代码：
//FTP文件上传 public static boolean upload(String hostname, int port, String username, String password, String targetPath, String fileName, InputStream inputStream) throws SocketException, IOException { //实例化ftpClient FTPClient ftpClient = new FTPClient(); //设置登陆超时时间,默认是20s ftpClient.setDataTimeout(12000); //1.连接服务器 ftpClient.connect(hostname, port); ftpClient.enterLocalPassiveMode(); //2.登录（指定用户名和密码） boolean b = ftpClient.login(username, password); if (!b) { log.info("ftp登陸超時"); if (ftpClient.isConnected()) { // 断开连接 ftpClient.disconnect(); } } log.info("ftp登陸成功"); // 设置字符编码 ftpClient.setControlEncoding("UTF-8"); //基本路径，一定存在 String[] pathArray = targetPath.split("/"); for (String path : pathArray) { if (path.equals("")) { continue; } //3.指定目录 返回布尔类型 true表示该目录存在 boolean dirExsists = ftpClient.changeWorkingDirectory(path); //4.如果指定的目录不存在，则创建目录 if (!dirExsists) { //此方式，每次，只能创建一级目录 boolean flag = ftpClient.makeDirectory(path); if (!flag) { System.out.println("文件目录创建失败！"); return false; } ftpClient.changeWorkingDirectory(path); } } log.info("重新指定上传文件的路径：" + targetPath); //重新指定上传文件的路径 // ftpClient.changeWorkingDirectory(targetPath); //5.设置上传文件的方式 ftpClient.setBufferSize(1024 * 1024 * 10); ftpClient.setFileType(FTP.BINARY_FILE_TYPE); /** * 6.执行上传 * remote 上传服务后，文件的名称 * local 文件输入流 * 上传文件时，如果已经存在同名文件，会被覆盖 */ boolean uploadFlag = false; try { uploadFlag = ftpClient.storeFile(fileName, inputStream); } catch (Exception e) { e.printStackTrace(); } finally { ftpClient.logout(); ftpClient.disconnect(); } if (uploadFlag) { System.out.println("上传成功！"); return true; } return false; }
问题解决，记录一下爬坑的过程，顺便希望能帮到其他人。
顺便记录下ftp文件下载
/** * 文件下载--FTP服务器 */ @LogRecord(name = "文件下载--FTP服务器") @GetMapping(value = "/v1/zdyl/downloadFile") public ResultJson downloadFileFtp(HttpServletRequest request, HttpServletResponse response) throws Exception { String url = request.getParameter("url"); if (url == null) throw new RRException("url is Empty！"); URI uri = new URI(url); log.info("url:" + url); String path = uri.getPath(); log.info("path:" + path); InputStream inputStream = UploadUtil.downloadFile(ftpConfig.getHost(), ftpConfig.getPort(), ftpConfig.getUsername(), ftpConfig.getPassword(), path); log.info("fileName:" + path.substring(path.lastIndexOf("/") + 1)); response.setContentType("application/force-download"); response.addHeader("Content-disposition", "attachment;fileName=" + path.substring(path.lastIndexOf("/") + 1)); OutputStream os = response.getOutputStream(); byte[] buf = new byte[1024]; int len = 0; while ((len = inputStream.read(buf)) != -1) { os.write(buf, 0, len); } return null; }
/** * 功能：根据文件名称，下载文件流 * * @return * @throws IOException */ public static InputStream downloadFile(String hostname, int port, String username, String password, String remoteFilePath) throws IOException { InputStream in = null; FTPClient ftpClient = null; try { //实例化ftpClient ftpClient = new FTPClient(); //设置登陆超时时间,默认是20s ftpClient.setDataTimeout(12000); //1.连接服务器 ftpClient.connect(hostname, port); ftpClient.enterLocalPassiveMode(); //2.登录（指定用户名和密码） boolean b = ftpClient.login(username, password); if (!b) { log.info("登陸超時"); if (ftpClient.isConnected()) { // 断开连接 ftpClient.disconnect(); } } log.info("登陸成功"); // 设置字符编码 ftpClient.setControlEncoding("UTF-8"); // 设置传输二进制文件 ftpClient.setBufferSize(1024 * 1024 * 10); ftpClient.setFileType(FTP.BINARY_FILE_TYPE); int reply = ftpClient.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftpClient.disconnect(); throw new RRException("failed to connect to the FTP Server:"); } // ftp文件获取文件 in = ftpClient.retrieveFileStream(encodingPath(remoteFilePath)); } catch (FTPConnectionClosedException e) { log.error("ftp连接被关闭！", e); throw e; } catch (Exception e) { log.error("ERR : upload file " + remoteFilePath + " from ftp : failed!", e); throw new RRException("ERR : upload file " + remoteFilePath + " from ftp : failed!"); } finally { ftpClient.disconnect(); } return in; } /** * 编码文件路径 */ private static String encodingPath(String path) throws UnsupportedEncodingException { // FTP协议里面，规定文件名编码为iso-8859-1，所以目录名或文件名需要转码 return new String(path.replaceAll("//", "/").getBytes("GBK"), "iso-8859-1"); }