用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);
}
}
}
}
}