SpringMVC流式傳輸媒體數(shù)據(jù)的方法

更新時(shí)間：2025年07月03日 08:59:27 作者：javadoge

Spring Boot利用ResourceHttpRequestHandler實(shí)現(xiàn)媒體流傳輸,支持分片加載避免全量下載,需自定義繼承該類,重寫getResource方法,并配置ResponseEntity及異常處理,推薦使用MinIO或視頻云點(diǎn)播優(yōu)化性能,本文給大家介紹SpringMVC流式傳輸媒體數(shù)據(jù)的方法,感興趣的朋友一起看看吧

目前已知Spring Boot傳輸視頻流的方法

讀取整個(gè)視頻文件，然后把文件流寫入HttpServletResponse的OutputStream。
（此方法可行，但是需要消耗較多的服務(wù)器資源，且客戶端需要下載整個(gè)視頻才能播放）
使用HTTP的Range實(shí)現(xiàn)分片加載，但是需要手動(dòng)實(shí)現(xiàn)，比較麻煩。
使用Spring自帶的ResourceHttpRequestHandler是最佳實(shí)踐。

思路

ResourceHttpRequestHandler是Spring Boot用于加載靜態(tài)資源的一個(gè)類，默認(rèn)用于從"classpath:/static"等目錄讀取靜態(tài)資源，以便前端訪問(wèn)。我們可以繼承它自定義一個(gè)實(shí)現(xiàn)。

使用方法

在項(xiàng)目的config包（推薦）繼承ResourceHttpRequestHandler并重寫getResource方法，使其返回所需要呈現(xiàn)給前端的資源（org.springframework.core.io.Resource）

package com.example.server.config;
import jakarta.servlet.http.HttpServletRequest;
import org.springframework.core.io.Resource;
import org.springframework.core.io.UrlResource;
import org.springframework.lang.NonNull;
import org.springframework.stereotype.Component;
import org.springframework.web.servlet.resource.ResourceHttpRequestHandler;
import java.net.MalformedURLException;
import java.nio.file.Path;
import java.util.List;
@Component
public class CustomResourceHttpRequestHandler extends ResourceHttpRequestHandler {
    private Resource resource;
    @Override
    protected Resource getResource(@NonNull HttpServletRequest request) {
        return this.resource;
    }
    public void setResource(Path filePath) throws MalformedURLException {
        this.resource = new UrlResource(filePath.toUri());
        setLocations(List.of(this.resource));
    }
}

控制層注入CustomResourceHttpRequestHandler，并向setResource方法傳入文件路徑（java.nio.file.Path），設(shè)置請(qǐng)求頭，最后讓customResourceHttpRequestHandler處理請(qǐng)求。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.nio.file.Path;
import java.nio.file.Paths;
@Controller
@RequestMapping("/files")
public class FileController {
    @Autowired
    private CustomResourceHttpRequestHandler resourceHttpRequestHandler;
    @GetMapping("/{filename}")
    public ResponseEntity<?> getFile(@PathVariable String filename, HttpServletRequest request, HttpServletResponse response) {
        try {
            // 解析文件路徑
            Path filePath = Paths.get("D:/StorageService").resolve(filename).normalize();
            // 檢查文件是否存在
            if (!filePath.toFile().exists()) {
                return new ResponseEntity<>(HttpStatus.NOT_FOUND);
            }
            // 設(shè)置資源路徑
            resourceHttpRequestHandler.setResource(filePath);
            // 設(shè)置響應(yīng)頭，inline 會(huì)在瀏覽器中顯示或播放文件
            response.setHeader(HttpHeaders.CONTENT_DISPOSITION, "inline; filename=\"" + filename + "\"");
            // 讓 CustomResourceHttpRequestHandler 處理請(qǐng)求
            resourceHttpRequestHandler.handleRequest(request, response);
            return new ResponseEntity<>(HttpStatus.OK);
        } catch (Exception e) {
            return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
        }
    }
}

注意點(diǎn)

控制層返回值需要ResponseEntity類型（org.springframework.http.ResponseEntity），且try-catch不能省略，否則可能會(huì)不斷拋出異常（AsyncRequestNotUsableException和IOException）但不影響正常使用。