Merge pull request #119 from QiaoKes/develop

1.  [fix] 修复部分网盘STRM播放失败的问题

Author: QiaoKes

README.md

@@ -14,9 +14,9 @@
 
 - **原生桌面体验** - 基于飞牛影视Web端构建的桌面应用，提供类原生体验
 - **多账户管理** - 支持自动登录，支持多账户管理，自由切换账户和服务器
-- **硬解播放** - 支持H264 / HEVC / VP9 / AV1，具体支持查看下面感谢项目
-- **直链播放** - 适配官方直链播放，默认使用直链，可以在托盘处调整为nas代理模式
-- **进度回传** - mpv播放器支持实时将进度回传到飞牛服务器
+- **硬解播放** - 使用MPV播放器，支持H264 / HEVC / VP9 / AV1等编码格式
+- **直链播放** - 适配官方直链 / STRM播放，默认使用302重定向，可以在托盘处调整为nas代理模式
+- **进度回传** - MPV播放器支持实时将进度回传到飞牛服务器
 - **弹幕支持** - MPV播放器支持弹幕自动匹配加载，无法匹配时支持手动搜索
 - **视频增强** - 内置anime4K着色器以及对应预设模式
 - **智能跳过** - 可在MPV播放器界面设置。支持三种跳过片头片尾模式：章节检查，手动设置片头片尾，快捷键跳过固定时长
@@ -34,72 +34,72 @@
 
 感谢这些来自爱发电的赞助者：
 
