Supports specifying a file name during video recording, facilitating third-party access to the API for retrieving the recorded file name.

example/default/config.yaml

@@ -1,11 +1,25 @@
 global:
+  http:
+    listenaddr: :8080
   location:
     "^/hdl/(.*)": "/flv/$1" # 兼容 v4
     "^/stress/api/(.*)": "/test/api/stress/$1" # 5.0.x
     "^/monitor/(.*)": "/debug/$1" # 5.0.x
-  loglevel: debug
+  loglevel: info
   admin:
     enablelogin: false
+  # S3存储配置示例（需要时取消注释并填写实际值）
+  # storage:
+  #   s3:
+  #     endpoint: "s3.amazonaws.com"          # S3服务端点
+  #     region: "us-east-1"                   # AWS区域
+  #     accessKeyID: "your-access-key-id"     # 访问密钥ID
+  #     secretAccessKey: "your-secret-access-key" # 秘密访问密钥
+  #     bucket: "your-bucket-name"            # 存储桶名称
+  #     pathPrefix: "monibuca/recordings"     # 文件路径前缀
+  #     forcePathStyle: false                 # 强制路径样式（MinIO需要设为true）
+  #     useSSL: true                          # 是否使用SSL
+  #     timeout: "30s"                        # 上传超时时间
   # pullproxy:
   #   - id: 1                        # 唯一ID标识，必须大于0
   #     name: "camera-1"             # 拉流代理名称
@@ -57,23 +71,23 @@ gb28181:
         - platformservergbid: "34020000002000000002" #上级平台GBID
           channeldbid: "34020000001110000003_34020000001320000005" #通道DBID,格式为设备ID_通道ID
 mp4:
-  # enable: false
+  enable: true
   # publish:
   #   delayclosetimeout: 3s
   # onpub:
   #   record:
-  #     ^live/.+:
-  #         fragment: 10s
-  #         filepath: record/$0
-  #         storage:
-  #           s3:
-  #             endpoint: "storage-dev.xiding.tech"
-  #             accessKeyId: "xidinguser"
-  #             secretAccessKey: "U2FsdGVkX1/7uyvj0trCzSNFsfDZ66dMSAEZjNlvW1c="
-  #             bucket: "vidu-media-bucket"
-  #             pathPrefix: ""
-  #             forcePathStyle: true
-  #             useSSL: true
+  #     ^live/(.+)$:
+  #       filepath: s3rec/$0
+  #       filename: $0.mp4
+  #       storage:
+  #         s3:
+  #           endpoint: "storage-dev.xiding.tech"
+  #           accessKeyId: "xidinguser"
+  #           secretAccessKey: "U2FsdGVkX1/7uyvj0trCzSNFsfDZ66dMSAEZjNlvW1c="
+  #           bucket: "vidu-media-bucket"
+  #           pathPrefix: "recordings"
+  #           forcePathStyle: true
+  #           useSSL: true
   # pull:
   #   live/test: /Users/dexter/Movies/1744963190.mp4
   onsub:
@@ -90,8 +104,16 @@ flv:
   # onpub:
   #   record:
   #     ^live/.+:
-  #         fragment: 1m
   #         filepath: record/$0
+  #         storage:
+  #           s3:
+  #             endpoint: "s3.amazonaws.com"
+  #             accessKeyId: "your-access-key-id"
+  #             secretAccessKey: "your-secret-access-key"
+  #             bucket: "your-bucket-name"
+  #             pathPrefix: "flv-recordings"
+  #             forcePathStyle: false
+  #             useSSL: true
   publish:
     delayclosetimeout: 3s
   onsub:

pkg/config/types.go

