使用apache的net包ftp上傳文件

mcc 10年前發布 | 2K 次閱讀 Java

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;

public class JFtpApche
{
privatestatic FTPClient ftpClient = new FTPClient();

privatestatic String encoding = System.getProperty("file.encoding"); 

publicstatic 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(newString(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;  
} 

public voidtestUpLoadFromDisk()  
{ 
   try  
   {  
       FileInputStream in = new FileInputStream(newFile("./data/se/1-2015-02-03-14.list"));  
       //boolean flag = uploadFile("127.0.0.1", 21, "zlb", "123", "/","哈哈.txt", in);  
       boolean flag = uploadFile("10.10.2.55", 21, "anonymous", "", "/","1-2015-02-03-14.list", in);  
       System.out.println(flag);  
   } catch (FileNotFoundException e)  
   {  
       e.printStackTrace();  
   }  
} 

publicstatic boolean downFile(String url, int port, String username,String password, String remotePath, String fileName, StringlocalPath)  
{ 
   boolean result = false;  
   try  
   {  
       int reply;  
       ftpClient.setControlEncoding(encoding);  

       // 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(newString(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;  
} 

public voidtestDownFile()  
{ 
   try  
   {  
       boolean flag = downFile("127.0.0.1", 21, "zlb", "123", "/","contact.txt", "D:/");  
       System.out.println(flag);  
   } catch (Exception e)  
   {  
       e.printStackTrace();  
   }  
} 

publicstatic void main(String[] args)  
{ 
   JFtpApche fa = new JFtpApche();  
   //fa.testDownFile();  
   fa.testUpLoadFromDisk();
} 

} </pre>

 本文由用戶 mcc 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!