ftp斷點續傳java

『壹』 java實現ftp斷點續傳問題

//嘗試移動文件內讀取指針,實現斷點續傳
result
=
uploadFile(remoteFileName,
f,
ftpClient,
remoteSize);
//如果斷點續傳沒有成功，則刪除伺服器上文件，重新上傳
if(result
==
UploadStatus.Upload_From_Break_Failed){
if(!ftpClient.deleteFile(remoteFileName)){
return
UploadStatus.Delete_Remote_Faild;
}
result
=
uploadFile(remoteFileName,
f,
ftpClient,
0);
}

『貳』 java中文件大小超過多大需要斷點續傳

這個不太難吧？
假設A給B傳文件F（1024位元組）。第一次B接收了512位元組，那麼第二次連接A就應該從513位元組開始傳輸。
也就是說，在第二次傳輸時，B要提供「我要從513位元組開始傳送文件F」的信息，然後A使用FileInputStream構建輸入流讀取本地文件，使用skip(512)方法跳過文件F的前512位元組再傳送文件，之後B將數據追加（append）到先前接收的文件末尾即可。
進一步考慮，如果要實現多線程傳送，即分塊傳輸，也同樣的道理。假如B要求分作兩塊同時傳輸，那麼A啟動兩個線程，一個從513位元組讀到768位元組（工256位元組），第二個線程從769位元組到1024位元組即可。
如果你要從網路上下載文件，就是說A方不是你實現的，那麼你要先確認A方支不支持斷電續傳功能（HTTP1.1），然後你查閱下HTTP1.1協議，在HTTP1.1版本里，可以通過設置請求包頭某個欄位的信息（使用URLConnection創建連接並使用setRequestProperty(String key, String value) 方法設置）從而精確讀取文件的某一段數據的。注意，基於HTTP斷點續傳的關鍵是1.1版本，1.0版本是不支持的。

『叄』 Java ftp 斷點續傳報錯

NoClassDefFoundError
1.未通過編譯
2.沒有引入jar包

『肆』 java ftp怎麼實現java ftp方式的斷點續傳

運用類的辦法，編程人員能夠長途登錄到FTP伺服器，羅列該伺服器上的目錄，設置傳輸協議，以及傳送文件。FtpClient類涵 蓋了簡直一切FTP的功用，FtpClient的實例變數保留了有關樹立"署理"的各種信息。下面給出了這些實例變數：

public static boolean useFtpProxy

這個變數用於標明FTP傳輸過程中是不是運用了一個署理，因此，它實際上是一個符號，此符號若為TRUE，標明運用了一個署理主機。

public static String ftpProxyHost

此變數只要在變數useFtpProxy為TRUE時才有用，用於保留署理主機名。

public static int ftpProxyPort

此變數只要在變數useFtpProxy為TRUE時才有用，用於保留署理主機的埠地址。

FtpClient有三種不同方式的結構函數，如下所示：

1、public FtpClient(String hostname,int port)

此結構函數運用給出的主機名和埠號樹立一條FTP銜接。

2、public FtpClient(String hostname)

此結構函數運用給出的主機名樹立一條FTP銜接，運用默許埠號。

3、FtpClient()

此結構函數將創立一FtpClient類，但不樹立FTP銜接。這時，FTP銜接能夠用openServer辦法樹立。

一旦樹立了類FtpClient，就能夠用這個類的辦法來翻開與FTP伺服器的銜接。類ftpClient供給了如下兩個可用於翻開與FTP伺服器之間的銜接的辦法。

public void openServer(String hostname)

這個辦法用於樹立一條與指定主機上的FTP伺服器的銜接，運用默許埠號。

『伍』 怎麼用libcurl實現ftp斷點續傳

