Java使用FTPClient类读写FTP
程序员文章站
2024-02-26 19:23:34
本文实例为大家分享了java使用ftpclient类读写ftp的具体代码,供大家参考,具体内容如下
1.首先先导入相关jar包
2.创建一个连接ftp的工具类ftp...
本文实例为大家分享了java使用ftpclient类读写ftp的具体代码,供大家参考,具体内容如下
1.首先先导入相关jar包
2.创建一个连接ftp的工具类ftputil.java
package com.metarnet.ftp.util; import java.io.ioexception; import java.io.inputstream; import java.net.socketexception; import java.util.properties; import org.apache.commons.net.ftp.ftpclient; import org.apache.commons.net.ftp.ftpreply; import org.apache.log4j.logger; public class ftputil { private static logger logger = logger.getlogger(ftputil.class); /** * 获取ftpclient对象 * @param ftphost ftp主机服务器 * @param ftppassword ftp 登录密码 * @param ftpusername ftp登录用户名 * @param ftpport ftp端口 默认为21 * @return */ public static ftpclient getftpclient(string ftphost, string ftppassword, string ftpusername, int ftpport) { ftpclient ftpclient = null; try { ftpclient = new ftpclient(); ftpclient.connect(ftphost, ftpport);// 连接ftp服务器 ftpclient.login(ftpusername, ftppassword);// 登陆ftp服务器 if (!ftpreply.ispositivecompletion(ftpclient.getreplycode())) { logger.info("未连接到ftp,用户名或密码错误。"); ftpclient.disconnect(); } else { logger.info("ftp连接成功。"); } } catch (socketexception e) { e.printstacktrace(); logger.info("ftp的ip地址可能错误,请正确配置。"); } catch (ioexception e) { e.printstacktrace(); logger.info("ftp的端口错误,请正确配置。"); } return ftpclient; } }
3.编写一个读取ftp上文件的类readftpfile.java
package com.metarnet.ftp.read; import java.io.bufferedreader; import java.io.fileinputstream; import java.io.filenotfoundexception; import java.io.ioexception; import java.io.inputstream; import java.io.inputstreamreader; import java.net.socketexception; import org.apache.commons.net.ftp.ftpclient; import org.apache.log4j.logger; import com.metarnet.ftp.util.ftputil; public class readftpfile { private logger logger = logger.getlogger(readftpfile.class); /** * 去 服务器的ftp路径下上读取文件 * * @param ftpusername * @param ftppassword * @param ftppath * @param ftpserver * @return */ public string readconfigfileforftp(string ftpusername, string ftppassword, string ftppath, string ftphost, int ftpport, string filename) { stringbuffer resultbuffer = new stringbuffer(); fileinputstream infile = null; inputstream in = null; ftpclient ftpclient = null; logger.info("开始读取绝对路径" + ftppath + "文件!"); try { ftpclient = ftputil.getftpclient(ftphost, ftppassword, ftpusername, ftpport); ftpclient.setcontrolencoding("utf-8"); // 中文支持 ftpclient.setfiletype(ftpclient.binary_file_type); ftpclient.enterlocalpassivemode(); ftpclient.changeworkingdirectory(ftppath); in = ftpclient.retrievefilestream(filename); } catch (filenotfoundexception e) { logger.error("没有找到" + ftppath + "文件"); e.printstacktrace(); return "下载配置文件失败,请联系管理员."; } catch (socketexception e) { logger.error("连接ftp失败."); e.printstacktrace(); } catch (ioexception e) { e.printstacktrace(); logger.error("文件读取错误。"); e.printstacktrace(); return "配置文件读取失败,请联系管理员."; } if (in != null) { bufferedreader br = new bufferedreader(new inputstreamreader(in)); string data = null; try { while ((data = br.readline()) != null) { resultbuffer.append(data + "\n"); } } catch (ioexception e) { logger.error("文件读取错误。"); e.printstacktrace(); return "配置文件读取失败,请联系管理员."; }finally{ try { ftpclient.disconnect(); } catch (ioexception e) { e.printstacktrace(); } } }else{ logger.error("in为空,不能读取。"); return "配置文件读取失败,请联系管理员."; } return resultbuffer.tostring(); } }
4.创建一个往ftp上写入文件的类writeftpfile.java
package com.metarnet.ftp.write; import java.io.bufferedwriter; import java.io.file; import java.io.fileinputstream; import java.io.filewriter; import java.io.ioexception; import java.io.inputstream; import org.apache.commons.net.ftp.ftpclient; import org.apache.commons.net.ftp.ftpfile; import org.apache.log4j.logger; import com.metarnet.ftp.util.ftputil; public class writeftpfile { private logger logger = logger.getlogger(writeftpfile.class); /** * 本地上传文件到ftp服务器 * * @param ftppath * 远程文件路径ftp * @throws ioexception */ public void upload(string ftppath, string ftpusername, string ftppassword, string ftphost, int ftpport, string filecontent, string writetempfielpath) { ftpclient ftpclient = null; logger.info("开始上传文件到ftp."); try { ftpclient = ftputil.getftpclient(ftphost, ftppassword, ftpusername, ftpport); // 设置passivemode传输 ftpclient.enterlocalpassivemode(); // 设置以二进制流的方式传输 ftpclient.setfiletype(ftpclient.binary_file_type); // 对远程目录的处理 string remotefilename = ftppath; if (ftppath.contains("/")) { remotefilename = ftppath .substring(ftppath.lastindexof("/") + 1); } // ftpfile[] files = ftpclient.listfiles(new // string(remotefilename)); // 先把文件写在本地。在上传到ftp上最后在删除 boolean writeresult = write(remotefilename, filecontent, writetempfielpath); if (writeresult) { file f = new file(writetempfielpath + "/" + remotefilename); inputstream in = new fileinputstream(f); ftpclient.storefile(remotefilename, in); in.close(); logger.info("上传文件" + remotefilename + "到ftp成功!"); f.delete(); } else { logger.info("写文件失败!"); } } catch (exception e) { e.printstacktrace(); }finally{ try { ftpclient.disconnect(); } catch (ioexception e) { e.printstacktrace(); } } } /** * 把配置文件先写到本地的一个文件中取 * * @param ftppath * @param str * @return */ public boolean write(string filename, string filecontext, string writetempfielpath) { try { logger.info("开始写配置文件"); file f = new file(writetempfielpath + "/" + filename); if(!f.exists()){ if(!f.createnewfile()){ logger.info("文件不存在,创建失败!"); } } bufferedwriter bw = new bufferedwriter(new filewriter(f, true)); bw.write(filecontext.replaceall("\n", "\r\n")); bw.flush(); bw.close(); return true; } catch (exception e) { logger.error("写文件没有成功"); e.printstacktrace(); return false; } } }
5.建立一个测试类ftpmain.java
package com.metarnet.ftp.main; import java.io.inputstream; import java.util.properties; import org.apache.log4j.logger; import com.metarnet.ftp.read.readftpfile; import com.metarnet.ftp.util.ftputil; import com.metarnet.ftp.write.writeftpfile; public class ftpmain { private static logger logger = logger.getlogger(ftpmain.class); public static void main(string[] args) { int ftpport = 0; string ftpusername = ""; string ftppassword = ""; string ftphost = ""; string ftppath = ""; string writetempfielpath = ""; try { inputstream in = ftputil.class.getclassloader() .getresourceasstream("env.properties"); if (in == null) { logger.info("配置文件env.properties读取失败"); } else { properties properties = new properties(); properties.load(in); ftpusername = properties.getproperty("ftpusername"); ftppassword = properties.getproperty("ftppassword"); ftphost = properties.getproperty("ftphost"); ftpport = integer.valueof(properties.getproperty("ftpport")) .intvalue(); ftppath = properties.getproperty("ftppath"); writetempfielpath = properties.getproperty("writetempfielpath"); readftpfile read = new readftpfile(); string result = read.readconfigfileforftp(ftpusername, ftppassword, ftppath, ftphost, ftpport, "huawei_220.248.192.200.cfg"); system.out.println("读取配置文件结果为:" + result); writeftpfile write = new writeftpfile(); ftppath = ftppath + "/" + "huawei_220.248.192.200_new1.cfg"; write.upload(ftppath, ftpusername, ftppassword, ftphost, ftpport, result, writetempfielpath); } } catch (exception e) { e.printstacktrace(); } } }
最后肯定是执行,看最后执行结果,ok步骤已讲完。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: java调用短信猫发短信示例
下一篇: 应用程序分层开发模式----MVC