java做的比較完善的FTP連接上傳下載文件 
（加入日期:2004-9-23 點擊數:1818）
【對此文發表評論】 【編程愛好者論壇】 【保存文章至硬盤】 【打印文章】 
 
這是偶第一次寫java程序實現公司要求的FTP數據同步，所有原代碼如下，以供各位參考并提出寶貴意見！另外俺還有兩個功能沒有實現，有請高手指點一二：1、如何刪除FTP服務器上已經下載過的文件？2、如何將上傳的文件改名？上傳時在文件名前加“temp_”，上傳完畢后需要把文件名改回來。3、如何使用openPassiveDataConnection()方法將ftp連接更改為主動連接，因為要從unix系統配置的ftp服務器下載文件的話，就需要主動連接。



/*
*******************************************************************************************************

Filename:  ftp.java
Author:   leetsing(elove)
Create date: 2004-08-30
Use:   connect to FTP server,then upload and download file
Modify date: 2004-09-05 add to upload file
     2004-09-13 add to download file
Copy right:  Magisky Media Technology Co.,Ltd.

*******************************************************************************************************
*/
//import cz.dhl.io.*;
//import cz.dhl.ftp.*;
import sun.net.ftp.*; 
import sun.net.*;
import java.applet.*; 
import java.io.*;
import java.io.IOException;
import java.util.StringTokenizer;
import sun.net.ftp.FtpClient;
import java.util.ArrayList;