如何用libcurl實現ftp斷點續傳
如題，在libcurl官網上找了一個上傳函數，但測試無法實現
int upload(CURL *curlhandle, const char * remotepath, const char * localpath, long timeout, long tries)
{
FILE *f;
long uploaded_len = 0;
CURLcode r = CURLE_GOT_NOTHING;
int c;
f = fopen(localpath, "rb");
if (f == NULL) {
perror(NULL);
return 0;
}
curl_easy_setopt(curlhandle, CURLOPT_UPLOAD, 1L);
curl_easy_setopt(curlhandle, CURLOPT_URL, remotepath);
curl_easy_setopt(curlhandle, CURLOPT_USERPWD, "spider:spider");
if (timeout)
curl_easy_setopt(curlhandle, CURLOPT_FTP_RESPONSE_TIMEOUT, timeout);
curl_easy_setopt(curlhandle, CURLOPT_HEADERFUNCTION, getcontentlengthfunc);
curl_easy_setopt(curlhandle, CURLOPT_HEADERDATA, &uploaded_len);
curl_easy_setopt(curlhandle, CURLOPT_WRITEFUNCTION, discardfunc);
curl_easy_setopt(curlhandle, CURLOPT_READFUNCTION, readfunc);
curl_easy_setopt(curlhandle, CURLOPT_READDATA, f);
curl_easy_setopt(curlhandle, CURLOPT_FTPPORT, "-"); /* disable passive mode */
curl_easy_setopt(curlhandle, CURLOPT_FTP_CREATE_MISSING_DIRS, 1L);
curl_easy_setopt(curlhandle, CURLOPT_VERBOSE, 1L);
for (c = 0; (r != CURLE_OK) && (c < tries); c++) {
/* are we resuming */
if (c) { /* yes */
/* determine the length of the file already written */
/*
* With NOBODY and NOHEADER, libcurl will issue a SIZE
* command, but the only way to retrieve the result is
* to parse the returned Content-Length header. Thus,
* getcontentlengthfunc(). We need discardfunc() above
* because HEADER will mp the headers to stdout
* without it.
*/
curl_easy_setopt(curlhandle, CURLOPT_NOBODY, 1L);
curl_easy_setopt(curlhandle, CURLOPT_HEADER, 1L);
r = curl_easy_perform(curlhandle);
if (r != CURLE_OK)
continue;
curl_easy_setopt(curlhandle, CURLOPT_NOBODY, 0L);
curl_easy_setopt(curlhandle, CURLOPT_HEADER, 0L);
fseek(f, uploaded_len, SEEK_SET);
curl_easy_setopt(curlhandle, CURLOPT_APPEND, 1L);
}
else { /* no */
curl_easy_setopt(curlhandle, CURLOPT_APPEND, 0L);
}
r = curl_easy_perform(curlhandle);
}
fclose(f);
if (r == CURLE_OK)
return 1;
else {
fprintf(stderr, "%s\n", curl_easy_strerror(r));
return 0;
}
}

『陸』 java ftp下載

這個和ftp沒有太大關系，只是一個普通的下載，java連接ftp伺服器傳輸文件是需要提供ip 埠號，用戶名密碼 路徑的，這個只是一個靜態資源，用這個就可以，支持斷點續傳

這邊用到了apachecommons-httpclient-3.1包

importjava.io.File;
importjava.io.IOException;
importjava.io.InputStream;
importjava.io.RandomAccessFile;

importorg.apache.http.HttpEntity;
importorg.apache.http.HttpResponse;
importorg.apache.http.client.ClientProtocolException;
importorg.apache.http.client.HttpClient;
importorg.apache.http.client.methods.HttpGet;
importorg.apache.http.impl.client.DefaultHttpClient;

@SuppressWarnings("deprecation")
publicclassDownloadTool{
publicstaticvoidmain(String[]args)throwsClientProtocolException,IOException{
Stringurl="
[陽光電影
].神探駕到.BD.720p.國粵雙語中字.mkv";
StringdownFile="d:\aaa.mkv";//本地存放路徑
LongnetFileLenght=getNetFileSize(url);
LonglocalFileLenght=getLocalFileSize(downFile);

if(localFileLenght>=netFileLenght){
System.out.println("已下載完成");
return;
}

System.out.println("netFileLenght:"+netFileLenght+"localFileLenght:"+localFileLenght);
finalHttpClienthttpClient=newDefaultHttpClient();
httpClient.getParams().setIntParameter("http.socket.timeout",5000);

finalHttpGethttpGet=newHttpGet(url);
httpGet.addHeader("Range","bytes="+localFileLenght+"-");

finalHttpResponseresponse=httpClient.execute(httpGet);
finalintcode=response.getStatusLine().getStatusCode();
finalHttpEntityentity=response.getEntity();
System.out.println(code);

if(entity!=null&&code<400){

Filefile=newFile(downFile);
=newRandomAccessFile(file,"rw");
randomAccessFile.seek(localFileLenght);

InputStreaminputStream=entity.getContent();
intb=0;
finalbytebuffer[]=newbyte[1024];
while((b=inputStream.read(buffer))!=-1){
randomAccessFile.write(buffer,0,b);
}

randomAccessFile.close();
inputStream.close();
httpClient.getConnectionManager().shutdown();
System.out.println("下載完成");
}
}

(StringfileName){
Filefile=newFile(fileName);
returnfile.length();
}

(Stringurl){
Longcount=-1L;
finalHttpClienthttpClient=newDefaultHttpClient();
httpClient.getParams().setIntParameter("http.socket.timeout",5000);

finalHttpGethttpGet=newHttpGet(url);
HttpResponseresponse=null;
try{
response=httpClient.execute(httpGet);
finalintcode=response.getStatusLine().getStatusCode();
finalHttpEntityentity=response.getEntity();
if(entity!=null&&code==200){
count=entity.getContentLength();
}
}catch(ClientProtocolExceptione){
e.printStackTrace();
}catch(IOExceptione){
e.printStackTrace();
}finally{
httpClient.getConnectionManager().shutdown();
}
returncount;
}
}

