HttpURLConnection實現檔案斷點續傳

阿新 • • 發佈：2019-01-27

首先

client端：

HttpURLConnection conn = null;
BufferedInputStream fin = null;
BufferedOutputStream out = null;
URL reqUrl;
try {
reqUrl = new URL("http://<ip>:<port>/Emergency/phone/attachmentUpload");
conn = (HttpURLConnection) reqUrl.openConnection();
conn.setConnectTimeout(3000);
conn.setRequestMethod("PUT");
if(isCommit){
conn.setRequestProperty("isCommit", "true");
}else{
conn.setRequestProperty("isCommit", "false");
}
conn.setRequestMethod("PUT"

);
conn.setRequestProperty("Content-Type", "binary/octet-stream");
conn.setRequestProperty("offset", StringUtil.toString(offset));
conn.setDoOutput(true);
conn.setDoInput(true);
// 1M的chunk緩衝
conn.setChunkedStreamingMode(1024*1024

);
out = new BufferedOutputStream(conn.getOutputStream());
fin = new BufferedInputStream(new FileInputStream(file));
byte[] buf = newbyte[bufferSizeUpload];
int len = -1;
long currentUploadSize = offset;
fin.skip(offset);
while ((len = fin.read(buf)) != -1&currentUploadSize<offset+uploadSize) {
if(offset+uploadSize-currentUploadSize<bufferSizeUpload){
len = Integer.parseInt(StringUtil.toString(offset+uploadSize-currentUploadSize));
}
if(len>0){
if(out!=null){
out.write(buf, 0, len);
out.flush();
}
}
currentUploadSize += len;
}
} catch (SocketTimeoutException e) {
e.printStackTrace();
} catch(IOException e){
e.printStackTrace();
} finally {
try {
if (fin != null) {
fin.close();
fin = null;
}
if (out != null) {
out.close();
out = null;
}
if (conn != null) {
conn.disconnect();
conn = null;
}
} catch (IOException ioe) {
ioe.printStackTrace();
thrownew RuntimeException("Release resource failed.");
}
}

HttpURLConnection conn = null;
		BufferedInputStream fin = null;
		BufferedOutputStream out = null;
		URL reqUrl;
		try {
			reqUrl = new URL("http://<ip>:<port>/Emergency/phone/attachmentUpload");
			conn = (HttpURLConnection) reqUrl.openConnection();
			conn.setConnectTimeout(3000);
			conn.setRequestMethod("PUT");
			if(isCommit){
				conn.setRequestProperty("isCommit", "true");
			}else{
				conn.setRequestProperty("isCommit", "false");
			}
			conn.setRequestMethod("PUT");
			conn.setRequestProperty("Content-Type", "binary/octet-stream");
			conn.setRequestProperty("offset", StringUtil.toString(offset));
			conn.setDoOutput(true);
			conn.setDoInput(true);
			// 1M的chunk緩衝
			conn.setChunkedStreamingMode(1024*1024);
			out = new BufferedOutputStream(conn.getOutputStream());
			fin = new BufferedInputStream(new FileInputStream(file));
			byte[] buf = new byte[bufferSizeUpload];
			int len = -1;
			long currentUploadSize = offset;
			fin.skip(offset);
			while ((len = fin.read(buf)) != -1&currentUploadSize<offset+uploadSize) {
				if(offset+uploadSize-currentUploadSize<bufferSizeUpload){
					len = Integer.parseInt(StringUtil.toString(offset+uploadSize-currentUploadSize));
				}
				if(len>0){
					if(out!=null){
						out.write(buf, 0, len);
						out.flush();
					}
				}
				currentUploadSize += len;
			}
		} catch (SocketTimeoutException e) {
			e.printStackTrace();
		} catch(IOException e){
			e.printStackTrace();
		} finally {
			try {
				if (fin != null) {
					fin.close();
					fin = null;
				}
				if (out != null) {
					out.close();
					out = null;
				}
				if (conn != null) {
					conn.disconnect();
					conn = null;
				}
			} catch (IOException ioe) {
				ioe.printStackTrace();
				throw new RuntimeException("Release resource failed.");
			}
		}

如上所示：url引數通過setRequestProperty方法放在請求頭中，而檔案流放在 body 中。

同時需要注意 HttpURLConnection.setChunkedStreamingMode 此方法保證每次檔案流達到指定大小就傳送一次，避免了放在快取並一次性傳輸中可能遇到的資料缺失。

服務端：

[java] view plain copy print?

