当前位置：首页 > 文章列表 > Golang > Go问答 > Golang 反向代理 | TCP 连接错误：拨打代理连接失败到 10.0.0.0:443

Golang 反向代理 | TCP 连接错误：拨打代理连接失败到 10.0.0.0:443

来源：stackoverflow 2024-02-14 19:24:24 0浏览收藏

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《Golang 反向代理 | TCP 连接错误：拨打代理连接失败到 10.0.0.0:443》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

问题内容

我正在执行一个简单的反向代理操作，虽然后台运行的服务器通常在 cloudflare 上运行，但当我进入反向代理后面时，我开始收到无数的“连接：连接被拒绝”错误。

我使用标准的go库，没有额外的性能提升优化。

这里没有我可以分享的示例代码，因为我做了一个非常简单的过程..

我正在处理的网站每天收到 4-500 万个请求，并且实时请求的数量令人难以置信。我对标准网站没有任何问题，但这种规模的网站让我很难受。有什么技巧可以推荐给我吗？

jun 19 03:44:33 ubuntu main[492935]: 2021/06/19 03:44:33 http: proxy error: dial tcp xx.xxx.x.xx:80: connect: connection refused
jun 19 03:44:33 ubuntu main[492935]: 2021/06/19 03:44:33 http: proxy error: dial tcp xx.xxx.x.xx:80: connect: connection refused
... repeated many many times ...

编辑帖子；评论后，我也想分享我的代码。

package main

import (
    "io/ioutil"
    "log"
    "net/http"
    "net/http/httputil"
    "net/url"
    "time"
)

type server struct {
    proxy *httputil.ReverseProxy
}

func handler(handler http.Handler) http.Handler {
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        s := &server{}
        ob := &resp{ResponseWriter: w}
        s.ServeHTTP(ob, r)
        log.Printf("%s %s \"%s %s %s\" %d %d \"%s\" \"%s\"", r.RemoteAddr, r.Host, r.Method, r.URL.Path, r.Proto, ob.status, ob.written, r.Referer(), r.UserAgent())
    })
}

type resp struct {
    http.ResponseWriter
    status      int
    written     uint64
    wroteHeader bool
}

func (o *resp) Write(p []byte) (bytes int, err error) {
    if !o.wroteHeader {
        o.WriteHeader(http.StatusOK)
    }
    bytes, err = o.ResponseWriter.Write(p)
    o.written += uint64(bytes)
    return
}

func (o *resp) WriteHeader(code int) {
    o.ResponseWriter.WriteHeader(code)
    if o.wroteHeader {
        return
    }
    o.wroteHeader = true
    o.status = code
}

func (s *server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
    backend, _ := url.Parse("http://10.0.0.10")
    s.proxy = httputil.NewSingleHostReverseProxy(backend)
    s.proxy.ServeHTTP(w, r)
}

func main() {
    base := &server{}
    http.Handle("/", base)
    s := &http.Server{
        Addr:         ":80",
        Handler:      handler(http.DefaultServeMux),
        ReadTimeout:  30 * time.Second,
        WriteTimeout: 60 * time.Second,
        IdleTimeout:  120 * time.Second,
        ErrorLog:     log.New(ioutil.Discard, "", 0),
    }
    log.Panicln(s.ListenAndServe())
}