『柒』 FTP該如何實現斷點續傳

客戶端的實現步驟如下：
一、下載：
1、向伺服器發送「REST + 本地文件長度」命令，告訴伺服器，客戶端要斷點下載了。這時伺服器還不知道客戶端要下載哪個文件；
要實現FTP的斷點續傳，FTP伺服器必須支持REST指令，這條指令在FTP協議文本RFC959中就已經定義了，不過它不是FTP伺服器必須支持的指令。一般,你可以在下載前使用REST 100命令進行實驗，如果伺服器正常執行了這條命令，說明該伺服器支持FTP斷點續傳。REST後面跟的數表示下載文件的起始位置，而REST 0表示從文件最開始處下載。REST命令本身並不執行下載功能，你仍需要使用RETR命令執行下載工作。
2、向伺服器發送「RETR + 文件名」命令，通知伺服器要下載的文件名，這時伺服器開始定位文件指針讀文件並發送數據。
3、客戶端定位本地文件指針（文件末尾）；
4、兩端的准備工作都做完了以後，客戶端創建socket，以被動或非被動方式建立數據通道，循環調用recv接收數據並追加入本地文件；
二、上傳：
1、獲取伺服器上和本地要上傳文件的同名文件大小；
2、向伺服器發送「APPE ＋ 文件名」，通知伺服器，接下來從數據通道發送給你的數據要附加到這個文件末尾。
3、定位本地文件指針（和FTP上文件大小相同的位置）
4、從文件指針處讀數據並發送。
代碼里將斷點上傳和斷點下載放到同一個函數（MoveFile）里，通過get參數說明是上傳還是下載。

『捌』 java ftp上傳時斷網，文件損壞

以二進制流上傳，然後實現斷點續傳。

/**
* 上傳文件到FTP伺服器，支持斷點續傳
* @param local 本地文件名稱，絕對路徑
* @param remote 遠程文件路徑，使用/home/directory1/subdirectory/file.ext 按照Linux上的路徑指定方式，支持多級目錄嵌套，支持遞歸創建不存在的目錄結構
* @return 上傳結果
* @throws IOException
*/
public UploadStatus upload(String local,String remote) throws IOException{
FTPClient ftpClient = new FTPClient();
//設置PassiveMode傳輸
ftpClient.enterLocalPassiveMode();
//設置以二進制流的方式傳輸
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
UploadStatus result;
//對遠程目錄的處理
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)){
//如果遠程目錄不存在，則遞歸創建遠程伺服器目錄
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("創建目錄失敗");
return UploadStatus.Create_Directory_Fail;
}
}

start = end + 1;
end = directory.indexOf("/",start);

//檢查所有目錄是否創建完畢
if(end <= start){
break;
}
}
}
}

//檢查遠程是否存在文件
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;
}

//嘗試移動文件內讀取指針,實現斷點續傳
InputStream is = new FileInputStream(f);
if(is.skip(remoteSize)==remoteSize){
ftpClient.setRestartOffset(remoteSize);
if(ftpClient.storeFile(remote, is)){
return UploadStatus.Upload_From_Break_Success;
}
}

//如果斷點續傳沒有成功，則刪除伺服器上文件，重新上傳
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;
}