如何让应用A不缓存文件到内存，将文件流Pipe至应用B的POST请求？

你的核心思路是对的：通过直接传递IO流实现零内存拷贝的文件转发，但代码里遗漏了几个关键细节，导致应用B无法正确接收内容。

关键问题点 #

• 未校验GET请求有效性：如果GET请求失败（比如返回404、500），response.Body可能是空或错误流，此时POST过去的自然不是有效文件内容。
• 未传递必要HTTP头：应用B可能依赖Content-Length确定读取字节数，或依赖Content-Type识别文件类型，直接传递Body时这些头不会自动复制。
• 资源泄漏风险：未在错误路径下关闭response.Body，可能导致连接池资源耗尽。

修正后的代码 #

import (
    "context"
    "fmt"
    "net/http"
)

func forwardFile(ctx context.Context, httpClient *http.Client, fileURL, appBURL string) error {
    // 发起GET请求获取文件流
    getReq, err := http.NewRequestWithContext(ctx, http.MethodGet, fileURL, nil)
    if err != nil {
        return fmt.Errorf("create get request failed: %w", err)
    }

    getResp, err := httpClient.Do(getReq)
    if err != nil {
        return fmt.Errorf("send get request failed: %w", err)
    }
    // 确保错误路径下关闭Body
    defer func() {
        if getResp.Body != nil {
            getResp.Body.Close()
        }
    }()

    // 校验GET响应状态
    if getResp.StatusCode != http.StatusOK {
        return fmt.Errorf("fetch file failed, status: %s", getResp.Status)
    }

    // 构建POST请求，直接复用GET响应体
    postReq, err := http.NewRequestWithContext(ctx, http.MethodPost, appBURL, getResp.Body)
    if err != nil {
        return fmt.Errorf("create post request failed: %w", err)
    }

    // 复制关键头信息，帮助应用B正确解析内容
    postReq.ContentLength = getResp.ContentLength
    postReq.Header.Set("Content-Type", getResp.Header.Get("Content-Type"))

    // 发送POST请求
    postResp, err := httpClient.Do(postReq)
    if err != nil {
        return fmt.Errorf("send post request failed: %w", err)
    }
    defer postResp.Body.Close()

    // 按需处理应用B的响应（比如校验状态码）
    if postResp.StatusCode < 200 || postResp.StatusCode >= 300 {
        return fmt.Errorf("appB returned error status: %s", postResp.Status)
    }

    return nil
}

补充说明 #

• 分块编码兼容：如果源存储服务返回分块编码（无Content-Length头），Go的http.Client会自动以分块方式发送POST请求，只要应用B支持分块读取（能正确处理Transfer-Encoding: chunked头），就能正常接收内容。
• Body生命周期：将getResp.Body传给POST请求后，httpClient.Do(postReq)会在请求完成后自动关闭该Body，所以无需额外手动关闭（但错误路径下的defer仍需保留）。

内容的提问来源于stack exchange，提问作者Tarta