基于断点续传下载原理的实现
需求背景
动态创建的文件下载的时候希望浏览器显示下载进度
动态创建的文件希望能够分段下载
HTTP断点续传报文
要实现HTTP断点续传必须要简单了解以下几个报文。
Accept-Ranges告诉客户端(浏览器..)服务器端支持断点续传服务器端返回
Range客户端告诉服务器端从指定的的位置/范围(这里值字节数)下载资源客户端发出
Content-Range服务器端告诉客户端响应的数据信息,在整个返回体中本部分的字节位置服务器端返回
ETag资源标识非必须服务器端返回
Last-Modified资源最后一次更新的时间非必须服务器端返回
Range的范围格式
表示0-499个字节范围:Range:bytes=0-499
表示最后500个字节范围:Range:bytes=-500
表示500字节开始到结束范围:Range:bytes=500-
表示第一个和最后一个字节:Range:bytes=0-0,-1
表示同时指定几个范围:Range:bytes=500-600,601-999
Content-Range的数据格式
Content-Range:bytes0-499/22036:表示返回0-499字节范围数据资源一共22036个字节
原理
客户端发起请求设置Range指定开始字节数或结束字节数如果是从0开始也可以不用设置。
服务器端检查到客户端Range头解析开始字节数以及结束字节数并返回报文头Accept-Ranges表示支持断点续传,Content-Range记录该次向客户端写入流的位置信息,然后再写入流到客户端。
服务端可以使用ETagLast-Modified标记一下资源是否被修改。作一些验证工作,如果验证不通过则返回错误,非必须项。
java实现
OutputStreamos=null; InputStreaminputStream=null; FilezipFile=null; try{ longzipStart=System.currentTimeMillis(); zipFile=createFile();//动态根据业务创建文件 if(logger.isInfoEnabled()){ logger.info(String.format("压缩ZIP花费时间%s(s)", (System.currentTimeMillis()-zipStart)/1000)); } if(zipFile.exists()){ longdownloadStart=System.currentTimeMillis(); inputStream=newBufferedInputStream(newFileInputStream(zipFile)); response.reset(); os=newBufferedOutputStream(response.getOutputStream()); StringuserAgent=request.getHeader("USER-AGENT"); StringfileName=zipFile.getName(); if(null!=userAgent&&-1!=userAgent.indexOf("MSIE")){ fileName=URLEncoder.encode(fileName,"UTF8"); }elseif(null!=userAgent&&-1!=userAgent.indexOf("Mozilla")){ fileName=newString(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); longpos=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{ //暂时只处理这2种range格式1、RANGE:bytes=111-2、Range:bytes=0-499 StringnumRang=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(NumberFormatExceptione){ logger.error(request.getHeader("Range")+"error"); pos=0; } } longrangLength=last-pos+1; StringcontentRange=newStringBuffer("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=newbyte[1024*512];//每次以512KB0.5MB的流量下载 intlength=0,sendTotal=0; while(sendTotal比如google浏览器下载的时候就能看到下载进度以及暂停下载和恢复下载操作,也可以设置Range测试分段下载。
以上这篇基于断点续传下载原理的实现就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。