public String underUpload() throws IOException{
String data = request.getHeader("data");
String userInfo = request.getHeader("userInfo");
userInfo = new String(userInfo.getBytes("iso-8859-1"),"GBK");
//System.out.println(data);
//System.out.println(userInfo);
Map<String,String> data_map = gson.fromJson(data,attachVo.data_map.getClass());
if(data_map!=null) attachVo.data_map=data_map;
attachVo.user = gson.fromJson(userInfo,attachVo.user.getClass());
apiService.attachUpload(attachVo,new BufferedInputStream(request.getInputStream()));
//response.setStatus(200);
returnnull;
}

public String underUpload() throws IOException{
		String data = request.getHeader("data"); 
		String userInfo = request.getHeader("userInfo"); 
		userInfo = new String(userInfo.getBytes("iso-8859-1"),"GBK");
		//System.out.println(data);
		//System.out.println(userInfo);
		Map<String,String> data_map = gson.fromJson(data,attachVo.data_map.getClass());
		if(data_map!=null) attachVo.data_map=data_map;
		attachVo.user = gson.fromJson(userInfo,attachVo.user.getClass());
		apiService.attachUpload(attachVo,new BufferedInputStream(request.getInputStream()));
		//response.setStatus(200);
		return null;
	}

使用的是ssh架構，通過getHeader 得到 url引數，通過getInputStream得到檔案流，同時還要控制好編碼，以防中文亂碼。

至於斷點續傳，基本思想是通過資訊頭的部分傳遞每次傳輸的檔案大小，與伺服器端的檔案大小匹配。並通過

[java] view plain copy print?

RandomAccessFile raFile = new RandomAccessFile(uploadFile.getAbsolutePath(), "rw");
raFile.seek(uploadFile.length());

RandomAccessFile raFile = new RandomAccessFile(uploadFile.getAbsolutePath(), "rw");
		raFile.seek(uploadFile.length());

方法進行根據傳輸大小實時進行檔案讀寫。

[java] view plain copy print?

publicstaticvoid saveFile(String destFilePathStr,String destFileName){
try {
File destFilePath = new File(destFilePathStr);
if(!destFilePath.exists()){
destFilePath.mkdirs();
destFilePath = null;
}
File destFile = new File(destFilePathStr+"//"+destFileName);
if(!destFile.exists()){
destFile.createNewFile();
}
} catch (Exception e) {
e.printStackTrace();
}
}
publicstaticlong uploadFile(String offset,String destFileName,BufferedInputStream bis)
throws IOException{
File uploadFile = new File(destFileName);
int len = 0;
byte[] bt = newbyte[1024];
RandomAccessFile raFile = new RandomAccessFile(uploadFile.getAbsolutePath(), "rw");
raFile.seek(uploadFile.length());
while ((len = bis.read(bt)) > 0){
raFile.write(bt, 0, len);
}
long l = raFile.length();
try {
if(bis != null)
bis.close();
if (raFile != null)
raFile.close();
} catch (IOException e) {
l = 0;
e.printStackTrace();
}
return l ;
}