public class ftp  extends Applet
{
FtpClient aftp; 
DataOutputStream outputs ; 
TelnetInputStream ins; 
TelnetOutputStream outs;

int ch; 
public String a; 
String hostname="";
private String path = "/";

public static void main(String[] args) 
{
  String hostname = "192.168.0.56";
  int port = 2121;
  String uid = "lee";
  String pwd = "lee";
  String RWFileDir = "D:\\smsftp\\";//文件目錄

  //連接ftp服務器
  ftp ft = new  ftp();
  ft.connect(RWFileDir,hostname,port,uid,pwd); 

  //下載文件
  if (ft.aftp != null){
   try {
    ft.getNameList(RWFileDir);
   }catch(IOException e) 
   { 
    System.out.println("下載文件出錯："+e);
   } 
  }


  //上傳文件
  if (ft.aftp != null){
   String sdir = RWFileDir + "subunsubfromsp\\";
   File fdir = new File(sdir);
   String FileName = "";
  
   for(int i=0;i    FileName = sdir + (fdir.list())[i];
   
    ft.uploadFile(RWFileDir,FileName);
   }
   //System.out.println("成功上傳的文件：");
   //ft.showFileContents("subunsubfromsp\\"); 
  }

  //刪除subunsubfromsp目錄下已經上傳的文件文件
//  ft.deleFile(RWFileDir);

  //斷開服務器連接
  ft.stop(RWFileDir);

}

public FtpClient connect(String RWFileDir,String hostname,int port,String uid,String pwd) 
{
  this.hostname = hostname;
  System.out.println("正在連接"+hostname+"，請等待.....");
  try{ 
   aftp = new FtpClient(hostname,port); 
   aftp.login(uid,pwd); 
   aftp.binary();
   //aftp.openPortDataConnection();
   a = "連接主機:"+hostname+"成功!";
   System.out.println(a); 
  } 
  catch(FtpLoginException e){ 
   a="登陸主機:"+hostname+"失敗!請檢查用戶名或密碼是否正確："+e; 
   System.out.println(a);
   //return false; 
  } 
  catch (IOException e){ 
   a="連接主機:"+hostname+"失敗!請檢查端口是否正確："+e; 
   System.out.println(a);
   //return false; 
  } 
  catch(SecurityException e) 
  { 
   a="無權限與主機:"+hostname+"連接!請檢查是否有訪問權限："+e; 
   System.out.println(a);
   //return false; 
  } 
  
  log(RWFileDir,a);
  return aftp; 
} 

public void stop(String RWFileDir) 
{ 
  String message = "";
  try { 
   if(aftp!=null){
    aftp.closeServer(); 
    message = "與主機"+hostname+"連接已斷開!";
    System.out.println(message); 
    log(RWFileDir,message);
   }
  } 
  catch(IOException e) 
  { 
   message = "與主機"+hostname+"斷開連接失敗!"+e;
   System.out.println(message); 
   log(RWFileDir,message);
  } 
} 


public boolean downloadFile(String RWFileDir,String filepathname){ 
  boolean result=true; 
  String message = "";
  if (aftp != null) 
  { 
   System.out.println("正在下載文件"+filepathname+",請等待...."); 
   String badfile = filepathname.substring(filepathname.length()-4,filepathname.length());
   String badlog = filepathname.substring(filepathname.length()-7,filepathname.length());
   String baddir = "";
   if ((badfile.compareTo(".bad") != 0) && (badlog.compareTo(".badlog") != 0)){
    baddir = "subunsubtosp\\";
   }
   else{
    baddir = "bad\\";
   }
   String strdir = "subunsubtosp\\";
   //System.out.println(RWFileDir + baddir + filepathname);
   try{ 
    //FtpClient fc=new FtpClient("192.168.0.56",2121);
    //fc.login("lee","lee");
    int ch;
    File fi = new File(RWFileDir + baddir + filepathname);
    //aftp.cd(strdir);
    RandomAccessFile getFile = new RandomAccessFile(fi,"rw");
    getFile.seek(0);
    TelnetInputStream fget=aftp.get(strdir+filepathname);
    DataInputStream puts = new DataInputStream(fget);
    while ((ch = puts.read()) >= 0) {
     getFile.write(ch);
     
    }
    //s.delete();
    
    fget.close();
    getFile.close();
    //fc.closeServer();

    message = "下載"+filepathname+"文件到"+baddir +"目錄成功!";
    System.out.println(message); 
    log(RWFileDir,message);
   } 
   catch(IOException e){ 
    message = "下載"+filepathname+"文件到"+baddir +"目錄失敗!"+e; 
    System.out.println(message); 
    log(RWFileDir,message);
    result = false ; 

   } 
  } 
  else{ 
   result = false; 
  } 
  return result; 
} 


public boolean uploadFile(String RWFileDir,String filepathname){ 
  boolean result=true; 
  String message = "";
  if (aftp != null) 
  { 
   System.out.println("正在上傳文件"+filepathname+",請等待...."); 

   try{ 
    String fg =new  String("\\subunsubfromsp\\"); 
    int index = filepathname.lastIndexOf(fg); 
    String filename = filepathname.substring(index+1); 
    File localFile = new File(filepathname) ;
      
    RandomAccessFile sendFile = new RandomAccessFile(filepathname,"r"); 
    // 
    sendFile.seek(0); 
    //改名上傳temp_
    filename = filename.substring(0,15)+"temp_"+filename.substring(15,filename.length());
    outs = aftp.put(filename); 
    outputs = new DataOutputStream(outs); 
    while (sendFile.getFilePointer() < sendFile.length() ) 
    { 
     ch = sendFile.read(); 
     outputs.write(ch); 
    } 
    
    rename(filename.substring(15,filename.length()),filename.substring(20,filename.length()));
    outs.close(); 
    sendFile.close(); 
    
    message = "上傳"+filepathname+"文件成功!";
    System.out.println(message); 
    log(RWFileDir,message);
   } 
   catch(IOException e){ 
    message = "上傳"+filepathname+"文件失敗!"+e;
    System.out.println(message); 
    log(RWFileDir,message);
    result = false ; 

   } 
  } 
  else{ 
   result = false; 
  } 
  return result; 
} 

public void rename(String oldName,String newName){
  
   //aftp.renameTo(oldName,newName);
   File Old = new File(oldName); //oldName
   File New = new File(newName); //newName
   //aftp.renameTo(New);
   //boolean Old.renameTo(File newName);
   //System.out.println(Old);
   //System.out.println(New);
  
}

public static void deleFile(String RWFileDir) { 
//try { 
  //取得ReadFile目錄下的txt文件
  String sdir = RWFileDir + "subunsubfromsp\\";
  File fdir = new File(sdir);
  String FileName = "";
  int j = fdir.list().length;
  
  System.out.println(sdir+"目錄下要刪除的文件數："+fdir.list().length);
  File  file;
  for(int i=0;i  {
   //刪除subunsubfromsp中的txt文件
   FileName = RWFileDir + "subunsubfromsp\\" + (fdir.list())[0];
   file = new  File(FileName);
   file.delete();
   System.out.println("已經成功刪除"+FileName+"文件！");
  }
//} 
//catch (IOException e) { 
// System.out.println("刪除txt文件錯誤!");
// e.printStackTrace();
//}
}


public void showFileContents(String strdir) 
{ 
  StringBuffer buf = new StringBuffer();
  try { 
   aftp.cd(strdir);
   ins= aftp.list(); 
   while ((ch=ins.read())>=0){ 
    buf.append((char)ch); 
   } 
   
   System.out.println(buf.toString()); 

   ins.close(); 
        } 
  catch(IOException e) 
  { 
  } 
}



// 返回當前目錄的所有文件及文件夾

public ArrayList getFileList() throws IOException {
  BufferedReader dr = new BufferedReader(new InputStreamReader(aftp.list()));
  ArrayList al = new ArrayList();
  String s = "";
  while ( (s = dr.readLine()) != null) {
  al.add(s);
  }
  return al;
}

public void setPath(String path) throws IOException {
  if (aftp == null)
  this.path = path;
  else {
   aftp.cd(path);
  }
}

// 返回當前目錄的文件名稱

public ArrayList getNameList(String RWFileDir) throws IOException {
  
  BufferedReader dr = new BufferedReader(new InputStreamReader(aftp.nameList("subunsubtosp\\")));
  ArrayList al = new ArrayList();
  String s = "";
  while ( (s = dr.readLine()) != null) {
   al.add(s);
   s = s.substring(13,s.length());
   isFile(s);
   downloadFile(RWFileDir,s);
   //String strFileDelF = aftp.nameList("subunsubtosp\\");
   File fileDelF=new File(s);
   fileDelF.delete();
  }
  return al;
  //System.out.println(al.add(s));
}

// 判斷一行文件信息是否為目錄

public boolean isDir(String line) {
  return ( (String) parseLine(line).get(0)).indexOf("d") != -1;
}

public boolean isFile(String line) {
  return!isDir(line);
}

// 處理getFileList取得的行信息

private ArrayList parseLine(String line) {
  ArrayList s1 = new ArrayList();
  StringTokenizer st = new StringTokenizer(line, " ");
  while (st.hasMoreTokens()) {
   s1.add(st.nextToken());
  }
   return s1;
}

//寫消息日志
public static void log(String RWFileDir,String msg)
{
  String message = "";
  try {
   java.text.DateFormat df = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
   java.text.DateFormat dflog = new java.text.SimpleDateFormat("yyyyMMdd");
   java.util.Date date = new java.util.Date() ;
   String datestr = df.format(new java.util.Date()) ;
   String datelog = dflog.format(new java.util.Date()) ;
   //String datelog = datestr.substring(0,10);
   //datelog = datelog.replace('-',' ');

   //按日期每天生成一個日志文件
   FileWriter fwl = new FileWriter(RWFileDir + "CMSSftp"+datelog+".log",true);
   PrintWriter outl = new PrintWriter(fwl);
   outl.println(datestr + "  " + msg);
   outl.close();
   fwl.close();
  }catch (IOException e) { 
   message = "寫log文件錯誤!"+e;
   e.printStackTrace();
   log(RWFileDir,message);
   System.out.println(message);
  }
}
}

本欄文章均來自于互聯網，版權歸原作者和各發布網站所有，本站收集這些文章僅供學習參考之用。任何人都不能將這些文章用于商業或者其他目的。( ProgramFan.Com )