当前位置: 代码迷 >> Web前端 >> 利用edtftpj组件实现FTP文件的下传-方法一
  详细解决方案

利用edtftpj组件实现FTP文件的下传-方法一

热度:113   发布时间:2012-09-01 09:33:03.0
利用edtftpj组件实现FTP文件的上传--方法一
在一般的web应用中,文件上传可以分为两类(ftp上传和http上传)。其中http上传是在页面的form表单中加入<input type=“file“ name=“file“>类型的接口,当表单被提交时,file中所指的文件就会被写入request对象中。那么在服务器端,用户只要根据rfc1867协议解析request中的数据流就可以得到文件,但是这样上传的速度很慢了,并且对文件的大小又要求。相比之下,ftp上传就很优越了。他是ftp客户端直接与ftp服务器进行交互,将文件创传到ftp服务器。当然,ftp客户端已经被实现。下面我们就应用第三方ftp客户端实现ftp上传。

首先,从www.enterprisedt.com下载ftp客户端。整个应用公有五个类组成Upload.java,FileUpload.java,DirectoryUpload.java,Directory.java,UploadException.java.希望大家改进。

  /*
   * @(#)Upload.java 1.0 04/11/17
   * 实现上传前的初始化
   */
  package com.head.upload;
  //调用第三方ftp客户端,可在www.enterprisedt.com下载
  import com.enterprisedt.net.ftp.*;
  import java.io.*;
  public class Upload {
  
   static FTPClient ftpClient;
   static String path;
   //ftp服务器的ip地址,登陆用户和密码
   String remoteAddress="127.0.0.1",userName="xie",password="xie";
  
   Upload(){}
  
   Upload(String path){
   this.path = path;
   }
  
   public boolean config(String fileName) throws UploadException {
   //从配置文件中读取远端地址,用户名和密码(没实现)
   return false;
   }
  
   public void init() throws UploadException {
   try{
   ftpClient = new FTPClient(this.remoteAddress);
   ftpClient.login(this.userName,this.password);
   ftpClient.setConnectMode(FTPConnectMode.PASV);
   ftpClient.setType(FTPTransferType.BINARY);
   }catch(Exception e)
   {
   throw new UploadException(e.toString(),"Upload.init()");
   }
  
   }
  
   public boolean upload() throws UploadException {
   File file = null;
   boolean flag = false;
   try{
   init();
  
   file = new File(path);
   if(file.isFile() && new FileUpload().uploadFile())
   flag = true;
   else if(file.isDirectory() && new DirectoryUpload().uploadFile(path))
   flag = true;
   }catch(Exception e)
   {
   throw new UploadException(e.toString(),"Upload.upload()");
   }
   finally{
   clear(ftpClient);
   }
   return flag;
   }
  
  
   boolean clear(FTPClient ftpClient) throws UploadException {
   try{
   ftpClient.quit();
   return true;
   }catch(Exception e)
   {
   throw new UploadException(e.toString(),"Upload.clear(ftpClient)");
   }
   }
  
   }
  }
  /*
   * @(#)FileUpload.java 1.0 04/11/17
   *
   * 上传单个文件
   */
  package com.head.upload;
  import com.enterprisedt.net.ftp.*;
  import java.io.*;
  public class FileUpload extends Upload {
  
   FileUpload(){}
  
   public boolean uploadFile() throws UploadException{
   //the name of file will be changed to avoid iteration
   String fileName = path.substring(path.lastIndexOf("\\")+1);
   try{
   ftpClient.put(path,fileName);
   return true;
   }catch(Exception e){
   throw new UploadException(e.toString(),"FileUpload.uploadFile()");
   }
   }
  
   public boolean uploadFile(String name) throws UploadException{
   //the name of file will be changed to avoid iteration
   String fileName = name.substring(name.lastIndexOf("\\")+1);
   try{
   ftpClient.put(name,fileName);
   return true;
   }catch(Exception e){
   throw new UploadException(e.toString(),"FileUpload.uploadFile(name)");
   }
   }
   }
  *
   * @(#)DirectoryUpload.java 1.0 04/11/17
   *
   * 上传文件夹
   */
  package com.head.upload;
  import com.enterprisedt.net.ftp.*;
  import java.io.*;
  public class DirectoryUpload extends Upload {
  
   DirectoryUpload(){}
  
   public boolean uploadFile(String dir) throws UploadException{
   //the name of directory will be changed to avoid iteration
   String dirName = dir.substring(dir.lastIndexOf("\\")+1);
   ftpMkDir(dirName);
  
   try{
   String currentDir = ftpClient.pwd();
   ftpClient.chdir(dirName);
   String[] subFiles = new Directory(dir).fileNames();
   for(int i=0;i<subFiles.length;i++) {
   String tmpP = dir +"\\" + subFiles[i];
   if(new File(tmpP).isFile()) {
   System.out.println("upload file:"+tmpP);
   new FileUpload().uploadFile(tmpP);
   }
   else{
   System.out.println("into the directory:"+tmpP);
   uploadFile(tmpP);
   }
   }
   ftpClient.chdir(currentDir);
   }catch(Exception e){
   throw new UploadException(e.toString(),"DirecotryUpload.uploadFile()");
   }
  
   return false;
   }
  
   private synchronized void ftpMkDir(String dirName) throws UploadException{
   try{
   ftpClient.mkdir(dirName);
   }catch(Exception e)
   {
   throw new UploadException(e.toString(),"DirecotryUpload.ftpMkDir(dirName)");
   }
   }
  
  
   }
  /*
   * @(#)Directory.java 1.0 04/11/17
   *
   *
   */
  package com.head.upload;
  import com.enterprisedt.net.ftp.*;
  import java.io.*;
  public class Directory {
  
   private String path;
  
   Directory(){}
  
   Directory(String path) {
   this.path = path;
   }
  
   //返回一个目录下所有的文件
   String[] fileNames() {
   String[] subNames = null;
   try{
   File file = new File(path);
   subNames = file.list();
   }catch(Exception e)
   {
   System.out.println(e.toString());
   }
   return subNames;
   }
  
   }
  
  /*
   * @(#)UploadException.java 1.0 04/11/17
   *
   *
   */
  package com.head.upload;
  
  public class UploadException extends Exception {
  
   UploadException(String eInfo,String location) {
   String info = "The error("+eInfo+") occur in "+location;
   System.out.println(info);
   }
  }
  相关解决方案