设为首页 收藏本站
查看: 952|回复: 0

[经验分享] java ftp 知识整理

[复制链接]

尚未签到

发表于 2016-6-8 10:20:38 | 显示全部楼层 |阅读模式
  1. 背景
  这两天在写一个jsp应用,涉及客户端上传一批pdf文件到服务端,然后取出来处理,再将相关结果返回。
  开始想用 org.apache.commons.fileupload , 用表单的方式上传, 但是这样只能上传单个文件,批上传则要在一个
  form里做多个上传的input,不太方便,所以后来想用ftp的方式,让用户选择本地一个文件夹,点击后整个上传到服务端的一个文件夹(网页的局限性导致无法直接由jsp获取文件夹目录,网上说好像要用 applet 做,现在还没搞清楚)。
  2. 网络资源
  网上找到的ftp上传主要有两种:一种是 sun.net.ftp ,据说sun包都不是标准包,所以没有javadoc,可以到www.sun.com 去下载源码,
  我找到了一个中文介绍:http://xhy0422.iyunv.com/blog/63017 ,
  还有一个包含 ftp 的远程命令列表的详细使用 http://blog.sina.com.cn/s/blog_4b898bdb010009xf.html
  第二种是 com.enterprisedt.net.ftp ,它是一个第三方包,功能比 sun.net.ftp 强大,找到一个比较详细的说明
  http://blog.163.com/cjp1320@126/blog/static/3547436320096212286312/
  
  有了以上几个链接,基本上就能实现 ftp 的相关功能了,这里再插下题外话,就是sun.net.ftp究竟是怎么实现的呢?我没有看过它的源码,但是看了那些方法之后,估计是对一般的ftp命令的封装,内部可能是用 socket 做的,使用时你会看到,一些方法里面很多命令行控制的影子,比如创建文件夹的核心语句  ftpClient.sendServer("MKD " + pathName + "\r\n");
  
  
  3.异常总结
  
  在实际使用过程中,出现了一些错误,网上看了一下,几乎没遇到好的说明的,所以总结一下,
  我在测试 sun.net.ftp 的时候,发现一个问题,就是老是出现
  java.io.FileNotFoundException: CWD F:\test\test4: 550 CWD failed. "/F:/test/test4": directory not found.
  的异常,其中,F:\\test\\test4 是我在服务端想要创建的文件夹,层层定位进去,发现创建文件夹那句ftpClient.sendServer("MKD " + pathName + "\r\n");并没有抛出异常,而是创建完后 cd(pathname)出现找不到文件夹的错误。远程登录到服务器去看,文件夹并没有创建。
  
  折腾了一下午后,才发现,代码是没错的,错在服务器端的保存路径“F:\\test\\test4 ”设错了,应该改为“\\test\\test4 ”就是将盘符去掉,结果一运行就可以了,远程登录看到在设为ftp服务域的文件夹下有了test/test4文件夹,里边打开有了上传的pdf文件。
  
  思考后发现,应该是服务器安装ftp服务器的时候,会选一个文件夹作为服务域(就是在本地用ftp工具登录过去看到的那个文件夹),所以,如果你在代码中设的目录像我前面那样“F:\\test\\test4 ”包含盘符就是违法的,因为F盘根目录没有在服务区域,改为“\\test\\test4 ”后,运行后是将这个目录连在服务域根目录之下。
  
  补充:查看网络帖子的过程中,发现一个比较多的错误,就是创建文件夹不成功的错误,原因是在创建语句ftpClient.sendServer("MKD " + pathName + "\r\n");后边缺了得到服务器端响应的语句ftpClient.readServerResponse();加上去就可以了,这类错误的异常是
  sun.net.ftp.FtpProtocolException:   PORT   :500   'EPRT            command   not   understood
  【奇怪的是,我自己测的时候去掉后面那句,还是可以执行成功,估计是不是权限方面的问题,希望研究过sun.net.ftp源码的朋友赐教一下】
  
  4.我的sun.net.ftp 的源码
  package common;
  //转载请标明出处:http://blog.csdn.net/yancong008/archive/2008/11/18/3327088.aspx
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import java.util.StringTokenizer;
import sun.net.ftp.FtpClient;
  /**
 * ftp上传
 *
 * @author colin
 * @version 1.0
 *
 */
