Go语言中处理复杂网络地址：解决“冒号过多”错误

dial tcp http://user:password@host:8332: too many colons in address

dial ip http://user:password@host:8332: lookup http://user:password@host:8332: no such host

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    // 假设的JSON-RPC服务器地址和凭证
    user := "rpcuser"
    password := "rpcpassword"
    host := "127.0.0.1" // 或实际的域名
    port := "8332"

    // 错误的地址格式示例 (会导致 "too many colons in address" 或 "no such host")
    // errorAddress := fmt.Sprintf("%s:%s@%s:%s", user, password, host, port)
    // fmt.Printf("尝试连接错误地址: %s\n", errorAddress)
    // conn, err := net.DialTimeout("tcp", errorAddress, 5*time.Second)
    // if err != nil {
    //  fmt.Printf("错误连接失败: %v\n", err)
    // } else {
    //  fmt.Println("错误连接成功 (意外情况)")
    //  conn.Close()
    // }

    // 正确的地址格式
    // 将 'user:password@host' 整个作为主机部分，并用方括号包裹
    correctHostPart := fmt.Sprintf("%s:%s@%s", user, password, host)
    correctAddress := fmt.Sprintf("[%s]:%s", correctHostPart, port)

    fmt.Printf("尝试连接正确地址: %s\n", correctAddress)

    // 使用 net.DialTimeout 尝试连接
    // 注意：此处仅演示地址格式的正确性，实际连接成功与否取决于目标服务是否可用
    conn, err := net.DialTimeout("tcp", correctAddress, 5*time.Second)
    if err != nil {
        fmt.Printf("正确连接失败: %v\n", err)
        // 实际应用中，这里可能是目标服务未运行或防火墙问题
    } else {
        fmt.Printf("正确连接成功到 %s\n", correctAddress)
        conn.Close()
    }

    // 模拟一个没有认证信息的简单地址
    simpleAddress := fmt.Sprintf("%s:%s", host, port)
    fmt.Printf("尝试连接简单地址: %s\n", simpleAddress)
    conn, err = net.DialTimeout("tcp", simpleAddress, 5*time.Second)
    if err != nil {
        fmt.Printf("简单连接失败: %v\n", err)
    } else {
        fmt.Printf("简单连接成功到 %s\n", simpleAddress)
        conn.Close()
    }
}

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io/ioutil"
    "net"
    "net/http"
    "time"
)

// CustomDialContext 模拟一个自定义的DialContext，它将使用方括号规则
func CustomDialContext(dialer *net.Dialer) func(network, addr string) (net.Conn, error) {
    return func(network, addr string) (net.Conn, error) {
        fmt.Printf("CustomDialContext 尝试拨号: network=%s, addr=%s\n", network, addr)
        // 在这里，如果addr是复杂格式，我们假设它已经被正确处理为 [host]:port
        // 实际生产中，可能需要更复杂的逻辑来解析 addr
        return dialer.Dial(network, addr)
    }
}

func main() {
    // 假设的JSON-RPC服务器URL和凭证
    user := "rpcuser"
    password := "rpcpassword"
    host := "127.0.0.1" // 或实际的域名
    port := "8332"
    rpcPath := "/" // JSON-RPC通常在根路径

    // 构建完整的URL，包含认证信息
    // 注意：http.Client 通常能自行处理这种格式的URL
    // 但是如果底层dialer接收到的host:port部分有问题，则可能出现错误
    fullURL := fmt.Sprintf("http://%s:%s@%s:%s%s", user, password, host, port, rpcPath)
    fmt.Printf("构造的完整URL: %s\n", fullURL)

    // 创建一个HTTP客户端
    client := &http.Client{
        Timeout: 10 * time.Second,
        Transport: &http.Transport{
            // 使用自定义DialContext，它会打印出底层拨号的地址
            // 实际中，如果你的自定义DialContext需要特殊处理复杂地址，
            // 你可能需要在addr参数上应用方括号规则
            DialContext: (&net.Dialer{
                Timeout:   5 * time.Second,
                KeepAlive: 30 * time.Second,
            }).DialContext,
            // 如果你直接用DialContext(network, addr string) (net.Conn, error)
            // 则addr就是host:port，需要确保其格式正确
            // DialContext: CustomDialContext((&net.Dialer{
            //  Timeout:   5 * time.Second,
            //  KeepAlive: 30 * time.Second,
            // })),
        },
    }

    // 构造JSON-RPC请求体
    requestBody := map[string]interface{}{
        "jsonrpc": "1.0",
        "id":      "go-jsonrpc-client",
        "method":  "getblockchaininfo", // 假设的RPC方法
        "params":  []interface{}{},
    }
    jsonBody, _ := json.Marshal(requestBody)

    req, err := http.NewRequest("POST", fullURL, bytes.NewBuffer(jsonBody))
    if err != nil {
        fmt.Printf("创建请求失败: %v\n", err)
        return
    }
    req.Header.Set("Content-Type", "application/json")

    // 发送请求
    resp, err := client.Do(req)
    if err != nil {
        fmt.Printf("发送请求失败: %v\n", err)
        // 这里的错误可能是 "dial tcp [rpcuser:rpcpassword@127.0.0.1]:8332: connect: connection refused"
        // 这表明地址格式正确，但目标服务未运行或无法访问。
        // 如果这里出现 "too many colons in address"，则说明URL解析或底层Dialer配置有问题。
        return
    }
    defer resp.Body.Close()

    // 读取响应
    responseBody, _ := ioutil.ReadAll(resp.Body)
    fmt.Printf("响应状态: %s\n", resp.Status)
    fmt.Printf("响应体: %s\n", string(responseBody))
}