问答 / 0 / 2 / 创建于 3年前 / 更新于 3年前
1、使用双向io.Copy进行tcp代理。
2、使用httputil.NewSingleHostReverseProxy进行http代理,http代理可以不分协议版本,如果一定要h2,可以关闭server h1和设置h2dail转发。
能不能参考一下这个正向代理:
package main import ( "fmt" "io" "net" "net/http" "strings" ) type Pxy struct { } func main() { fmt.Println("Serve on:8180") http.Handle("/", &Pxy{}) http.ListenAndServe("0.0.0.0:8180", nil) } func (p *Pxy) ServeHTTP(rw http.ResponseWriter, req *http.Request) { fmt.Printf("Received requrest: %s, %s, %s, \n", req.Method, req.Host, req.RemoteAddr) transport := http.DefaultTransport //浅拷贝对象 outReq := new(http.Request) *outReq = *req if clientIP, _, err := net.SplitHostPort(req.RemoteAddr); err == nil { if prior, ok := outReq.Header["X-Forwarded-For"]; ok { clientIP = strings.Join(prior, ", ") + ", " + clientIP } outReq.Header.Set("X-Forwarded-For", clientIP) } //请求下游 res, err := transport.RoundTrip(outReq) if err != nil { rw.WriteHeader(http.StatusBadGateway) return } //把下游内容返回给上游 //将头部返回 for key, value := range res.Header { for _, v := range value { rw.Header().Add(key, v) } } rw.WriteHeader(res.StatusCode) //将内容返回 io.Copy(rw, res.Body) res.Body.Close() }
我要举报该,理由是:
1、使用双向io.Copy进行tcp代理。
2、使用httputil.NewSingleHostReverseProxy进行http代理,http代理可以不分协议版本,如果一定要h2,可以关闭server h1和设置h2dail转发。
能不能参考一下这个正向代理: