用Golang实现一个简单的HTTP/HTTPS代理服务器 https://www.iamle.com/archives/2652.html

httpproxy.go

package main

import (
    "flag"
    "io"
    "log"
    "net"
    "net/http"
    "strings"
)

type Pxy struct {
    Cfg Cfg
}

// 设置type
type Cfg struct {
    Addr        string   // 监听地址
    Port        string   // 监听端口
    IsAnonymous bool     // 高匿名模式
    Debug       bool     // 调试模式
}

func main() {

    // 参数
    faddr := flag.String("addr","0.0.0.0","监听地址，默认0.0.0.0")
    fprot := flag.String("port","8080","监听端口，默认8080")
    fanonymous :=  flag.Bool("anonymous",true,"高匿名，默认高匿名")
    fdebug :=  flag.Bool("debug",false,"调试模式显示更多信息，默认关闭")
    flag.Parse()

    cfg := &Cfg{}
    cfg.Addr = *faddr
    cfg.Port = *fprot
    cfg.IsAnonymous = *fanonymous
    cfg.Debug = *fdebug
    // fmt.Println(cfg)
    Run(cfg)
}

func Run(cfg *Cfg) {
    pxy := NewPxy()
    pxy.SetPxyCfg(cfg)
    log.Printf("HttpPxoy is runing on %s:%s \n", cfg.Addr, cfg.Port)
    // http.Handle("/", pxy)
    bindAddr := cfg.Addr + ":" + cfg.Port
    log.Fatalln(http.ListenAndServe(bindAddr, pxy))
}


// 实例化
func NewPxy() *Pxy {
    return &Pxy{
        Cfg: Cfg{
            Addr:        "",
            Port:        "8081",
            IsAnonymous: true,
            Debug:       false,
        },
    }
}

// 配置参数
func (p *Pxy) SetPxyCfg(cfg *Cfg) {
    if cfg.Addr != "" {
        p.Cfg.Addr = cfg.Addr
    }
    if cfg.Port != "" {
        p.Cfg.Port = cfg.Port
    }
    if cfg.IsAnonymous != p.Cfg.IsAnonymous {
        p.Cfg.IsAnonymous = cfg.IsAnonymous
    }
    if cfg.Debug != p.Cfg.Debug {
        p.Cfg.Debug = cfg.Debug
    }

}

// 运行代理服务
func (p *Pxy) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
    // debug
    if p.Cfg.Debug {
        log.Printf("Received request %s %s %s\n", req.Method, req.Host, req.RemoteAddr)
        // fmt.Println(req)
    }

    // http && https
    if req.Method != "CONNECT" {
        // 处理http
        p.HTTP(rw, req)
    } else {
        // 处理https
        // 直通模式不做任何中间处理
        p.HTTPS(rw, req)
    }

}

// http
func (p *Pxy) HTTP(rw http.ResponseWriter, req *http.Request) {

    transport := http.DefaultTransport

    // 新建一个请求outReq
    outReq := new(http.Request)
    // 复制客户端请求到outReq上
    *outReq = *req // 复制请求

    //  处理匿名代理
    if p.Cfg.IsAnonymous == false {
        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)
        }
    }

    // outReq请求放到传送上
    res, err := transport.RoundTrip(outReq)
    if err != nil {
        rw.WriteHeader(http.StatusBadGateway)
        rw.Write([]byte(err.Error()))
        return
    }

    // 回写http头
    for key, value := range res.Header {
        for _, v := range value {
            rw.Header().Add(key, v)
        }
    }
    // 回写状态码
    rw.WriteHeader(res.StatusCode)
    // 回写body
    io.Copy(rw, res.Body)
    res.Body.Close()
}


// https
func (p *Pxy) HTTPS(rw http.ResponseWriter, req *http.Request) {

    // 拿出host
    host := req.URL.Host
    hij, ok := rw.(http.Hijacker)
    if !ok {
        log.Printf("HTTP Server does not support hijacking")
    }

    client, _, err := hij.Hijack()
    if err != nil {
        return
    }

    // 连接远程
    server, err := net.Dial("tcp", host)
    if err != nil {
        return
    }
    client.Write([]byte("HTTP/1.0 200 Connection Established\r\n\r\n"))

    // 直通双向复制
    go io.Copy(server, client)
    go io.Copy(client, server)
}

感谢，搜了ChatGPT，一顿胡说八道，靠这段代码解惑了