Java后端接口返回视频流，使用video组件播放视频，实现分段下载

2024-07-12 07:13| 来源: 网络整理| 查看: 265

视频文件保存在不为人知的地方，总之前端不能直接访问的位置，需要通过后端接口取出来再返回给前端。前端这样子播放

src=后端接口如果后端直接这样子写

//path为本地文件路劲 public void play(String path, HttpServletRequest request, HttpServletResponse response) { //获取视频文件流 FileInputStream fileInputStream = null; OutputStream outputStream = null; try { outputStream = response.getOutputStream(); fileInputStream = new FileInputStream(new File(path)); byte[] cache = new byte[1024]; response.setHeader(HttpHeaders.CONTENT_TYPE, "video/mp4"); response.setHeader(HttpHeaders.CONTENT_LENGTH, fileInputStream.available()+""); int flag; while ((flag = fileInputStream.read(cache)) != -1) { outputStream.write(cache, 0, flag); } outputStream.flush(); outputStream.close(); }catch (Exception e){ log.error("文件传输错误", e); throw new RuntimeException("文件传输错误"); } finally{ if(outputStream != null){ try { outputStream.close(); } catch (IOException e) { log.error("流释放错误", e); } } if(fileInputStream != null){ try { fileInputStream.close(); } catch (IOException e) { log.error("文件流释放错误", e); } } } }

小视频问题不大，视频大的话会卡顿很久，查看请求发现会先请求下载完整视频后开始播放。而且不能拖动进度条进行播放。追及原因是因为video会先发送一个探测请求获取视频的大小、长度等信息，之后才开始进行播放。不能拖动进度条播放是因为获取视频接口不支持断点传输所以只能依次观看。 http请求就有相关断点传输的协议，http协议状态码206就是实现断点传输的协议，Http请求头部需要指定获取数据的范围： Range: bytes=first-end，first，开始数据的索引位置，end，结束数据的索引位置。Http响应需要指定范围响应头：content-range bytes first-end，并且http状态码设置为206。所以实现视频断点播放的大概思路为，先识别http请求头是否携带range请求头，如果携带则表示请求需要进行断点下载，识别出断点的位置后使用随机读取文件类RandomAccessFile进行一定范围的读写，之后返回设置Content-Range请求头表示返回数据的范围，并设置http状态码为206表示断点传输。代码如下

//path为本地文件路劲 public void play(String path, HttpServletRequest request, HttpServletResponse response) { RandomAccessFile targetFile = null; OutputStream outputStream = null; try { outputStream = response.getOutputStream(); response.reset(); //获取请求头中Range的值 String rangeString = request.getHeader(HttpHeaders.RANGE); //打开文件 File file = new File(path); if (file.exists()) { //使用RandomAccessFile读取文件 targetFile = new RandomAccessFile(file, "r"); long fileLength = targetFile.length(); long requestSize = (int) fileLength; //分段下载视频 if (StringUtils.hasText(rangeString)) { //从Range中提取需要获取数据的开始和结束位置 long requestStart = 0, requestEnd = 0; String[] ranges = rangeString.split("="); if (ranges.length > 1) { String[] rangeDatas = ranges[1].split("-"); requestStart = Integer.parseInt(rangeDatas[0]); if (rangeDatas.length > 1) { requestEnd = Integer.parseInt(rangeDatas[1]); } } if (requestEnd != 0 && requestEnd > requestStart) { requestSize = requestEnd - requestStart + 1; } //根据协议设置请求头 response.setHeader(HttpHeaders.ACCEPT_RANGES, "bytes"); response.setHeader(HttpHeaders.CONTENT_TYPE, "video/mp4"); if (!StringUtils.hasText(rangeString)) { response.setHeader(HttpHeaders.CONTENT_LENGTH, fileLength + ""); } else { long length; if (requestEnd > 0) { length = requestEnd - requestStart + 1; response.setHeader(HttpHeaders.CONTENT_LENGTH, "" + length); response.setHeader(HttpHeaders.CONTENT_RANGE, "bytes " + requestStart + "-" + requestEnd + "/" + fileLength); } else { length = fileLength - requestStart; response.setHeader(HttpHeaders.CONTENT_LENGTH, "" + length); response.setHeader(HttpHeaders.CONTENT_RANGE, "bytes " + requestStart + "-" + (fileLength - 1) + "/" + fileLength); } } //断点传输下载视频返回206 response.setStatus(HttpServletResponse.SC_PARTIAL_CONTENT); //设置targetFile，从自定义位置开始读取数据 targetFile.seek(requestStart); } else { //如果Range为空则下载整个视频 response.setHeader(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=test.mp4"); //设置文件长度 response.setHeader(HttpHeaders.CONTENT_LENGTH, String.valueOf(fileLength)); } //从磁盘读取数据流返回 byte[] cache = new byte[4096]; try { while (requestSize > 0) { int len = targetFile.read(cache); if (requestSize outputStream.write(cache, 0, len); if (len // tomcat原话。写操作IO异常几乎总是由于客户端主动关闭连接导致，所以直接吃掉异常打日志 //比如使用video播放视频时经常会发送Range为0- 的范围只是为了获取视频大小，之后就中断连接了 log.info(e.getMessage()); } } else { throw new RuntimeException("文件路劲有误"); } outputStream.flush(); } catch (Exception e) { log.error("文件传输错误", e); throw new RuntimeException("文件传输错误"); }finally { if(outputStream != null){ try { outputStream.close(); } catch (IOException e) { log.error("流释放错误", e); } } if(targetFile != null){ try { targetFile.close(); } catch (IOException e) { log.error("文件流释放错误", e); } } } }

【本文地址】

公司简介

联系我们