Golang应用无法启用Socks5代理的问题求助

我之前在调试Golang应用通过Socks5代理访问K8s API时，也碰到过和你几乎一样的问题——curl能通，但Golang死活不走代理。结合你的尝试，给你几个经过验证的解决方案：

Golang的http.Client默认会读取系统环境变量，但有几个容易踩坑的点：

• 变量格式与大小写：确保环境变量是socks5://<IP:port>的完整格式，Unix-like系统下优先用小写的http_proxy、https_proxy、all_proxy（大写也能生效，但小写更稳妥）。
• 进程级生效：必须在启动Golang应用的终端里先export变量，再启动应用，否则进程读不到。可以在代码里加一行验证：

  fmt.Println("当前all_proxy值:", os.Getenv("all_proxy"))
  

• 避免被代码覆盖：如果你的代码里手动创建了http.Client并自定义了Transport，环境变量的代理设置会被忽略——因为只有默认的Transport才会自动读取环境变量。

你之前用proxy.SOCKS5的代码有两个关键问题：一是用了已废弃的Dial方法，二是没有兼容ContextDialer（很多库包括client-go会优先用这个）。修改后的代码如下：

import (
    "context"
    "fmt"
    "net"
    "net/http"
    "net/url"
    "crypto/tls"

    "golang.org/x/net/proxy"
)

func NewSocks5Transport(proxyAddr string) (*http.Transport, error) {
    // 解析代理地址，确保格式正确
    proxyURL, err := url.Parse(proxyAddr)
    if err != nil {
        return nil, fmt.Errorf("解析代理地址失败: %v", err)
    }

    // 创建支持Context的拨号器
    dialer, err := proxy.FromURL(proxyURL, proxy.Direct)
    if err != nil {
        return nil, fmt.Errorf("创建代理拨号器失败: %v", err)
    }

    ctxDialer, ok := dialer.(proxy.ContextDialer)
    if !ok {
        return nil, fmt.Errorf("代理拨号器不支持ContextDialer接口")
    }

    return &http.Transport{
        TLSClientConfig: &tls.Config{InsecureSkipVerify: true}, // 仅测试环境用，生产务必关闭
        DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
            // 这里可以加日志验证是否走了代理
            fmt.Printf("通过代理请求: %s://%s\n", network, addr)
            return ctxDialer.DialContext(ctx, network, addr)
        },
    }, nil
}

使用时直接把这个Transport传给http.Client：

transport, err := NewSocks5Transport("socks5://<你的代理IP:端口>")
if err != nil {
    panic(err)
}
client := &http.Client{Transport: transport}

// 用这个client发起请求即可，比如调用K8s API
resp, err := client.Get("https://<K8s API地址>/api/v1/services")

如果你是用client-go连接K8s集群，需要确保把自定义代理Transport注入到rest.Config中，而不是只修改普通的http.Client：

import (
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)

func main() {
    // 加载kubeconfig
    config, err := clientcmd.BuildConfigFromFlags("", "/path/to/你的kubeconfig文件")
    if err != nil {
        panic(err)
    }

    // 替换默认Transport为带代理的版本
    transport, err := NewSocks5Transport("socks5://<你的代理IP:端口>")
    if err != nil {
        panic(err)
    }
    config.Transport = transport

    // 创建K8s客户端
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err)
    }

    // 测试调用，比如列出所有Service
    services, err := clientset.CoreV1().Services("").List(context.TODO(), metav1.ListOptions{})
    if err != nil {
        panic(err)
    }
    fmt.Printf("找到%d个Service\n", len(services.Items))
}

• 查看代理服务器的访问日志，确认Golang应用的请求是否到达了代理。
• 暂时关闭代理服务器，看Golang应用是否会报错（如果报错说明代理已经生效）。

内容的提问来源于stack exchange，提问作者mahesh_klp