Elgato_dark/sol-cloud
1
0
Fork 0
mirror of https://github.com/BgaSol/sol-cloud synced 2026-05-05 23:58:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat(file): Realize the online playback function of video files

Browse source
This commit is contained in:
sol 2025-09-10 17:16:07 +08:00
parent 5aa47b663b
commit 9c73eabc17
1 changed files with 41 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
cloud/web/web-file-8082/src/main/java/com/bgasol/web/file/file/controller/FileController.java
View file

@ -17,11 +17,15 @@ import jakarta.validation.Valid;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.core.io.InputStreamResource;
import org.springframework.core.io.Resource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import java.io.IOException;
import java.io.InputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
@ -103,13 +107,43 @@ public class FileController extends BaseController<
@GetMapping("/stream/{id}")
@Operation(summary = "在线播放文件", operationId = "streamFile")
@SaCheckPermission("file:stream")
public ResponseEntity<InputStreamResource> stream(@PathVariable("id") String id) {
public ResponseEntity<Resource> playVideo(
@PathVariable("id") String id,
@RequestHeader(value = "Range", required = false) String rangeHeader) throws IOException {
FileEntity file = fileService.findById(id);
return ResponseEntity.ok()
.contentType(MediaType.valueOf(file.getType())) // video/mp4
.header(HttpHeaders.CONTENT_LENGTH, String.valueOf(file.getSize()))
.body(new InputStreamResource(
ossService.readFileStream(file.getBucket(), file.getId(), file.getName())
));
if (file == null) {
return ResponseEntity.notFound().build();
}
// 视频总大小
long fileSize = file.getSize();
String contentType = file.getType(); // e.g. "video/mp4"
// 默认从头到尾
long rangeStart = 0;
long rangeEnd = fileSize - 1;
if (rangeHeader != null && rangeHeader.startsWith("bytes=")) {
String[] ranges = rangeHeader.substring(6).split("-");
rangeStart = Long.parseLong(ranges[0]);
if (ranges.length > 1 && !ranges[1].isEmpty()) {
rangeEnd = Long.parseLong(ranges[1]);
}
}
long contentLength = rangeEnd - rangeStart + 1;
InputStream inputStream = ossService.readFileStream(file.getBucket(), file.getId(), file.getName());
inputStream.skip(rangeStart); // 跳到起始位置
InputStreamResource resource = new InputStreamResource(inputStream);
return ResponseEntity.status(rangeHeader == null ? HttpStatus.OK : HttpStatus.PARTIAL_CONTENT)
.header(HttpHeaders.CONTENT_TYPE, contentType)
.header(HttpHeaders.ACCEPT_RANGES, "bytes")
.header(HttpHeaders.CONTENT_LENGTH, String.valueOf(contentLength))
.header(HttpHeaders.CONTENT_RANGE, "bytes " + rangeStart + "-" + rangeEnd + "/" + fileSize)
.body(resource);
}
}