制作http.正确的ReverseProxy Foward响应流

Question

我的主web服务器中有反向代理，专门用于某个微服务，并将请求转发到相应的微服务。

func newTrimPrefixReverseProxy(target *url.URL, prefix string) *httputil.ReverseProxy {
    director := func(req *http.Request) {
        // ... trims prefix from request path and prepends the path of the target url
    }

    return &httputil.ReverseProxy{Director: director}
}

这对于纯JSON响应非常有效，但我最近在尝试通过反向代理提供内容（流响应）时遇到了问题。服务内容的方式是不相关的，当直接访问服务而不是通过反向代理访问服务时，（视频）内容按预期服务。

服务内容：

http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    http.ServeContent(w, r, "video.mp4", time.Now().Add(time.Hour*24*365*12*9*-1), videoReadSeeker)
})

同样，videoReadSeeker和内容的服务方式不是问题，问题是通过反向代理将我的响应按预期转发给请求者；当直接访问该服务时，视频就会显示出来，我可以尽情地将其删除。

请注意，内容的数据响应已被接收（http状态、标头），但响应正文中的内容流未被接收。

如何确保反向代理按照内容的意图处理流响应？

Answer 1

使用以下方法时，您是否会得到相同的结果：

package main

import (
    "log"
    "net/http"
    "net/http/httputil"
    "net/url"
)

func main() {
    u, err := url.Parse("http://localhost:8080/asdfasdf")
    if err != nil {
        log.Fatal("url.Parse: %v", err)
    }

    proxy := httputil.NewSingleHostReverseProxy(u)

    log.Printf("Listening at :8081")
    if err := http.ListenAndServe(":8081", proxy); err != nil {
        log.Fatal("ListenAndServe: %v", err)
    }
}

最终，这些都是相同的引擎盖下的实现，但是这里提供的控制器确保存在一些预期的头文件，您将需要这些头文件来实现一些代理功能。