public static void saveFile(String destFilePathStr,String destFileName){
		try {
			File destFilePath = new File(destFilePathStr);
			if(!destFilePath.exists()){
				destFilePath.mkdirs();
				destFilePath = null;
			}
			File destFile = new File(destFilePathStr+"//"+destFileName);
			if(!destFile.exists()){
				destFile.createNewFile();
			}
	
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static long uploadFile(String offset,String destFileName,BufferedInputStream bis) 
	throws IOException{
		File uploadFile = new File(destFileName);
		int len = 0;
		byte[] bt = new byte[1024];
		RandomAccessFile raFile = new RandomAccessFile(uploadFile.getAbsolutePath(), "rw");
		raFile.seek(uploadFile.length());
	    while ((len = bis.read(bt)) > 0){
	    	raFile.write(bt, 0, len);
    	}
	    long l = raFile.length();
	    try {
		     if(bis != null)
		    	 bis.close();
		     if (raFile != null)
		    	 raFile.close();
		     
		} catch (IOException e) {
			l = 0;
		    e.printStackTrace();
		}
		return l ;
	}

首先建立一個空檔案，接下來根據每次接收的檔案流及檔案長度寫入檔案。

HttpURLConnection實現檔案斷點續傳

首先 client端： [java] view plain copy print? HttpURLConnection conn = null; BufferedInputStream fin = null; Buffere

springmvc mybatis fileupload實現檔案斷點續傳

為什麼要斷點續傳：在傳輸較大檔案沒傳輸完成時若出現斷網或者伺服器異常等情況則檔案會上傳失敗，使用者需要重新開始上傳檔案，這樣會使使用者體驗十分不好，所以需要有斷點續傳。斷點續傳好的方法是將檔案分為N個片段進行上傳，這樣即使後面的片段還未上傳完畢之前已上傳的片段也會得以保留。

Android 實現多執行緒下載檔案+斷點續傳

Android 多執行緒下載檔案+斷點續傳在專案快要結束的時候，發現了app沒有版本更新的功能，於是找到一些過去的資料，在app上應用完成了版本更新，現在記錄一下apk的下載，也就是如何通過多執行緒將ap

java檔案斷點續傳的簡單實現

import java.awt.Color; import java.awt.Container; import java.awt.Dimension; import java.awt.FlowLayout; import java.awt.event.ActionEvent; import java.aw

一分鐘實現多檔案斷點續傳——斷點續傳框架

本人先前的部落格有對多檔案分段斷點續傳的功能進行詳細的介紹，如果你有興趣可以先閱讀Android多檔案斷點續傳（一）——資料封裝以及介面實現。本人在先前的基礎上對程式碼進行了封裝，本帖主要介紹如何整合封裝好的框架快速實現多檔案分段斷點續傳功能。先看效果圖

IOS 下載檔案斷點續傳原理與實現(附原始碼)

在網路狀況不好的情況下，對於檔案的傳輸，我們希望能夠支援可以每次傳部分資料。首先從檔案傳輸協議FTP和TFTP開始分析， FTP是基於TCP的，一般情況下建立兩個連線，一個負責指令，一個負責資料；而TFTP是基於UDP的，由於UDP傳輸是不可靠的，雖然傳輸速度很快，但對於普通的檔案像PDF這種，少了一個

php實現大檔案斷點續傳下載例項

require_once('download.class.php'); date_default_timezone_set('Asia/Shanghai'); error_reporting(E_STRICT); function errorHandler($errno, $errs

【飛秋教程】檔案斷點續傳

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！

(QT) C++ 版本IM通訊軟體（客戶端+伺服器文字聊天、檔案斷點續傳、線上使用者搜尋）

緊接著上一節課程，這次的作業是要求實現一個簡易版的“QQ”，可支援“軟體需求”所列出的功能。當時由於圖方便便選擇了QTCPSocket進行整個過程的通訊（事後才知道有多坑）。服務端介面比較簡單，就幾個按鈕一個進度條，主要在客戶端實現了基本的功能和介面。整個學習和

阿里雲OSS單檔案斷點續傳+前端簡單展示（springmvc架構）

業務沒有需要多檔案一起上傳，所以這裡只是單檔案，多檔案的話也是在獲得File的地方變成List即可，多個迴圈，多一些執行緒，網上有程式碼一、pom.xml <dependencys> <dependenc

Android使用OKHttp3實現下載(斷點續傳、顯示進度)

OKHttp3是如今非常流行的Android網路請求框架,那麼如何利用Android實現斷點續傳呢,今天寫了個Demo嘗試了一下,感覺還是有點意思準備階段我們會用到OKHttp3來做網路請求,使用RxJava來實現執行緒的切換,並且開啟Java8來啟用Lambda表示式

Java實現的斷點續傳功能

import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.io.RandomAccessFile; impor

java http大檔案斷點續傳上傳

1，專案調研因為需要研究下斷點上傳的問題。找了很久終於找到一個比較好的專案。在GoogleCode上面，程式碼弄下來超級不方便，還是配置hosts才好，把程式碼重新上傳到了github上面。效果：上傳中，顯示進度，時間，百分比。點選【Pause

使用OKHttp3實現下載(斷點續傳、顯示進度)

今日科技快訊近日，於國務院總理李克強在《政府工作報告》中明確提到全面取消國內長途和漫遊費後，三大運營商中國移動、中國聯通、中國電信同時宣佈：今年10月1日起，將取消手機漫遊費。

HTTP檔案斷點續傳的原理

前幾天一個同事跑過來找我說，我們在廣告素材視訊這塊想做斷點續傳，就是這次某個視訊快取到一半，下次不用重頭開始，可以在原來停留得位置開始繼續下載.以提供更好的使用者體驗。同時說需要我們支援吐素材地址的業務介面告訴終端最後修改時間/檔案簽名（md5），用這個用來判斷我當前要下的檔案有沒有變化，同時告訴終端檔案