用 vlc 替换 ffplay 的播放方式用来修复视频播放问题

pkg/video/paly.go

@@ -1,53 +0,0 @@
-package video
-
-import (
-	"bufio"
-	"context"
-	"go.uber.org/zap"
-	"io"
-	"os"
-	"os/exec"
-	"sync"
-)
-
-func Play(ctx context.Context, file string) error {
-	if file == "" {
-		zap.S().Infoln("video file is empty")
-		return nil
-	}
-	// 判断文件是否存在
-	if _, err := os.Stat(file); err != nil {
-		zap.S().Errorf("视频文件不存在: %v", err)
-		return err
-	}
-	cmd := exec.CommandContext(ctx, "ffplay", "-autoexit", "-fs", file)
-	pipe, err := cmd.StderrPipe()
-	if err != nil {
-		return err
-	}
-
-	var wait sync.WaitGroup
-	defer wait.Wait()
-
-	wait.Add(1)
-	go func() {
-		defer wait.Done()
-		reader := bufio.NewReader(pipe)
-		for {
-			select {
-			case <-ctx.Done():
-				return
-			default:
-				line, _, err := reader.ReadLine()
-				if err != nil {
-					if err == io.EOF {
-						return
-					}
-					break
-				}
-				zap.L().Info(string(line))
-			}
-		}
-	}()
-	return cmd.Run()
-}

pkg/video/play.go

@@ -0,0 +1,68 @@
+package video
+
+import (
+	"context"
+	"fmt"
+	libvlc "github.com/adrg/libvlc-go/v3"
+)
+
+func Play(ctx context.Context, file string) error {
+	// 1. 初始化 VLC
+	if err := libvlc.Init("--no-xlib"); err != nil {
+		return fmt.Errorf("VLC初始化失败: %w", err)
+	}
+	defer libvlc.Release()
+
+	// 2. 创建播放器
+	player, err := libvlc.NewPlayer()
+	if err != nil {
+		return fmt.Errorf("播放器创建失败: %w", err)
+	}
+	defer player.Stop()
+	defer player.Release()
+
+	// 3. 注册结束事件
+	eventManager, err := player.EventManager()
+	if err != nil {
+		return fmt.Errorf("事件管理器获取失败: %w", err)
+	}
+
+	done := make(chan struct{})
+	defer close(done)
+
+	_, err = eventManager.Attach(libvlc.MediaPlayerEndReached, func(libvlc.Event, interface{}) {
+		done <- struct{}{}
+	}, nil)
+	if err != nil {
+		return fmt.Errorf("事件绑定失败: %w", err)
+	}
+
+	// 4. 加载并播放文件
+	if _, err := player.LoadMediaFromPath(file); err != nil {
+		return fmt.Errorf("文件加载失败: %w", err)
+	}
+
+	if err := player.Play(); err != nil {
+		return fmt.Errorf("播放启动失败: %w", err)
+	}
+
+	// 设置全屏模式
+	if err := player.SetFullScreen(true); err != nil {
+		return fmt.Errorf("设置全屏模式失败: %w", err)
+	}
+
+	// 设置音量为最大
+	if err := player.SetVolume(100); err != nil {
+		return fmt.Errorf("设置音量失败: %w", err)
+	}
+
+	// 5. 等待事件
+	fmt.Printf("正在播放: %s\n", file)
+	select {
+	case <-ctx.Done():
+		return fmt.Errorf("播放被用户中断")
+	case <-done:
+		fmt.Println("播放正常结束")
+		return nil
+	}
+}