public class MyFtp {
  private String ip = "";
  private String username = "";
  private String password = "";
  private int port = 21;
  private String localFileDir = "";// 需要上传的目录
  private String remoteFileDir = "";
  FtpClient ftpClient = null;
  OutputStream os = null;
  FileInputStream is = null;
  public MyFtp(String serverIP, int port, String username, String password) {
  this.ip = serverIP;
  this.username = username;
  this.password = password;
  this.port = port;
  }
  public MyFtp(String serverIP, String username, String password) {
  this.ip = serverIP;
  this.username = username;
  this.password = password;
  }
  /**
  * 创建文件夹
  *
  * @param dir
  * @param ftpClient
  * @throws Exception
  */
 private void createDir(String dir, FtpClient ftpClient) throws Exception {
  ftpClient.ascii();
  StringTokenizer s = new StringTokenizer(dir, "/"); // sign
  int count = s.countTokens();
  String pathName = "";
  while (s.hasMoreElements()) {
  
      pathName = pathName + "/" + (String) s.nextElement();
   
   try {
    ftpClient.sendServer("MKD " + pathName + "\r\n");
    System.out.println("success make"+pathName);
   } catch (Exception e) {
    System.out.println(e);
    e = null;
   }
   ftpClient.readServerResponse();
  }
  ftpClient.binary();
  }
  /**
  * 检查文件夹是否存在
  *
  * @param dir
  * @param ftpClient
  * @return
  */
 private Boolean isDirExist(String dir, FtpClient ftpClient) {
  try {
   ftpClient.cd(dir);
  } catch (Exception e) {
  return false;
  }
  return true;
 }
 /**
  *
  * @param ftpClient
  */
    public void testCreatDir(FtpClient ftpClient){
     String path = "F:/IM_FTP/test";
     try{
          ftpClient.sendServer("MKD " + path + "\r\n");
          ftpClient.readServerResponse();
     }catch(Exception e){
      System.out.println(e);
     }
    }
 /**
  * ftp上传
  *
  * @param localFileFullName
  *            上传的源文件夹
  * @return
  */
 public Boolean upload(String localFileDir, String remoteFileDir) {
  this.localFileDir = localFileDir;
  this.remoteFileDir = remoteFileDir;
  try {
   // 中文路径转换编码,本机操作系统默认编码是'GBK'
   String localfilepath = new String(localFileDir.getBytes("GBK"),
     "utf-8");
   // 新建一个FTP客户端连接
   ftpClient = new FtpClient();
   ftpClient.openServer(this.ip, this.port);
   ftpClient.login(this.username, this.password);
   ftpClient.cd("/");
   // System.out.println(ftpClient.welcomeMsg);//报告连接信息
   // 打开本地待上传的文件
//   testCreatDir(ftpClient);
   File file_in = new File(localfilepath);
   processFile(file_in, ftpClient);
   if (is != null) {
    is.close();
   }
   if (os != null) {
    os.close();
   }
   if (ftpClient != null) {
    ftpClient.closeServer();
   }
   return true;
  } catch (Exception e) {
   e.printStackTrace();
   System.err.println("Exception e in Ftp upload(): " + e.toString());
   return false;
  }
  }
  /**
  * 上传文件
  *
  * @param source
  * @param ftpClient
  * @throws Exception
  */
 private void processFile(File source, FtpClient ftpClient) throws Exception {
  if (source.exists()) {
   if (source.isDirectory()) {
    System.out.println("source:" + source.getPath());
    if (!isDirExist(this.remoteFileDir, ftpClient)) {
     createDir(this.remoteFileDir, ftpClient);
    }
    File sourceFile[] = source.listFiles();
    for (int i = 0; i < sourceFile.length; i++) {
     if (sourceFile.exists()) {
      if (sourceFile.isDirectory()) {
       this.processFile(sourceFile, ftpClient);
      } else {
       System.out.println("success1");
       ftpClient.cd(this.remoteFileDir);
       System.out.println("success2");
       ftpClient.binary();
       String fname = sourceFile.getName();
       os = ftpClient.put(fname);
       byte[] bytes = new byte[1024];
       is = new FileInputStream(sourceFile);
       // 开始复制
       int c;
       // 暂未考虑中途终止的情况
       while ((c = is.read(bytes)) != -1) {
        os.write(bytes, 0, c);
       }
       is.close();
       os.close();
      }
     }
    }
   } else {
    ftpClient.cd(this.remoteFileDir);
    ftpClient.binary();
    os = ftpClient.put(source.getName());
    byte[] bytes = new byte[1024];
    is = new FileInputStream(source);
    // 开始复制
    int c;
    // 暂未考虑中途终止的情况
    while ((c = is.read(bytes)) != -1) {
     os.write(bytes, 0, c);
    }
    is.close();
    os.close();
   }
  } else {
   throw new Exception("此文件或文件夹[" + source.getName() + "]有误或不存在!");
  }
  }
  public static void main(String args[]) throws Exception {
  MyFtp ftpup = new MyFtp("202.116.73.50", 2345, "**", "**");
  ftpup.upload("F:\\chen_pdf_processor\\pdf_test_data2", "\\test\\test4");
 }
}

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-227738-1-1.html 上篇帖子: 目前几种ftp服务器 下篇帖子: [转] FTP命令详解
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表