feat(media): support cloud codec via ffmpeg

Author: PIKACHUIM

internal/transcode/local_runner.go

@@ -295,8 +295,11 @@ func (r *LocalRunner) runJobLegacy(ctx context.Context, job *Job, profile Profil
 }
 
 // watchSegments 周期性扫描输出目录，把新切片登记到 Cache
+// 【内存优化】把扫描频率从 500ms 降到 2s，减少每次 os.ReadDir 和 parseFFmpegPlaylistDurations
+// 触发的字符串/字节切片分配。chunk 模式下每个 chunk 完成时还会主动调用 publishChunkSegments，
+// 所以这里只需要兜底登记中间切片，2s 频率完全够用。
 func (r *LocalRunner) watchSegments(job *Job, profile Profile, dir string, stop chan struct{}) {
-	t := time.NewTicker(500 * time.Millisecond)
+	t := time.NewTicker(2 * time.Second)
 	defer t.Stop()
 	for {
 		select {
@@ -439,9 +442,35 @@ func (r *LocalRunner) publishChunkSegments(job *Job, profile Profile, dir string
 	}
 }
 
+// playlistDurCache 缓存 m3u8 解析结果，按文件 mtime+size 失效。
+// 【内存优化】scanAndPublish 每 2 秒一次，每次都会解析同一个 m3u8（长视频几百 KB），
+// strings.Split 会产生大量临时字符串切片造成 GC 压力。用缓存减少 99% 的重复解析。
+type playlistDurCacheEntry struct {
+	mtime time.Time
+	size  int64
+	durs  map[int]float64
+}
+
+var (
+	playlistDurCache   = make(map[string]*playlistDurCacheEntry)
+	playlistDurCacheMu sync.Mutex
+)
+
 // parseFFmpegPlaylistDurations 解析 ffmpeg 写出的 m3u8，返回 seq -> duration 的映射
 // 用于获取每个切片的真实时长，避免后端用硬编码 segDur 导致总时长显示偏差
 func parseFFmpegPlaylistDurations(path string) map[int]float64 {
+	fi, err := os.Stat(path)
+	if err != nil {
+		return map[int]float64{}
+	}
+	// 命中缓存：mtime + size 都没变就直接复用
+	playlistDurCacheMu.Lock()
+	if e, ok := playlistDurCache[path]; ok && e.mtime.Equal(fi.ModTime()) && e.size == fi.Size() {
+		playlistDurCacheMu.Unlock()
+		return e.durs
+	}
+	playlistDurCacheMu.Unlock()
+
 	out := make(map[int]float64)
 	data, err := os.ReadFile(path)
 	if err != nil {
@@ -469,6 +498,14 @@ func parseFFmpegPlaylistDurations(path string) map[int]float64 {
 			pendingDur = 0
 		}
 	}
+	// 写入缓存
+	playlistDurCacheMu.Lock()
+	playlistDurCache[path] = &playlistDurCacheEntry{
+		mtime: fi.ModTime(),
+		size:  fi.Size(),
+		durs:  out,
+	}
+	playlistDurCacheMu.Unlock()
 	return out
 }
 

server/handles/transcode.go

@@ -5,12 +5,15 @@ import (
 	"net/http"
 	"net/url"
 	"os"
+	"path/filepath"
 	"strconv"
 	"strings"
 	"time"
 
 	"github.com/OpenListTeam/OpenList/v4/internal/conf"
+	"github.com/OpenListTeam/OpenList/v4/internal/driver"
 	"github.com/OpenListTeam/OpenList/v4/internal/fs"
+	"github.com/OpenListTeam/OpenList/v4/internal/op"
 	"github.com/OpenListTeam/OpenList/v4/internal/setting"
 	"github.com/OpenListTeam/OpenList/v4/internal/sign"
 	"github.com/OpenListTeam/OpenList/v4/internal/transcode"
@@ -65,10 +68,21 @@ func TranscodePlay(c *gin.Context) {
 	mgr := transcode.Default()
 	mgr.Start()
 
-	// 构造源签名 URL（让 Worker 通过 /d/ 直接下载）
+	// 【内存优化】优先尝试解析为本地文件路径，让 ffmpeg 直接读取本地文件，
+	// 完全绕过 HTTP /d 代理路径——避免 net.Downloader 给每个 range 请求分配
+	// 高达 MaxBufferLimit (默认系统内存 5%) 的大缓冲。这是降低 Go 进程内存
+	// 占用最有效的方法。如果不是本地驱动则退回到 HTTP 签名 URL。
 	apiURL := common.GetApiUrlFromRequest(c.Request)
-	signedPath := sign.Sign(req.Path)
-	sourceURL := fmt.Sprintf("%s/d%s?sign=%s", apiURL, encodePath(req.Path), signedPath)
+	var sourceURL string
+	if localFile, ok := resolveLocalFilePath(req.Path); ok {
+		// ffmpeg 接受本地路径作为输入，无需 file:// 前缀
+		sourceURL = localFile
+		fmt.Printf("[transcode] using local file path for ffmpeg: %s\n", localFile)
+	} else {
+		// 远程驱动：构造签名 HTTP URL
+		signedPath := sign.Sign(req.Path)
+		sourceURL = fmt.Sprintf("%s/d%s?sign=%s", apiURL, encodePath(req.Path), signedPath)
+	}
 
 	// 创建 Job
 	job := transcode.NewJob()
@@ -110,6 +124,37 @@ func encodePath(p string) string {
 	return strings.Join(parts, "/")
 }
 
+// resolveLocalFilePath 尝试把 OpenList 路径解析为宿主机文件系统的实际路径。
+// 仅对本地驱动 (Local) 有效，其他驱动（云盘等）返回 false。
+//
+// 这是内存优化的关键路径：本地文件场景下让 ffmpeg 直接读文件，可以完全绕过
+// HTTP /d 代理路径上的 net.Downloader 大块缓冲（默认每个 range 请求最高
+// 占用 MaxBufferLimit = 系统内存 5%，多 chunk 并发 + 多 range 累计可达数 GB）。
+func resolveLocalFilePath(rawPath string) (string, bool) {
+	storage, actualPath, err := op.GetStorageAndActualPath(rawPath)
+	if err != nil || storage == nil {
+		return "", false
+	}
+	if storage.Config().Name != "Local" {
+		return "", false
+	}
+	rooter, ok := storage.(driver.IRootPath)
+	if !ok {
+		return "", false
+	}
+	root := rooter.GetRootPath()
+	if root == "" {
+		return "", false
+	}
+	full := filepath.Join(root, actualPath)
+	// 只接受真实存在的文件，避免传给 ffmpeg 一个无效路径
+	fi, err := os.Stat(full)
+	if err != nil || fi.IsDir() {
+		return "", false
+	}
+	return full, true
+}
+
 // ============================================================
 // 播放端：/tc/:job/:token/...  Master/Variant playlist & 切片
 // ============================================================