1. 程式人生 > >用java實現ftp上傳檔案

用java實現ftp上傳檔案

實際專案需求:從資料庫查詢資訊,在本地生成檔案,再上傳到ftp

所用Jar包:NetComponents.jar

核心程式碼:


import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;

import com.oroinc.net.ftp.FTP;
import com.oroinc.net.ftp.FTPClient;
import com.oroinc.net.ftp.FTPReply;


public class FtpUtil {      
    
    
      public void connect(String ip, String port, String username,String password,String path,String filePath,String dateString){
             FTPClient ftp = new FTPClient();
             try{
                 int reply;
                 
                 ftp.connect(ip);
                 System.out.println("Connected to " + ip + ".");

                 reply = ftp.getReplyCode();

                 if (!FTPReply.isPositiveCompletion(reply))
                 {
                     ftp.disconnect();
                     throw new RuntimeException("FTP server refused connection.");
                 }
                 
                 if (!ftp.login(username, password))
                 {
                     ftp.logout();
                     throw new RuntimeException("FTP login error.");
                 }
                 
                 System.out.println("ftp系統名稱 " + ftp.getSystemName());
                 
                 ftp.setFileType(FTP.BINARY_FILE_TYPE);
                 ftp.enterLocalPassiveMode();//主動模式,埠自動獲取的
                 //在ftp伺服器上建立資料夾,要有許可權
                boolean a=  ftp.makeDirectory(path+"/"+dateString);//dateString 我們要求是以時間生成資料夾
                //轉換工作空間,準備上傳
                 boolean b =  ftp.changeWorkingDirectory(path+"/"+dateString);
              // ftpClient.enterLocalPassiveMode(); //被動模式
                 System.out.println("ftp就緒");
                 //獲得所有檔案的名字
                 File file=new File(filePath);
                 String[] files=file.list();
                 //遍歷上傳
                 for (int i = 0; i < files.length; i++) {
                     File f = new File(filePath+"/"+files[i]);
                     InputStream input = new FileInputStream(f);
                     System.out.println("準備傳送"+files[i]);
                     //ftp.storeFile(path,input);
                     //第一個引數是將要上傳到ftp伺服器上的絕對路徑加檔名,第二個引數是上傳的檔案流,也要是本地的絕對路徑
                     boolean flag = ftp.storeFile(path+"/"+dateString+"/"+files[i], input);
                     System.out.println("flag============================="+flag);
                     if(flag){
                         System.out.println("傳送完畢");
                     }else{
                         input.close();
                         throw new RuntimeException("傳送檔案失敗,請檢查ftp連線");
                     }
                     
                     input.close();
                 }
                 
                 System.out.println("上傳完成");
                 
                 
             } catch (Exception e) {
                 e.printStackTrace();
                 throw new RuntimeException("ftp__傳送資料給融合異常,請聯絡系統管理員");
             }finally{
                 if (ftp.isConnected())
                 {
                     try
                     {
                         ftp.logout();
                         ftp.disconnect();
                     }
                     catch (IOException f)
                     {
                          f.printStackTrace();
                          throw new RuntimeException("關閉FTP連線發生異常!", f);
                     }
                 }
             }
         }   
 
}