java基于Apache FTP點斷續(xù)傳的文件上傳和下載
更新時間：2016年11月01日 15:41:35 作者：boonya
本篇文章主要介紹了java基于Apache FTP點斷續(xù)傳的文件上傳和下載，利用FTP實現(xiàn)文件的上傳和下載，具有一定的參考價值，感興趣的小伙伴們可以參考一下。
基于Apache FTP實現(xiàn)文件上傳下載工具 ，上傳文件時需要考慮以下問題（實例是續(xù)傳功能）：
（1）、 FTP服務(wù)器是否存在改目錄，如果不存在目錄則需要創(chuàng)建目錄。
（2）、判斷上傳文件是否已經(jīng)存在，如果存在是需要刪除后再上傳還是續(xù)傳。
1、上傳或下載狀態(tài)的枚舉類：
package com.scengine.wtms.utils.ftp;
public enum UploadStatus
{
File_Exits(0), Create_Directory_Success(1), Create_Directory_Fail(2), Upload_From_Break_Success(3), Upload_From_Break_Faild(4), Download_From_Break_Success(5), Download_From_Break_Faild(6), Upload_New_File_Success(7), Upload_New_File_Failed(8), Delete_Remote_Success(9), Delete_Remote_Faild(10),Remote_Bigger_Local(11),Remote_smaller_locall(12);
private int status;
public int getStatus()
{
return status;
}
public void setStatus(int status)
{
this.status = status;
}
UploadStatus(int status)
{
this.status = status;
}
}
2、工具類代碼：
package com.scengine.wtms.utils.ftp;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import org.apache.commons.net.PrintCommandListener;
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 ContinueFTP
{
private FTPClient ftpClient = new FTPClient();
/**
* 對象構(gòu)造 設(shè)置將過程中使用到的命令輸出到控制臺
*/
public ContinueFTP()
{
this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));
}
/**
*
* java編程中用于連接到FTP服務(wù)器
*
* @param hostname
* 主機(jī)名
*
* @param port
* 端口
*
* @param username
* 用戶名
*
* @param password
* 密碼
*
* @return 是否連接成功
*
* @throws IOException
*/
public boolean connect(String hostname, int port, String username, String password) throws IOException
{
ftpClient.connect(hostname, port);
if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode()))
{
if (ftpClient.login(username, password))
{
return true;
}
}
disconnect();
return false;
}
/**
*
* 從FTP服務(wù)器上下載文件
*
* @param remote
* 遠(yuǎn)程文件路徑
*
* @param local
* 本地文件路徑
*
* @return 是否成功
*
* @throws IOException
*/
@SuppressWarnings("resource")
public boolean download(String remote, String local) throws IOException
{
ftpClient.enterLocalPassiveMode();
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
boolean result;
File f = new File(local);
FTPFile[] files = ftpClient.listFiles(remote);
if (files.length != 1)
{
System.out.println("遠(yuǎn)程文件不唯一");
return false;
}
long lRemoteSize = files[0].getSize();
if (f.exists())
{
OutputStream out = new FileOutputStream(f, true);
System.out.println("本地文件大小為:" + f.length());
if (f.length() >= lRemoteSize)
{
System.out.println("本地文件大小大于遠(yuǎn)程文件大小，下載中止");
return false;
}
ftpClient.setRestartOffset(f.length());
result = ftpClient.retrieveFile(remote, out);
out.close();
} else
{
OutputStream out = new FileOutputStream(f);
result = ftpClient.retrieveFile(remote, out);
out.close();
}
return result;
}
/**
*
* 上傳文件到FTP服務(wù)器，支持?jǐn)帱c續(xù)傳
*
* @param local
* 本地文件名稱，絕對路徑
*
* @param remote
* 遠(yuǎn)程文件路徑，使用/home/directory1/subdirectory/file.ext
* 按照Linux上的路徑指定方式，支持多級目錄嵌套，支持遞歸創(chuàng)建不存在的目錄結(jié)構(gòu)
*
* @return 上傳結(jié)果
*
* @throws IOException
*/
@SuppressWarnings("resource")
public UploadStatus upload(String local, String remote) throws IOException
{
// 設(shè)置PassiveMode傳輸
ftpClient.enterLocalPassiveMode();
// 設(shè)置以二進(jìn)制流的方式傳輸
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
UploadStatus result;
// 對遠(yuǎn)程目錄的處理
String remoteFileName = remote;
if (remote.contains("/"))
{
remoteFileName = remote.substring(remote.lastIndexOf("/") + 1);
String directory = remote.substring(0, remote.lastIndexOf("/") + 1);
if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(directory))
{
// 如果遠(yuǎn)程目錄不存在，則遞歸創(chuàng)建遠(yuǎn)程服務(wù)器目錄
int start = 0;
int end = 0;
if (directory.startsWith("/"))
{
start = 1;
} else
{
start = 0;
}
end = directory.indexOf("/", start);
while (true)
{
String subDirectory = remote.substring(start, end);
if (!ftpClient.changeWorkingDirectory(subDirectory))
{
if (ftpClient.makeDirectory(subDirectory))
{
ftpClient.changeWorkingDirectory(subDirectory);
} else
{
System.out.println("創(chuàng)建目錄失敗");
return UploadStatus.Create_Directory_Fail;
}
}
start = end + 1;
end = directory.indexOf("/", start);
// 檢查所有目錄是否創(chuàng)建完畢
if (end <= start)
{
break;
}
}
}
}
// 檢查遠(yuǎn)程是否存在文件
FTPFile[] files = ftpClient.listFiles(remoteFileName);
if (files.length == 1)
{
long remoteSize = files[0].getSize();
File f = new File(local);
long localSize = f.length();
if (remoteSize == localSize)
{
return UploadStatus.File_Exits;
} else if (remoteSize > localSize)
{
return UploadStatus.Remote_Bigger_Local;
}
// 嘗試移動文件內(nèi)讀取指針,實現(xiàn)斷點續(xù)傳
InputStream is = new FileInputStream(f);
if (is.skip(remoteSize) == remoteSize)
{
ftpClient.setRestartOffset(remoteSize);
if (ftpClient.storeFile(remote, is))
{
return UploadStatus.Upload_From_Break_Success;
}
}
// 如果斷點續(xù)傳沒有成功，則刪除服務(wù)器上文件，重新上傳
if (!ftpClient.deleteFile(remoteFileName))
{
return UploadStatus.Delete_Remote_Faild;
}
is = new FileInputStream(f);
if (ftpClient.storeFile(remote, is))
{
result = UploadStatus.Upload_New_File_Success;
} else
{
result = UploadStatus.Upload_New_File_Failed;
}
is.close();
} else
{
InputStream is = new FileInputStream(local);
if (ftpClient.storeFile(remoteFileName, is))
{
result = UploadStatus.Upload_New_File_Success;
} else
{
result = UploadStatus.Upload_New_File_Failed;
}
is.close();
}
return result;
}
/**
*
* 斷開與遠(yuǎn)程服務(wù)器的連接
*
* @throws IOException
*/
public void disconnect() throws IOException
{
if (ftpClient.isConnected())
{
ftpClient.disconnect();
}
}
public static void main(String[] args)
{
ContinueFTP myFtp = new ContinueFTP();
try
{
myFtp.connect("192.168.1.200", 21, "duser", "HTPDuserXP32");
System.out.println(myFtp.upload("C:\\Users\\Administrator\\Desktop\\swing.drawer.jar", "/jars/swing.drawer.jar"));
myFtp.disconnect();
} catch (IOException e)
{
System.out.println("連接FTP出錯：" + e.getMessage());
}
}
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
在程序員面試過程中redis相關(guān)的知識是常被問到的話題。這篇文章主要介紹了13道Redis面試題，整理一下分享給大家，感興趣的小伙伴們可以參考一下2021-07-07
這篇文章主要介紹了myeclipse中使用maven前常見錯誤及解決辦法 的相關(guān)資料,需要的朋友可以參考下2016-05-05
Optional類是Java8為了解決null值判斷問題,借鑒google guava類庫的Optional類而引入的一個同名Optional類,使用Optional類可以避免顯式的null值判斷,避免null導(dǎo)致的NPE,下面以一些典型場景為例,列出Optional API常用接口的用法,并附上相應(yīng)代碼,感興趣的朋友一起看看吧2024-01-01
本文主要介紹了Java單例模式中的線程安全問題，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06
Java實現(xiàn)發(fā)送短信驗證碼+redis限制發(fā)送的次數(shù)功能
這篇文章主要介紹了Java實現(xiàn)發(fā)送短信驗證碼+redis限制發(fā)送的次數(shù),本文通過示例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-04-04
Java并發(fā)包工具類CountDownLatch的應(yīng)用詳解
CountDownLatch是Java并發(fā)包中非常實用的一個工具類，它可以幫助我們實現(xiàn)線程之間的同步和協(xié)作。本文主要介紹了CountDownLatch的應(yīng)用場景及最佳實踐，希望對大家有所幫助2023-04-04
這篇文章主要介紹了Idea中導(dǎo)入新模塊無法被識別的問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-11-11
SpringBoot?Profile多環(huán)境配置方式
這篇文章主要介紹了SpringBoot?Profile多環(huán)境配置方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要為大家詳細(xì)介紹了Java實現(xiàn)順序表的基本操作，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01
java繼承中說到的Object類是java中一個特殊的類，所有的類都是直接或者間接的繼承自O(shè)bject類，即如果某個類沒有使用extends關(guān)鍵字則默認(rèn)是java.lang.Object類的子類，所以所有的類都可以使用Object類中定義的方法，下面介紹Object類的常用方法2022-05-05