斷點續傳java

❶ 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版本是不支持的。

補充：
嗯，查到了，是設置range屬性，即setRequestProperty("range", "bytes=513-1024").你可以使用迅雷下載某個文件，然後從」線程信息「中就可以看到這個http1.1斷點續傳的所有行為信息了。
希望能解決您的問題。

❷ 斷點續傳 java後台怎麼處理

實現思路：
(1) 創建一個下載任務類SiteInfoBean（用於記錄文件保存的目錄，文件下載URL，文件名)
(2) 創建一個FileAccessI 用於隨機訪問文件，向文件寫入內容。

(3) 創建一個下載任務執行線程SiteFileFetch，此線程主要做如下工作
(a) 接受指定 下載子線程個數
(b) 首先判斷下載的文件是否存在，
如果下載的文件已經存在則繼續判斷它對應的xxx.info文件是否存在，
如果info文件存在則認為是上次下載沒有完成。此時讀取info文件中的下載信息，分配下載區段。
如果info文件不存在，則認為已經下載完了，重新命名一個文件xxx(1)，如果重新命名的文件也存在則繼續累加命名xxx(2)...
(c) 判斷臨時文件xxx.info 文件（用於保存文件下載信息：下載子線程個數，子線程1開始位置,子線程1結束位置,子線程2開始位置,子線程2結束位置,...)
是否存在，存在則說明是上次沒有下載完成，不存在則創建此臨時info文件記錄下載信息。
(d) 獲取文件總長度，根據子線程個數將長度劃分若乾等分
(e) 創建若乾子線程，為每個子線程分配下載區段(文件開始位置,文件結束位置)，啟動子線程
(f) 每隔500ms從各個子線程獲取當前下載的進度位置，然後覆蓋保存在xxx.info文件中。
(g) 每隔500ms同時判斷是否存在沒有下載完分配區段內容的子線程，如果存在則認為整個下載任務是沒有完成的，如果不存在則認為總的已經下載完成。
(h) 每隔500ms同時統計出總的下載進度，當進度達到100%的時候，刪除臨時文件xx.info文件

❸ Java ftp 斷點續傳報錯

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

❹ 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;
}

❺ Java Socket如何實現文件的斷點續傳，有代碼更好

1package com.tangshun.www.socket;
2
3import java.io.File;
4import java.io.IOException;
5import java.io.InputStream;
6import java.io.RandomAccessFile;
7import java.net.HttpURLConnection;
8import java.net.MalformedURLException;
9import java.net.URL;
10
11//斷點續傳
12public class DownLoad {
13
14 public static void down(String URL, long nPos, String savePathAndFile) {
15 try {
16 URL url = new URL(URL);
17 HttpURLConnection httpConnection = (HttpURLConnection) url
18 .openConnection();
19 // 設置User-Agent
20 httpConnection.setRequestProperty("User-Agent", "NetFox");
21 // 設置斷點續傳的開始位置
22 httpConnection.setRequestProperty("RANGE", "bytes=" + nPos);
23 // 獲得輸入流
24 InputStream input = httpConnection.getInputStream();
25 RandomAccessFile oSavedFile = new RandomAccessFile(savePathAndFile,
26 "rw");
27 // 定位文件指針到nPos位置
28 oSavedFile.seek(nPos);
29 byte[] b = new byte[1024];
30 int nRead;
31 // 從輸入流中讀入位元組流，然後寫到文件中
32 while ((nRead = input.read(b, 0, 1024)) > 0) {
33 (oSavedFile).write(b, 0, nRead);
34 }
35 httpConnection.disconnect();
36 } catch (MalformedURLException e) {
37 e.printStackTrace();
38 } catch (IOException e) {
39 e.printStackTrace();
40 }
41 }
42
43 public static long getRemoteFileSize(String url) {
44 long size = 0;
45 try {
46 HttpURLConnection conn = (HttpURLConnection) (new URL(url))
47 .openConnection();
48 size = conn.getContentLength();
49 conn.disconnect();
50 } catch (Exception e) {
51 e.printStackTrace();
52 }
53 return size;
54 }
55
56public static void main(String[] args) {
57 String url = " http://www.videosource.cgogo.com/media/0/16/8678/8678.flv";
58 String savePath = "F:\\";
59 String fileName = url.substring(url.lastIndexOf("/"));
60 String fileNam=fileName;
61 HttpURLConnection conn = null;
62 try {
63 conn = (HttpURLConnection) (new URL(url)).openConnection();
64 } catch (Exception e) {
65 e.printStackTrace();
66 }
67 File file = new File(savePath + fileName);
68 // 獲得遠程文件大小
69 long remoteFileSize = getRemoteFileSize(url);
70 System.out.println("遠程文件大小="+remoteFileSize);
71 int i = 0;
72 if (file.exists()) {
73 // 先看看是否是完整的，完整，換名字，跳出循環，不完整，繼續下載
74 long localFileSize = file.length();
75 System.out.println("已有文件大小為:"+localFileSize);
76
77 if (localFileSize < remoteFileSize) {
78 System.out.println("文件續傳");
79 down(url, localFileSize, savePath + fileName);
80 }else{
81 System.out.println("文件存在，重新下載");
82 do{
83 i++;
84 fileName = fileNam.substring(0, fileNam.indexOf(".")) + "(" + i
85 + ")" + fileNam.substring(fileNam.indexOf("."));
86
87 file = new File(savePath + fileName);
88 }while(file.exists());
89 try {
90 file.createNewFile();
91 } catch (IOException e) {
92 e.printStackTrace();
93 }
94 down(url, 0, savePath + fileName);
95 }
96 // 下面表示文件存在，改名字
97
98 } else {
99 try {
100 file.createNewFile();
101 System.out.println("下載中");
102 down(url, 0, savePath + fileName);
103 } catch (IOException e) {
104 e.printStackTrace();
105 }
106 }
107 }}
108