package com.cloudpower.util;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import sun.net.TelnetInputStream;import sun.net.TelnetOutputStream;import sun.net.ftp.FtpClient;/** * Java自帶的API對FTP的操作 * @Title:Ftp.java * @author: 周玲斌  */public class Ftp { /**  * 本地文件名  */ private String localfilename; /**  * 遠程文件名  */ private String remotefilename; /**  * FTP客戶端  */ private FtpClient ftpClient; /**  * 服務器連接  * @param ip 服務器IP  * @param port 服務器端口  * @param user 用戶名  * @param password 密碼  * @param path 服務器路徑  * @author 周玲斌  * @date 2012-7-11  */ public void connectServer(String ip, int port, String user,   String password, String path) {  try {   /* ******連接服務器的兩種方法*******/   //第一種方法//   ftpClient = new FtpClient();//   ftpClient.openServer(ip, port);   //第二種方法   ftpClient = new FtpClient(ip);      ftpClient.login(user, password);   // 設置成2進制傳輸   ftpClient.binary();   System.out.println("login success!");   if (path.length() != 0){    //把遠程系統(tǒng)上的目錄切換到參數(shù)path所指定的目錄    ftpClient.cd(path);   }   ftpClient.binary();  } catch (IOException ex) {   ex.printStackTrace();   throw new RuntimeException(ex);  } } /**  * 關閉連接  * @author 周玲斌  * @date 2012-7-11  */ public void closeConnect() {  try {   ftpClient.closeServer();   System.out.println("disconnect success");  } catch (IOException ex) {   System.out.println("not disconnect");   ex.printStackTrace();   throw new RuntimeException(ex);  } } /**  * 上傳文件  * @param localFile 本地文件  * @param remoteFile 遠程文件  * @author 周玲斌  * @date 2012-7-11  */ public void upload(String localFile, String remoteFile) {  this.localfilename = localFile;  this.remotefilename = remoteFile;  TelnetOutputStream os = null;  FileInputStream is = null;  try {   //將遠程文件加入輸出流中   os = ftpClient.put(this.remotefilename);   //獲取本地文件的輸入流   File file_in = new File(this.localfilename);   is = new FileInputStream(file_in);   //創(chuàng)建一個緩沖區(qū)   byte[] bytes = new byte[1024];   int c;   while ((c = is.read(bytes)) != -1) {    os.write(bytes, 0, c);   }   System.out.println("upload success");  } catch (IOException ex) {   System.out.println("not upload");   ex.printStackTrace();   throw new RuntimeException(ex);  } finally{   try {    if(is != null){     is.close();    }   } catch (IOException e) {    e.printStackTrace();   } finally {    try {     if(os != null){      os.close();     }    } catch (IOException e) {     e.printStackTrace();    }   }  } }  /**  * 下載文件  * @param remoteFile 遠程文件路徑(服務器端)  * @param localFile 本地文件路徑(客戶端)  * @author 周玲斌  * @date 2012-7-11  */ public void download(String remoteFile, String localFile) {  TelnetInputStream is = null;  FileOutputStream os = null;  try {   //獲取遠程機器上的文件filename，借助TelnetInputStream把該文件傳送到本地。   is = ftpClient.get(remoteFile);   File file_in = new File(localFile);   os = new FileOutputStream(file_in);   byte[] bytes = new byte[1024];   int c;   while ((c = is.read(bytes)) != -1) {    os.write(bytes, 0, c);   }   System.out.println("download success");  } catch (IOException ex) {   System.out.println("not download");   ex.printStackTrace();   throw new RuntimeException(ex);  } finally{   try {    if(is != null){     is.close();    }   } catch (IOException e) {    e.printStackTrace();   } finally {    try {     if(os != null){      os.close();     }    } catch (IOException e) {     e.printStackTrace();    }   }  } } public static void main(String agrs[]) {  String filepath[] = { "/temp/aa.txt", "/temp/regist.log"};  String localfilepath[] = { "C://tmp//1.txt","C://tmp//2.log"};  Ftp fu = new Ftp();  /*   * 使用默認的端口號、用戶名、密碼以及根目錄連接FTP服務器   */  fu.connectServer("127.0.0.1", 22, "anonymous", "IEUser@", "/temp");    //下載  for (int i = 0; i < filepath.length; i++) {   fu.download(filepath[i], localfilepath[i]);  }    String localfile = "E://號碼.txt";  String remotefile = "/temp/哈哈.txt";  //上傳  fu.upload(localfile, remotefile);  fu.closeConnect(); }}

public class FtpApche { private static FTPClient ftpClient = new FTPClient(); private static String encoding = System.getProperty("file.encoding"); /**  * Description: 向FTP服務器上傳文件  *   * @Version1.0  * @param url  *   FTP服務器hostname  * @param port  *   FTP服務器端口  * @param username  *   FTP登錄賬號  * @param password  *   FTP登錄密碼  * @param path  *   FTP服務器保存目錄,如果是根目錄則為“/”  * @param filename  *   上傳到FTP服務器上的文件名  * @param input  *   本地文件輸入流  * @return 成功返回true，否則返回false  */ public static boolean uploadFile(String url, int port, String username,   String password, String path, String filename, InputStream input) {  boolean result = false;  try {   int reply;   // 如果采用默認端口，可以使用ftp.connect(url)的方式直接連接FTP服務器   ftpClient.connect(url);   // ftp.connect(url, port);// 連接FTP服務器   // 登錄   ftpClient.login(username, password);   ftpClient.setControlEncoding(encoding);   // 檢驗是否連接成功   reply = ftpClient.getReplyCode();   if (!FTPReply.isPositiveCompletion(reply)) {    System.out.println("連接失敗");    ftpClient.disconnect();    return result;   }   // 轉移工作目錄至指定目錄下   boolean change = ftpClient.changeWorkingDirectory(path);   ftpClient.setFileType(FTP.BINARY_FILE_TYPE);   if (change) {    result = ftpClient.storeFile(new String(filename.getBytes(encoding),"iso-8859-1"), input);    if (result) {     System.out.println("上傳成功!");    }   }   input.close();   ftpClient.logout();  } catch (IOException e) {   e.printStackTrace();  } finally {   if (ftpClient.isConnected()) {    try {     ftpClient.disconnect();    } catch (IOException ioe) {    }   }  }  return result; } /**  * 將本地文件上傳到FTP服務器上  *   */ public void testUpLoadFromDisk() {  try {   FileInputStream in = new FileInputStream(new File("E:/號碼.txt"));   boolean flag = uploadFile("127.0.0.1", 21, "zlb","123", "/", "哈哈.txt", in);   System.out.println(flag);  } catch (FileNotFoundException e) {   e.printStackTrace();  } } /**  * Description: 從FTP服務器下載文件  *   * @Version1.0  * @param url  *   FTP服務器hostname  * @param port  *   FTP服務器端口  * @param username  *   FTP登錄賬號  * @param password  *   FTP登錄密碼  * @param remotePath  *   FTP服務器上的相對路徑  * @param fileName  *   要下載的文件名  * @param localPath  *   下載后保存到本地的路徑  * @return  */ public static boolean downFile(String url, int port, String username,   String password, String remotePath, String fileName,   String localPath) {  boolean result = false;  try {   int reply;   ftpClient.setControlEncoding(encoding);      /*    * 為了上傳和下載中文文件，有些地方建議使用以下兩句代替    * new String(remotePath.getBytes(encoding),"iso-8859-1")轉碼。    * 經過測試，通不過。    *///   FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);//   conf.setServerLanguageCode("zh");   ftpClient.connect(url, port);   // 如果采用默認端口，可以使用ftp.connect(url)的方式直接連接FTP服務器   ftpClient.login(username, password);// 登錄   // 設置文件傳輸類型為二進制   ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);   // 獲取ftp登錄應答代碼   reply = ftpClient.getReplyCode();   // 驗證是否登陸成功   if (!FTPReply.isPositiveCompletion(reply)) {    ftpClient.disconnect();    System.err.println("FTP server refused connection.");    return result;   }   // 轉移到FTP服務器目錄至指定的目錄下   ftpClient.changeWorkingDirectory(new String(remotePath.getBytes(encoding),"iso-8859-1"));   // 獲取文件列表   FTPFile[] fs = ftpClient.listFiles();   for (FTPFile ff : fs) {    if (ff.getName().equals(fileName)) {     File localFile = new File(localPath + "/" + ff.getName());     OutputStream is = new FileOutputStream(localFile);     ftpClient.retrieveFile(ff.getName(), is);     is.close();    }   }   ftpClient.logout();   result = true;  } catch (IOException e) {   e.printStackTrace();  } finally {   if (ftpClient.isConnected()) {    try {     ftpClient.disconnect();    } catch (IOException ioe) {    }   }  }  return result; } /**  * 將FTP服務器上文件下載到本地  *   */ public void testDownFile() {  try {   boolean flag = downFile("127.0.0.1", 21, "zlb",     "123", "/", "哈哈.txt", "D:/");   System.out.println(flag);  } catch (Exception e) {   e.printStackTrace();  } }  public static void main(String[] args) {  FtpApche fa = new FtpApche();  fa.testDownFile(); }}