当前位置：首页 > 文章列表 > Golang > Go教程 > Golang反向代理实现，httputil.ReverseProxy详解

Golang反向代理实现，httputil.ReverseProxy详解

2025-08-19 11:59:27 0浏览收藏

大家好，今天本人给大家带来文章《Golang实现反向代理，httputil.ReverseProxy使用详解》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

答案：使用Golang的net/http/httputil包可快速实现反向代理。1. 通过url.Parse解析目标地址，httputil.NewSingleHostReverseProxy创建代理，http.ListenAndServe启动服务；2. 自定义Director函数可修改请求头、路径等；3. 设置ModifyResponse和ErrorHandler可定制响应与错误处理；4. 适用于开发代理、负载均衡及网关中间件。

Golang实现反向代理服务通过httputil.ReverseProxy转发请求

使用Golang实现反向代理服务非常简单，net/http/httputil 包中的 ReverseProxy 类型提供了开箱即用的反向代理功能。你只需要定义目标服务器地址，并通过 httputil.NewSingleHostReverseProxy 创建代理实例，再结合标准的 http.ListenAndServe 即可运行一个基本的反向代理服务。

1. 基本反向代理实现

以下是一个最简单的反向代理示例，将所有请求转发到本地运行的后端服务（例如运行在 http://localhost:8080）：

package main

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

func main() {
    // 目标后端服务地址
    target, _ := url.Parse("http://localhost:8080")
    
    // 创建反向代理对象
    proxy := httputil.NewSingleHostReverseProxy(target)

    // 设置HTTP处理器，将所有请求交给代理处理
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        proxy.ServeHTTP(w, r)
    })

    log.Println("反向代理服务启动，监听 :8081")
    log.Fatal(http.ListenAndServe(":8081", nil))
}

在这个例子中：

url.Parse 解析目标服务地址。
httputil.NewSingleHostReverseProxy 创建一个只代理到单一目标的反向代理。
proxy.ServeHTTP 处理请求并转发到目标服务，同时将响应返回给客户端。

2. 自定义请求修改

有时候你可能需要在转发前修改请求，比如添加请求头、修改路径或设置来源信息。可以通过设置 Director 函数实现：

proxy.Director = func(req *http.Request) {
    // 修改请求目标
    req.URL.Scheme = "http"
    req.URL.Host = "localhost:8080"
    
    // 可选：添加自定义头
    req.Header.Set("X-Forwarded-For", req.RemoteAddr)
    req.Header.Set("X-Real-IP", req.RemoteAddr)
    
    // 可选：修改路径前缀
    // req.URL.Path = "/api" + req.URL.Path
}

Director 允许你完全控制请求的转发逻辑。注意不要修改 req.Body，因为反向代理会自动处理流式传输。

3. 错误处理与响应修改

默认情况下，如果后端服务无响应或返回错误，反向代理会直接返回502 Bad Gateway。你可以通过设置 ModifyResponse 和 ErrorHandler 来自定义行为：

proxy.ModifyResponse = func(resp *http.Response) error {
    // 可以在这里修改响应头
    resp.Header.Set("X-Proxy-By", "Go-Reverse-Proxy")
    return nil
}

proxy.ErrorHandler = func(w http.ResponseWriter, r *http.Request, err error) {
    log.Printf("代理错误: %v", err)
    http.Error(w, "服务暂时不可用", http.StatusBadGateway)
}