중단점 이력서 다운로드 원칙의 Java 구현 공유 예

요구사항 배경

• 동적으로 생성된 파일을 다운로드할 때 브라우저에 다운로드 진행률이 표시되기를 바랍니다

• 동적으로 생성된 파일은 세그먼트별로 다운로드할 수 있기를

HTTP 중단점 재개 메시지

가 되도록 HTTP를 구현했습니다. 재개 가능한 전송을 위해서는 다음 메시지에 대한 간략한 이해가 필요합니다. HTTP断点续传必须要简单了解以下几个报文。

• Accept-Ranges 告诉客户端(浏览器..)服务器端支持断点续传 服务器端返回

• Range 客户端告诉服务器端从指定的的位置/范围(这里值字节数)下载资源 客户端发出

• Content-Range 服务器端告诉客户端响应的数据信息，在整个返回体中本部分的字节位置 服务器端返回

• ETag 资源标识 非必须 服务器端返回

• Last-Modified 资源最后一次更新的时间 非必须 服务器端返回

Range 的范围格式

1. 表示0-499个字节范围：Range: bytes=0-499

2. 表示最后500个字节范围：Range: bytes=-500

3. 表示500字节开始到结束范围：Range: bytes=500-

4. 表示第一个和最后一个字节：Range: bytes=0-0,-1

5. 表示同时指定几个范围：Range: bytes=500-600,601-999

Content-Range 的数据格式

Content-Range: bytes 0-499/22036 ：表示返回0-499字节范围数据 资源一共22036个字节

原理

1. 客户端发起请求 设置Range指定开始字节数或结束字节数 如果是从0开始也可以不用设置。

2. 服务器端检查到客户端Range头 解析开始字节数以及结束字节数 并返回报文头 Accept-Ranges表示支持断点续传，Content-Range记录该次向客户端写入流的位置信息，然后再写入流到客户端。

3. 服务端可以使用ETag Last-Modified

Accept-Ranges는 서버가 중단점 재개를 지원한다고 클라이언트(브라우저..)에 알립니다. 서버 반환

Range 클라이언트는 서버에 지정된 위치/범위( 값은 여기서 바이트 수입니다) 리소스 다운로드 클라이언트 전송

🎜Content-Range 서버는 클라이언트에게 응답 데이터 정보, 전체 반환 본문에서 이 부분의 바이트 위치를 알려줍니다. 서버에서 반환🎜🎜🎜🎜ETag 리소스 식별자 필요하지 않음 서버에서 반환🎜🎜🎜🎜Last-Modified 리소스가 마지막으로 업데이트된 시간 반드시 서버는 🎜🎜🎜🎜Range🎜

🎜🎜의 범위 형식을 반환합니다. 0-499를 나타냅니다. 범위: bytes=0-499🎜🎜🎜🎜는 마지막 500바이트 범위를 나타냅니다. 범위: bytes=-500🎜🎜🎜🎜은 500바이트의 처음부터 끝까지의 범위를 나타냅니다. 범위: 바이트=500 -🎜🎜 🎜🎜은 첫 번째 및 마지막 바이트를 의미합니다. Range: bytes=0-0,-1🎜🎜🎜🎜는 동시에 여러 범위를 지정하는 것을 의미합니다. Range: bytes=500-600,601-999🎜🎜🎜🎜Content-Range의 데이터 형식🎜🎜Content-Range: 바이트 0-499/22036: 0-499바이트 범위의 총 22036바이트의 데이터 리소스가 반환됨을 나타냅니다🎜🎜Principle🎜🎜🎜클라이언트는 시작 바이트 수 또는 종료 바이트 수를 지정하기 위해 Range를 설정하는 요청을 시작합니다. 설정할 필요가 없습니다. 🎜🎜🎜🎜서버는 클라이언트의 Range 헤더가 시작 바이트 번호와 끝 바이트 번호를 구문 분석하고 메시지 헤더 Accept-Ranges를 반환하여 중단점 재개를 지원하는지 확인합니다. code>Content-Range는 클라이언트에 작성된 스트림의 위치 정보를 기록한 후 해당 스트림을 클라이언트에 작성합니다. 🎜🎜🎜🎜서버는 ETag Last-Modified를 사용하여 리소스가 수정되었는지 여부를 표시할 수 있습니다. 몇 가지 확인 작업을 수행하고 확인에 실패하면 오류를 반환합니다. 이는 필요하지 않습니다. 🎜🎜🎜🎜Java 구현🎜

OutputStream os=null;
    InputStream inputStream =null;
    File zipFile=null;
    try{
        long zipStart=System.currentTimeMillis();
        zipFile=createFile();//动态根据业务创建文件
        if(logger.isInfoEnabled()){
            logger.info(String.format("压缩ZIP 花费时间 %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 {
                    // 暂时只处理这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("下载 花费时间 %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 Chrome을 다운로드할 때 다운로드 진행 상황을 확인하고, 다운로드를 일시 중지하고, 다운로드 작업을 재개할 수 있으며, Range를 설정하여 분할된 다운로드를 테스트할 수도 있습니다. 🎜🎜🎜🎜

위 내용은 중단점 이력서 다운로드 원칙의 Java 구현 공유 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!