-<!-- AFDIAN-ACTION:START -->
-
-<a href="https://afdian.com/u/bf093216d1da11f085b852540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-blue.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_7kDX" title="爱发电用户_7kDX"/>
-</a>
-<a href="https://afdian.com/u/5251e4e2d1c611f0b83d52540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_5251e" title="爱发电用户_5251e"/>
-</a>
-<a href="https://afdian.com/u/ec6015fcd0ca11ef8f8e52540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_ec601" title="爱发电用户_ec601"/>
-</a>
-<a href="https://afdian.com/u/713bc866afc811f093a952540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_7WxX" title="爱发电用户_7WxX"/>
-</a>
-<a href="https://afdian.com/u/f9548ae809f311ef805e52540025c377">
-    <img src="https://pic1.afdiancdn.com/user/f9548ae809f311ef805e52540025c377/avatar/b585c02959db06c4ea614f6e94fba294_w279_h252_s65.jpg.gif?imageView2/1/w/120/h/120" width="40" height="40" alt="1" title="1"/>
-</a>
-<a href="https://afdian.com/u/4514cc8c9a8411f0992b52540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_4514c" title="爱发电用户_4514c"/>
-</a>
-<a href="https://afdian.com/u/2685303096b611f0b4a652540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="嬴游仙人莫迪" title="嬴游仙人莫迪"/>
-</a>
-<a href="https://afdian.com/u/8a03268e8ba411f0bcbb52540025c377">
-    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-orange.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_e6g3" title="爱发电用户_e6g3"/>
-</a>
-
-<details>
-  <summary>点我 打开/关闭 赞助者列表</summary>
-
-<a href="https://afdian.com/u/bf093216d1da11f085b852540025c377">
-爱发电用户_7kDX
-</a>
-<span>( 1 次赞助, 共 ￥10 ) 留言: </span><br>
-<a href="https://afdian.com/u/5251e4e2d1c611f0b83d52540025c377">
-爱发电用户_5251e
-</a>
-<span>( 1 次赞助, 共 ￥20 ) 留言: </span><br>
-<a href="https://afdian.com/u/ec6015fcd0ca11ef8f8e52540025c377">
-爱发电用户_ec601
-</a>
-<span>( 1 次赞助, 共 ￥10 ) 留言: 不错不错</span><br>
-<a href="https://afdian.com/u/713bc866afc811f093a952540025c377">
-爱发电用户_7WxX
-</a>
-<span>( 1 次赞助, 共 ￥10 ) 留言: 加油，支持一杯蜜雪</span><br>
-<a href="https://afdian.com/u/f9548ae809f311ef805e52540025c377">
-1
-</a>
-<span>( 1 次赞助, 共 ￥10 ) 留言: fntv</span><br>
-<a href="https://afdian.com/u/4514cc8c9a8411f0992b52540025c377">
-爱发电用户_4514c
-</a>
-<span>( 1 次赞助, 共 ￥10 ) 留言: </span><br>
-<a href="https://afdian.com/u/2685303096b611f0b4a652540025c377">
-嬴游仙人莫迪
-</a>
-<span>( 1 次赞助, 共 ￥60 ) 留言: 谢谢，我是真的很喜欢...</span><br>
-<a href="https://afdian.com/u/8a03268e8ba411f0bcbb52540025c377">
-爱发电用户_e6g3
-</a>
-<span>( 1 次赞助, 共 ￥20 ) 留言: 给几个建议我是mac...</span><br>
-
-</details>
-<!-- 注意: 尽量将标签前靠,否则经测试可能被 GitHub 解析为代码块 -->
-
+<!-- AFDIAN-ACTION:START -->
+
+<a href="https://afdian.com/u/bf093216d1da11f085b852540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-blue.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_7kDX" title="爱发电用户_7kDX"/>
+</a>
+<a href="https://afdian.com/u/5251e4e2d1c611f0b83d52540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_5251e" title="爱发电用户_5251e"/>
+</a>
+<a href="https://afdian.com/u/ec6015fcd0ca11ef8f8e52540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_ec601" title="爱发电用户_ec601"/>
+</a>
+<a href="https://afdian.com/u/713bc866afc811f093a952540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_7WxX" title="爱发电用户_7WxX"/>
+</a>
+<a href="https://afdian.com/u/f9548ae809f311ef805e52540025c377">
+    <img src="https://pic1.afdiancdn.com/user/f9548ae809f311ef805e52540025c377/avatar/b585c02959db06c4ea614f6e94fba294_w279_h252_s65.jpg.gif?imageView2/1/w/120/h/120" width="40" height="40" alt="1" title="1"/>
+</a>
+<a href="https://afdian.com/u/4514cc8c9a8411f0992b52540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_4514c" title="爱发电用户_4514c"/>
+</a>
+<a href="https://afdian.com/u/2685303096b611f0b4a652540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-purple.png?imageView2/1/?imageView2/1/w/120/h/120" width="40" height="40" alt="嬴游仙人莫迪" title="嬴游仙人莫迪"/>
+</a>
+<a href="https://afdian.com/u/8a03268e8ba411f0bcbb52540025c377">
+    <img src="https://pic1.afdiancdn.com/default/avatar/avatar-orange.png?imageView2/1/w/120/h/120" width="40" height="40" alt="爱发电用户_e6g3" title="爱发电用户_e6g3"/>
+</a>
+
+<details>
+  <summary>点我 打开/关闭 赞助者列表</summary>
+
+<a href="https://afdian.com/u/bf093216d1da11f085b852540025c377">
+爱发电用户_7kDX
+</a>
+<span>( 1 次赞助, 共 ￥10 ) 留言: </span><br>
+<a href="https://afdian.com/u/5251e4e2d1c611f0b83d52540025c377">
+爱发电用户_5251e
+</a>
+<span>( 1 次赞助, 共 ￥20 ) 留言: </span><br>
+<a href="https://afdian.com/u/ec6015fcd0ca11ef8f8e52540025c377">
+爱发电用户_ec601
+</a>
+<span>( 1 次赞助, 共 ￥10 ) 留言: 不错不错</span><br>
+<a href="https://afdian.com/u/713bc866afc811f093a952540025c377">
+爱发电用户_7WxX
+</a>
+<span>( 1 次赞助, 共 ￥10 ) 留言: 加油，支持一杯蜜雪</span><br>
+<a href="https://afdian.com/u/f9548ae809f311ef805e52540025c377">
+1
+</a>
+<span>( 1 次赞助, 共 ￥10 ) 留言: fntv</span><br>
+<a href="https://afdian.com/u/4514cc8c9a8411f0992b52540025c377">
+爱发电用户_4514c
+</a>
+<span>( 1 次赞助, 共 ￥10 ) 留言: </span><br>
+<a href="https://afdian.com/u/2685303096b611f0b4a652540025c377">
+嬴游仙人莫迪
+</a>
+<span>( 1 次赞助, 共 ￥60 ) 留言: 谢谢，我是真的很喜欢...</span><br>
+<a href="https://afdian.com/u/8a03268e8ba411f0bcbb52540025c377">
+爱发电用户_e6g3
+</a>
+<span>( 1 次赞助, 共 ￥20 ) 留言: 给几个建议我是mac...</span><br>
+
+</details>
+<!-- 注意: 尽量将标签前靠,否则经测试可能被 GitHub 解析为代码块 -->
+
 <!-- AFDIAN-ACTION:END -->
 
 ## 📦 安装方法
@@ -161,11 +161,7 @@ npm run build:linux
 
 ## 常用问题Q&A
 
