基于斷點(diǎn)續(xù)傳下載原理的實(shí)現(xiàn)
需求背景
動態(tài)創(chuàng)建的文件下載的時(shí)候希望瀏覽器顯示下載進(jìn)度
動態(tài)創(chuàng)建的文件希望能夠分段下載
HTTP斷點(diǎn)續(xù)傳報(bào)文
要實(shí)現(xiàn)HTTP斷點(diǎn)續(xù)傳必須要簡單了解以下幾個(gè)報(bào)文。
Accept-Ranges 告訴客戶端(瀏覽器..)服務(wù)器端支持?jǐn)帱c(diǎn)續(xù)傳 服務(wù)器端返回
Range 客戶端告訴服務(wù)器端從指定的的位置/范圍(這里值字節(jié)數(shù))下載資源 客戶端發(fā)出
Content-Range 服務(wù)器端告訴客戶端響應(yīng)的數(shù)據(jù)信息,在整個(gè)返回體中本部分的字節(jié)位置 服務(wù)器端返回
ETag 資源標(biāo)識 非必須 服務(wù)器端返回
Last-Modified 資源最后一次更新的時(shí)間 非必須 服務(wù)器端返回
Range 的范圍格式
表示0-499個(gè)字節(jié)范圍:Range: bytes=0-499
表示最后500個(gè)字節(jié)范圍:Range: bytes=-500
表示500字節(jié)開始到結(jié)束范圍:Range: bytes=500-
表示第一個(gè)和最后一個(gè)字節(jié):Range: bytes=0-0,-1
表示同時(shí)指定幾個(gè)范圍:Range: bytes=500-600,601-999
Content-Range 的數(shù)據(jù)格式
Content-Range: bytes 0-499/22036 :表示返回0-499字節(jié)范圍數(shù)據(jù) 資源一共22036個(gè)字節(jié)
原理
客戶端發(fā)起請求 設(shè)置Range指定開始字節(jié)數(shù)或結(jié)束字節(jié)數(shù) 如果是從0開始也可以不用設(shè)置。
服務(wù)器端檢查到客戶端Range頭 解析開始字節(jié)數(shù)以及結(jié)束字節(jié)數(shù) 并返回報(bào)文頭 Accept-Ranges表示支持?jǐn)帱c(diǎn)續(xù)傳,Content-Range記錄該次向客戶端寫入流的位置信息,然后再寫入流到客戶端。
服務(wù)端可以使用ETag Last-Modified 標(biāo)記一下資源是否被修改。作一些驗(yàn)證工作,如果驗(yàn)證不通過則返回錯(cuò)誤,非必須項(xiàng)。
java實(shí)現(xiàn)
OutputStream os=null; InputStream inputStream =null; File zipFile=null; try{ long zipStart=System.currentTimeMillis(); zipFile=createFile();//動態(tài)根據(jù)業(yè)務(wù)創(chuàng)建文件 if(logger.isInfoEnabled()){ logger.info(String.format("壓縮ZIP 花費(fèi)時(shí)間 %s(s) ", (System.currentTimeMillis()-zipStart)/1000)); } if (zipFile.exists()) { long downloadStart=System.currentTimeMillis(); inputStream= new BufferedInputStream(new FileInputStream(zipFile)); response.reset(); os=new BufferedOutputStream(response.getOutputStream()); String userAgent = request.getHeader("USER-AGENT"); String fileName=zipFile.getName(); if (null != userAgent && -1 != userAgent.indexOf("MSIE")) { fileName = URLEncoder.encode(fileName, "UTF8"); } else if (null != userAgent && -1 != userAgent.indexOf("Mozilla")) { fileName = new String(fileName.getBytes("utf-8"), "ISO-8859-1"); } response.setHeader("Accept-Ranges", "bytes"); response.setHeader("Content-Disposition", "attachment;filename="+ fileName); response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE); long pos = 0, fileSize=zipFile.length(), last=fileSize-1; response.setHeader("ETag",zipFile.getName(). concat(Objects.toString(fileSize)) .concat("_").concat(Objects.toString(zipFile.lastModified()))); response.setDateHeader("Last-Modified",zipFile.lastModified()); response.setDateHeader("Expires", System.currentTimeMillis()+1000*60*60*24); if (null != request.getHeader("Range")) { response.setStatus(HttpServletResponse.SC_PARTIAL_CONTENT); try { // 暫時(shí)只處理這2種range格式 1、RANGE: bytes=111- 2、Range: bytes=0-499 String numRang = request.getHeader("Range") .replaceAll("bytes=", ""); String[] strRange = numRang.split("-"); if (strRange.length == 2) { pos = Long.parseLong(strRange[0].trim()); last = Long.parseLong(strRange[1].trim()); } else { pos = Long.parseLong(numRang.replaceAll("-", "").trim()); } } catch (NumberFormatException e) { logger.error(request.getHeader("Range") + " error"); pos = 0; } } long rangLength = last - pos + 1; String contentRange = new StringBuffer("bytes "). append(String.valueOf(pos)). append("-").append(last).append("/"). append(String.valueOf(fileSize)).toString(); response.setHeader("Content-Range", contentRange); response.addHeader("Content-Length",Objects.toString(rangLength)); if(pos>0){ inputStream.skip(pos); } byte[] buffer = new byte[1024*512];//每次以512KB 0.5MB的流量下載 int length = 0,sendTotal=0; while (sendTotal < rangLength && length!=-1) { length = inputStream.read(buffer, 0, ((rangLength - sendTotal) <= buffer.length ? ((int) (rangLength - sendTotal)) : buffer.length)); sendTotal = sendTotal + length; os.write(buffer, 0, length); } if(os!=null){ os.flush(); } if(logger.isInfoEnabled()){ logger.info(String.format("下載 花費(fèi)時(shí)間 %s(s) ", (System.currentTimeMillis()-downloadStart)/1000)); } } }catch (Exception e){ if(StringUtils.endsWithIgnoreCase(e.getMessage(),"Broken pipe")){ logger.error("用戶取消下載"); } logger.error(e.getMessage(),e); }finally { if(os!=null){ try{ os.close(); }catch (Exception e){} } if(inputStream!=null){ try{ IOUtils.closeQuietly(inputStream); }catch (Exception e){} } } }
比如google瀏覽器下載的時(shí)候就能看到下載進(jìn)度以及暫停下載和恢復(fù)下載操作,也可以設(shè)置Range測試分段下載。
以上這篇基于斷點(diǎn)續(xù)傳下載原理的實(shí)現(xiàn)就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot請求處理之常用參數(shù)注解介紹與源碼分析
SpringBoot是一種整合Spring技術(shù)棧的方式(或者說是框架),同時(shí)也是簡化Spring的一種快速開發(fā)的腳手架,本篇讓我們一起學(xué)習(xí)請求處理、常用注解和方法參數(shù)的小技巧2022-10-10詳解Java如何實(shí)現(xiàn)在PDF中插入,替換或刪除圖像
圖文并茂的內(nèi)容往往讓人看起來更加舒服,如果只是文字內(nèi)容的累加,往往會使讀者產(chǎn)生視覺疲勞。搭配精美的文章配圖則會使文章內(nèi)容更加豐富。那我們要如何在PDF中插入、替換或刪除圖像呢?別擔(dān)心,今天為大家介紹一種高效便捷的方法2023-01-01Java詳細(xì)講解IO流的Writer與Reader操作
Writer與Reader類不能直接調(diào)用,需要使用多帶的方法調(diào)用它們的子類,在他們的前邊加上一個(gè)File即可如(FileWriter或FileReader)的多態(tài)方法進(jìn)行其調(diào)用,并且他們也是抽象類調(diào)用需要連接接口Exception,它們的優(yōu)點(diǎn)在于可以直接寫入或讀出內(nèi)容,不需要使用byte轉(zhuǎn)八進(jìn)制2022-05-05JavaFX桌面應(yīng)用未響應(yīng)問題解決方案
這篇文章主要介紹了JavaFX桌面應(yīng)用未響應(yīng)問題解決方案,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-07-07Eureka源碼閱讀Client啟動入口注冊續(xù)約及定時(shí)任務(wù)
這篇文章主要為大家介紹了Eureka源碼閱讀Client啟動入口注冊續(xù)約及定時(shí)任務(wù)示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-10-10JavaWeb?Servlet技術(shù)及其應(yīng)用實(shí)踐
這篇文章主要介紹了JavaWeb?Servlet技術(shù),Servlet指在服務(wù)器端執(zhí)行的一段Java代碼,可以接收用戶的請求和返回給用戶響應(yīng)結(jié)果,感興趣想要詳細(xì)了解可以參考下文2023-05-05Struts2學(xué)習(xí)教程之Action類如何訪問WEB資源
這篇文章主要給大家介紹了關(guān)于Struts2學(xué)習(xí)教程之Action類如何訪問WEB資源的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-04-04基于SpringBoot和Vue實(shí)現(xiàn)頭像上傳與回顯功能
在現(xiàn)代Web應(yīng)用中,用戶個(gè)性化體驗(yàn)尤為重要,其中頭像上傳與回顯是一個(gè)常見的功能需求,本文將詳細(xì)介紹如何使用Spring Boot和Vue.js構(gòu)建一個(gè)前后端協(xié)同工作的頭像上傳系統(tǒng),并實(shí)現(xiàn)圖片的即時(shí)回顯,需要的朋友可以參考下2024-08-08img 加載網(wǎng)絡(luò)圖片失敗 顯示默認(rèn)圖片的方法
下面小編就為大家?guī)硪黄猧mg 加載網(wǎng)絡(luò)圖片失敗 顯示默認(rèn)圖片的方法。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-05-05