通过GO语言接入代码Demo

				
					package main

import (
    "crypto/tls"
    "fmt"
    "io/ioutil"
    "net/http"
    "net/url"
    "time"
)

func httpProxyDemo() {
    fmt.Println("=== HTTP 代理演示 ===")
    
    // HTTP代理配置
    proxyHost := "proxy.ipnut.com"
    proxyPort := "28001"
    proxyUsername := "ipnut"
    proxyPassword := "123456789"
    
    // 构建代理URL
    proxyURL := fmt.Sprintf("http://%s:%s@%s:%s", 
        url.QueryEscape(proxyUsername),
        url.QueryEscape(proxyPassword),
        proxyHost, 
        proxyPort)
    
    // 解析代理URL
    proxy, err := url.Parse(proxyURL)
    if err != nil {
        fmt.Printf("解析代理URL失败: %v\n", err)
        return
    }
    
    // 创建HTTP传输层
    httpTransport := &http.Transport{
        Proxy: http.ProxyURL(proxy),
        TLSClientConfig: &tls.Config{
            InsecureSkipVerify: true, // 仅测试使用，生产环境应验证证书
        },
        MaxIdleConns:        10,
        IdleConnTimeout:     30 * time.Second,
        TLSHandshakeTimeout: 10 * time.Second,
    }
    
    // 创建HTTP客户端
    client := &http.Client{
        Transport: httpTransport,
        Timeout:   30 * time.Second,
    }
    
    // 测试请求
    testURL := "http://httpbin.org/ip"
    fmt.Printf("通过HTTP代理访问: %s\n", testURL)
    
    resp, err := client.Get(testURL)
    if err != nil {
        fmt.Printf("请求失败: %v\n", err)
        return
    }
    defer resp.Body.Close()
    
    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        fmt.Printf("读取响应失败: %v\n", err)
        return
    }
    
    fmt.Printf("状态码: %d\n", resp.StatusCode)
    fmt.Printf("响应内容: %s\n", string(body))
}

func httpProxyWithMultipleRequests() {
    fmt.Println("\n=== HTTP 代理多请求演示 ===")
    
    proxyHost := "proxy.ipnut.com"
    proxyPort := "28001"
    proxyUsername := "ipnut"
    proxyPassword := "123456789"
    
    proxyURL := fmt.Sprintf("http://%s:%s@%s:%s", 
        url.QueryEscape(proxyUsername),
        url.QueryEscape(proxyPassword),
        proxyHost, 
        proxyPort)
    
    proxy, err := url.Parse(proxyURL)
    if err != nil {
        fmt.Printf("解析代理URL失败: %v\n", err)
        return
    }
    
    client := &http.Client{
        Transport: &http.Transport{
            Proxy: http.ProxyURL(proxy),
        },
        Timeout: 30 * time.Second,
    }
    
    // 测试多个端点
    testURLs := []string{
        "http://httpbin.org/ip",
        "http://httpbin.org/user-agent", 
        "http://httpbin.org/headers",
    }
    
    for i, testURL := range testURLs {
        fmt.Printf("\n请求 %d: %s\n", i+1, testURL)
        
        resp, err := client.Get(testURL)
        if err != nil {
            fmt.Printf("请求失败: %v\n", err)
            continue
        }
        defer resp.Body.Close()
        
        body, err := ioutil.ReadAll(resp.Body)
        if err != nil {
            fmt.Printf("读取响应失败: %v\n", err)
            continue
        }
        
        fmt.Printf("状态码: %d\n", resp.StatusCode)
        fmt.Printf("响应长度: %d 字节\n", len(body))
        
        time.Sleep(1 * time.Second) // 避免请求过快
    }
}