-### 1. 直接播放无法客户端硬解，还是在服务端解码？
-
-只有mpv播放能保证直链硬解，其余的虽然浏览器支持了硬解，但是飞牛网页端识别有问题，还是会走服务端转码，需要飞牛修复。
-
-### 2. mpv播放器功能有点少，怎么客制化，想添加补帧滤镜等？
+### 1. mpv播放器功能有点少，怎么客制化，想添加补帧滤镜等？
 
 1. 自动方法
    克隆fntv-mpv仓库，自己改一下相关配置：[fntv-mpv-config](https://github.com/QiaoKes/fntv-mpv-config)
@@ -174,35 +170,27 @@ npm run build:linux
 
 注意重新安装或者更新，会清空安装目录，注意备份你的mpv插件目录。
 
-### 3. 是否支持网盘挂载播放？
-
-支持，飞牛官方挂载的不支持302，需要官方支持。alist没有测试过，可以试一试。
+### 2. 能否支持potplayer？
 
-### 4. 能否支持potplayer？
+目前我这边没有使用potplayer的需求，如果需要的话可以自行修改源码适配一下，已留好interface，只需要适配。
 
-目前我这边没有使用potplayer的需求，如果需要的话可以自行修改源码适配一下。
-
-### 5. 是否支持飞牛connect登录？
+### 3. 是否支持飞牛connect登录？
 
 官方未开放相关API，无法支持。
 
-### 6. 域名账号密码正确但是无法登录？
-
-只支持正常dns解析的域名，和IP，其余的不支持。
-
-### 7. 弹幕相关问题？
+### 4. 弹幕相关问题？
 
 弹幕问题查看uosc_danmaku的文档，根据文档内容调整配置。
 
-### 8.登录完客户端后，如果服务器连接不上登录会超时卡透明屏，无法切换或修改服务器配置，卸载重装也不行
+### 5. 登录完客户端后，如果服务器连接不上登录会超时卡透明屏，无法切换或修改服务器配置，卸载重装也不行
 
 去C:\\Users\\{你的计算机用户名}\\.fntv 下面把config.json删除了，因为连接成功后实际上加载的还是飞牛网页端，没响应当然会透明了。
 
-### 9.打开弹幕视频掉帧
+### 6. 打开弹幕视频掉帧
 
 打开弹幕时，默认开启fps平滑滤镜，比较吃性能，不需要可以去安装目录下的third_party\fntv-mpv\portable_config\script-opts下uosc_danmaku.conf关闭相关配置
 
-### 10.双显卡，调用时发现使用核显
+### 7. 视频播放卡慢，双显卡，调用时发现使用核显
 
 以下两种方法任选其一：
 

package.json

@@ -1,6 +1,6 @@
 {
     "name": "fntv",
-    "version": "2.5.2",
+    "version": "2.5.3",
     "description": "A fntv app built with Electron",
     "main": "dest/main/main.js",
     "scripts": {

src/modules/proxy/pkg/utils/utils.go

@@ -1,15 +1,12 @@
 package utils
 
 import (
-	"bytes"
 	"crypto/sha1"
 	"crypto/tls"
 	"encoding/hex"
 	"encoding/json"
 	"io"
 	"net/http"
-	"net/http/httputil"
-	"net/url"
 	"time"
 
 	"proxy/pkg/logger"
@@ -74,94 +71,91 @@ func PassthroughHeaders(req *http.Request) map[string]string {
 	return headers
 }
 
-// DynamicProxy 执行透明代理
+// DynamicProxy 实现流式管道代理，支持自动跟随重定向
 func DynamicProxy(c *gin.Context, targetURL string, extraHeaders map[string]string, skipVerify bool) {
-	// 使用recover来捕获可能的panic
-	defer func() {
-		if err := recover(); err != nil {
-			// 检查是否是http.ErrAbortHandler错误
-			if err == http.ErrAbortHandler {
-				// logger.Debugf("客户端断开连接，忽略错误: %v", err)
-				return
-			}
-			// 其他panic重新抛出
-			panic(err)
-		}
-	}()
-
-	// 解析目标URL
-	target, err := url.Parse(targetURL)
+	// 1. 创建 HTTP 请求
+	// 注意：使用 c.Request.Context()，这样客户端断开连接时，下载也会自动停止
+	req, err := http.NewRequestWithContext(c.Request.Context(), c.Request.Method, targetURL, c.Request.Body)
 	if err != nil {
-		c.JSON(500, gin.H{"error": "Invalid target URL"})
+		c.JSON(500, gin.H{"error": "Failed to create request"})
 		return
 	}
 
-	// 创建反向代理
-	proxy := httputil.NewSingleHostReverseProxy(target)
-
-	// 设置超时时间
-	proxy.Transport = &http.Transport{
-		ResponseHeaderTimeout: 30 * time.Second,
-		TLSClientConfig: &tls.Config{
-			InsecureSkipVerify: skipVerify,
-		},
+	// 2. 复制客户端的 Header 到新请求
+	// 我们需要小心过滤掉一些 Hop-by-hop 的 Header
+	skipHeaders := map[string]bool{
+		"Host":                true, // Host 由 http.Client 根据 URL 自动设置
+		"Content-Length":      true, // 由 req.Body 自动处理
+		"Transfer-Encoding":   true,
+		"Connection":          true,
+		"Keep-Alive":          true,
+		"Proxy-Authenticate":  true,
+		"Proxy-Authorization": true,
+		"Te":                  true,
+		"Trailers":            true,
+		"Upgrade":             true,
 	}
 
-	// 修改请求前的处理
-	proxy.Director = func(req *http.Request) {
-		// 设置原始请求信息
-		req.URL.Scheme = target.Scheme
-		req.URL.Host = target.Host
-		req.URL.Path = target.Path
-		req.URL.RawQuery = target.RawQuery
-		req.Host = target.Host
-
-		// 复制原始请求的头部
-		for key, values := range c.Request.Header {
-			for _, value := range values {
-				req.Header.Set(key, value)
+	for k, v := range c.Request.Header {
+		if !skipHeaders[k] {
+			for _, vv := range v {
+				req.Header.Add(k, vv)
 			}
 		}
+	}
 
-		// 添加额外的头部信息
-		for key, value := range extraHeaders {
-			req.Header.Set(key, value)
-		}
-
-		logger.Infof("method:%s path:%s query:%s, header:%v", req.Method, req.URL.Path, req.URL.RawQuery, req.Header)
+	// 添加额外的 Header
+	for k, v := range extraHeaders {
+		req.Header.Set(k, v)
+	}
 
-		// 设置请求方法
-		req.Method = c.Request.Method
+	// 3. 配置 HTTP Client
+	client := &http.Client{
+		// 自动跟随重定向是 http.Client 的默认行为，无需额外配置
+		// 只要不设置 CheckRedirect，它就会自动处理 302 直到拿到 200
+		Timeout: 0, // 设置为 0，因为下载大文件或视频流需要长时间保持连接
+		Transport: &http.Transport{
+			TLSClientConfig:    &tls.Config{InsecureSkipVerify: skipVerify},
+			MaxIdleConns:       100,
+			IdleConnTimeout:    90 * time.Second,
+			DisableCompression: true, // 对于视频流，通常不需要压缩，且压缩可能导致流式传输问题
+		},
+	}
 
-		// 如果有请求体，复制它
-		if c.Request.Body != nil {
-			bodyBytes, err := io.ReadAll(c.Request.Body)
-			if err == nil {
-				req.Body = io.NopCloser(bytes.NewReader(bodyBytes))
-				req.ContentLength = int64(len(bodyBytes))
+	// 4. 发起请求 (这一步会自动处理 302 跳转)
+	resp, err := client.Do(req)
+	if err != nil {
+		logger.Errorf("代理请求失败: %v", err)
+		// 如果客户端已经断开，就不返回错误了
+		if c.Request.Context().Err() == nil {
+			c.Status(http.StatusBadGateway)
+		}
+		return
+	}
+	defer resp.Body.Close()
+
+	// 5. 将目标服务器的响应 Header 复制回给客户端
+	for k, v := range resp.Header {
+		// 同样过滤掉一些 Header
+		if !skipHeaders[k] {
+			for _, vv := range v {
+				c.Writer.Header().Add(k, vv)
 			}
 		}
 	}
 
-	// 修改响应后的处理
-	proxy.ModifyResponse = func(resp *http.Response) error {
-		// 打印相应头
-		logger.Infof("响应状态: %s, 头部: %v", resp.Status, resp.Header)
-		// 可以在这里修改响应头部或内容
-		return nil
-	}
+	// 设置状态码
+	c.Status(resp.StatusCode)
 
-	// 处理错误 - 修复：避免重复写入响应头
-	proxy.ErrorHandler = func(w http.ResponseWriter, req *http.Request, err error) {
-		// 检查响应是否已经开始写入
-		if c.Writer.Written() {
-			logger.Debugf("代理错误，但响应已开始写入: %v", err)
-			return
-		}
-		logger.Debugf("代理错误: %v", err)
-		c.JSON(500, gin.H{"error": "Proxy error", "details": err.Error()})
-	}
+	// 6. 关键步骤：建立数据管道
+	// 直接将上游的 Body 流式拷贝到 ResponseWriter
+	// 这样数据来多少发多少，不会占用服务器内存
+	buf := make([]byte, 32*1024) // 32KB 缓冲区
+	_, err = io.CopyBuffer(c.Writer, resp.Body, buf)
 
-	// 执行代理
-	proxy.ServeHTTP(c.Writer, c.Request)
+	if err != nil {
+		// 这里的错误通常是因为客户端（播放器）关闭了连接，或者是网络中断
+		// 不需要 panic，只需要记录日志即可
+		logger.Debugf("流式传输中断 (可能是客户端主动断开): %v", err)
+	}
 }