重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
怎么在java中使用FTP下载文件?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
创新互联的客户来自各行各业,为了共同目标,我们在工作上密切配合,从创业型小企业到企事业单位,感谢他们对我们的要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。专业领域包括做网站、网站建设、电商网站开发、微信营销、系统平台开发。
Java的特点有哪些 1.Java语言作为静态面向对象编程语言的代表,实现了面向对象理论,允许程序员以优雅的思维方式进行复杂的编程。 2.Java具有简单性、面向对象、分布式、安全性、平台独立与可移植性、动态性等特点。 3.使用Java可以编写桌面应用程序、Web应用程序、分布式系统和嵌入式系统应用程序等。
1、FTP说明
FTP是文件传输协议FileTransferProtocol的英文缩写,它是一种TCP/IP协议,属于TCP/IP协议组。双向传送控制文件。与此同时,它也是一种应用(应用程序)。根据不同的操作系统,FTP应用程序各不相同,而且所有这些应用程序都遵循用于传输文件的相同协议。该协议由两部分组成,一是FTP服务器,二是FTP客户端。
2、下载思路
(1)设置文件类型(二进制)
(2)处理ftp对应文件输入流,ftp客户端对象和 ftp文件输入流
(3)处理完毕的文件列表,用于执行文件删除使用
(4)处理当前的文件名称
3、FTP下载实例
/** * * JAVA操作 FTP 下载 * 文件下载。 * */ private void ftpDownload() { FTPClient ftpClient = null; InputStream input = null; boolean loginFlag = false; Listlist = new ArrayList (); try { int defaultPort = CommonsMessage.FTP_DEFAULT_PORT; // 21 int timeout = M400Constant.NUM_SIXTY_THOUSAND * M400Constant.NUM_TWO; // 120000 ftpClient = new FTPClient(); ftpClient.setDefaultPort(defaultPort); ftpClient.setConnectTimeout(timeout); // ftpClient.setSoTimeout(timeout); ftpClient.setDefaultTimeout(timeout); ftpClient.setDataTimeout(timeout); ftpClient.setControlEncoding("UTF-8"); FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_UNIX); conf.setServerLanguageCode("en"); conf.setDefaultDateFormatStr("MMM dd HH:mm"); ftpClient.configure(conf); ftpClient.connect(SystemConfig.getKey("scpFtpIp")); loginFlag = ftpClient.login(SystemConfig.getKey("scpFtpUserName").trim(), SystemConfig.getKey("scpFtpPassword").trim()); String ftpDir = SystemConfig.getKey("ftpHangupDir").trim(); if (!loginFlag) { DEBUGGER.debug("login scp ftp is :" + loginFlag); } // String ftpDir = SystemConfig.getKey("ftpHangupDir").trim(); if (ftpClient.changeWorkingDirectory(ftpDir)) { FTPFile file[] = ftpClient.listFiles(ftpDir); if (file != null && file.length > 0) { DEBUGGER.debug("hungup file size is: " + file.length); for (int i = 0; i < file.length; i++) { String fileName = file[i].getName(); ftpClient.setBufferSize(CommonsMessage.ONE_K_BUFFER_SIZE); // 设置文件类型(二进制) ftpClient.setFileType(FTP.BINARY_FILE_TYPE); input = ftpClient.retrieveFileStream(fileName); processInput(ftpClient, input, list, fileName); // if (downFlag) { // ftpClient.deleteFile(fileName); // } } } else { try { Thread.sleep(M400Constant.NUM_FIVE_THOUSAND); } catch (InterruptedException e) { /* * if (DEBUGGER.isDebugEnable()) { * DEBUGGER.debug("Failed to queryScpToQuery", e); } */ error("Failed to queryScpToQuery", e); } } } else { DEBUGGER.debug("scp dir is error "); } } catch (Exception e) { /* * DEBUGGER.debug("dowonload file is faild ", e); */ error("dowonload file is faild ", e); } finally { close(input, "close inputStream is faild "); if (ftpClient != null) { try { deleteFile(ftpClient, list); boolean logoutFlag = false; try { logoutFlag = ftpClient.logout(); // DEBUGGER.debug("logout : " + logoutFlag); } catch (Exception e) { /* * DEBUGGER.debug("logout : " + logoutFlag); */ error("logout : " + logoutFlag, e); } ftpClient = null; } catch (Exception e) { /* * if (DEBUGGER.isDebugEnable()) { * DEBUGGER.error("Failed to ftpDownload", e); } */ error("Failed to ftpDownload", e); } // try { // ftpClient.disconnect(); // } catch (IOException e) { // if (DEBUGGER.isDebugEnable()) { // DEBUGGER.debug("Failed to ftpDownload", e); // } // } } } } /** * 处理ftp对应文件输入流。 * * @param ftpClient * ftp客户端对象 * @param input * ftp文件输入流 * @param list * 处理完毕的文件列表,用于执行文件删除使用 * @param fileName * 当前处理的文件名称 */ private void processInput(FTPClient ftpClient, InputStream input, List list, String fileName) { if (input == null) { return; } // boolean downFlag = callingService(input); callingService(input); try { input.close(); ftpClient.completePendingCommand(); list.add(fileName); } catch (Exception e) { /* * DEBUGGER.debug("Failed to ftpDownload", e); */ error("Failed to ftpDownload", e); } } }
看完上述内容,你们掌握怎么在java中使用FTP下载文件的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!