@@ -123,8 +123,9 @@ type (
 	}
 	Record struct {
 		Mode              RecordMode     `json:"mode" desc:"事件类型,auto=连续录像模式，event=事件录像模式" gorm:"type:varchar(255);comment:事件类型,auto=连续录像模式，event=事件录像模式;default:'auto'"`
-		Type              string         `desc:"录制类型"`                         // 录制类型 mp4、flv、hls、hlsv7
-		FilePath          string         `desc:"录制文件路径"`                       // 录制文件路径
+		Type              string         `desc:"录制类型"`   // 录制类型 mp4、flv、hls、hlsv7
+		FilePath          string         `desc:"录制文件路径"` // 录制文件路径
+		FileName          string         `json:"fileName" desc:"录制文件名" gorm:"-"`
 		Fragment          time.Duration  `desc:"分片时长"`                         // 分片时长
 		RealTime          bool           `desc:"是否实时录制"`                       // 是否实时录制
 		Append            bool           `desc:"是否追加录制"`                       // 是否追加录制

plugin/flv/pkg/record.go

@@ -6,6 +6,7 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	"strings"
 	"time"
 
 	task "github.com/langhuihui/gotask"
@@ -148,6 +149,12 @@ type Recorder struct {
 }
 
 var CustomFileName = func(job *m7s.RecordJob) string {
+	if fn := job.RecConf.FileName; fn != "" {
+		if !strings.HasSuffix(strings.ToLower(fn), ".flv") {
+			fn = fn + ".flv"
+		}
+		return filepath.Join(job.RecConf.FilePath, fn)
+	}
 	if job.RecConf.Fragment == 0 || job.RecConf.Append {
 		return fmt.Sprintf("%s.flv", job.RecConf.FilePath)
 	}
@@ -160,6 +167,7 @@ func (r *Recorder) createStream(start time.Time) (err error) {
 	if err != nil {
 		return
 	}
+	r.Debug("flv create file", "filePath", r.Event.FilePath)
 
 	// 获取存储实例
 	st := r.RecordJob.GetStorage()

plugin/hls/pkg/record.go

@@ -1,10 +1,11 @@
 package hls
 
 import (
-	"context"
-	"fmt"
-	"path/filepath"
-	"time"
+    "context"
+    "fmt"
+    "strings"
+    "path/filepath"
+    "time"
 
 	"m7s.live/v5"
 	"m7s.live/v5/pkg/codec"
@@ -28,15 +29,26 @@ type Recorder struct {
 }
 
 var CustomFileName = func(job *m7s.RecordJob) string {
-	if job.RecConf.Fragment == 0 || job.RecConf.Append {
-		return fmt.Sprintf("%s/%s.ts", job.RecConf.FilePath, time.Now().Format("20060102150405"))
-	}
-	return filepath.Join(job.RecConf.FilePath, time.Now().Format("20060102150405")+".ts")
+    if fn := job.RecConf.FileName; fn != "" {
+        if !strings.HasSuffix(strings.ToLower(fn), ".ts") {
+            fn = fn + ".ts"
+        }
+        return filepath.Join(job.RecConf.FilePath, fn)
+    }
+    if job.RecConf.Fragment == 0 || job.RecConf.Append {
+        return fmt.Sprintf("%s/%s.ts", job.RecConf.FilePath, time.Now().Format("20060102150405"))
+    }
+    return filepath.Join(job.RecConf.FilePath, time.Now().Format("20060102150405")+".ts")
 }
 
 func (r *Recorder) createStream(start time.Time) (err error) {
-	r.RecordJob.RecConf.Type = "ts"
-	return r.CreateStream(start, CustomFileName)
+    r.RecordJob.RecConf.Type = "ts"
+    err = r.CreateStream(start, CustomFileName)
+    if err != nil {
+        return err
+    }
+    r.Debug("ts create file", "filePath", r.Event.FilePath)
+    return nil
 }
 
 func (r *Recorder) writeTailer(end time.Time) {

plugin/mp4/api.go

@@ -386,7 +386,6 @@ func (p *MP4Plugin) download(w http.ResponseWriter, r *http.Request) {
 		if err != nil {
 			return
 		}
-		p.Info("read", "file", file.Name())
 
 		// 创建解复用器并解析文件
 		demuxer := mp4.NewDemuxer(file)
@@ -558,16 +557,22 @@ func (p *MP4Plugin) download(w http.ResponseWriter, r *http.Request) {
 func (p *MP4Plugin) StartRecord(ctx context.Context, req *mp4pb.ReqStartRecord) (res *mp4pb.ResponseStartRecord, err error) {
 	var recordExists bool
 	var filePath = "."
+	var fileName = ""
 	var fragment = time.Minute
 	if req.Fragment != nil {
 		fragment = req.Fragment.AsDuration()
 	}
 	if req.FilePath != "" {
 		filePath = req.FilePath
 	}
+	if req.FileName != "" {
+		fileName = req.FileName
+	}
+
+	p.Debug("mp4 plugin start record", "streamPath", req.StreamPath, "filePath", filePath, "fileName", fileName, "fragment", fragment)
 	res = &mp4pb.ResponseStartRecord{}
 	_, recordExists = p.Server.Records.Find(func(job *m7s.RecordJob) bool {
-		return job.StreamPath == req.StreamPath && job.RecConf.FilePath == req.FilePath
+		return job.StreamPath == req.StreamPath && job.RecConf.FilePath == req.FilePath && job.RecConf.FileName == req.FileName
 	})
 	if recordExists {
 		err = pkg.ErrRecordExists
@@ -578,7 +583,9 @@ func (p *MP4Plugin) StartRecord(ctx context.Context, req *mp4pb.ReqStartRecord)
 		Append:   false,
 		Fragment: fragment,
 		FilePath: filePath,
+		FileName: fileName,
 	}
+
 	var stream *m7s.Publisher
 	var ok bool
 	if stream, ok = p.Server.Streams.SafeGet(req.StreamPath); !ok {
@@ -595,6 +602,7 @@ func (p *MP4Plugin) StartRecord(ctx context.Context, req *mp4pb.ReqStartRecord)
 		}
 	}
 	job := p.Record(stream, recordConf, nil)
+	p.Debug("mp4 record job", "taskPtr", uint64(job.GetTaskPointer()))
 	res.Data = uint64(job.GetTaskPointer())
 	err = job.WaitStarted()
 	return

plugin/mp4/pb/mp4.proto

@@ -106,6 +106,7 @@ message ReqStartRecord {
   string streamPath = 1;
   google.protobuf.Duration fragment = 2;
   string filePath = 3;
+  string fileName = 4;
 }
 
 message ResponseStartRecord {
@@ -171,4 +172,4 @@ message ResponseTagList {
   string message = 2;
   repeated TagInfo list = 3;
   uint32 total = 4;
-}
+}