Go语言连接比特币RPC：理解rpc/jsonrpc的局限与正确实践

package main

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

// RPCRequest 定义了标准的JSON-RPC请求结构
type RPCRequest struct {
    JSONRPC string        `json:"jsonrpc"` // JSON-RPC版本，比特币通常是"1.0"或不指定
    Method  string        `json:"method"`  // 要调用的RPC方法名
    Params  []interface{} `json:"params"`  // 方法参数，可以是数组
    ID      int           `json:"id"`      // 请求ID
}

// RPCResponse 定义了标准的JSON-RPC响应结构
type RPCResponse struct {
    Result interface{} `json:"result"` // RPC方法执行结果
    Error  interface{} `json:"error"`  // 错误信息，如果存在
    ID     int         `json:"id"`     // 响应ID，与请求ID对应
}

func main() {
    // 替换为你的比特币RPC配置
    rpcUser := "your_rpc_username" // 比特币配置文件中的 rpcuser
    rpcPass := "your_rpc_password" // 比特币配置文件中的 rpcpassword
    rpcHost := "localhost:8332"    // 比特币RPC监听地址和端口
    rpcURL := fmt.Sprintf("http://%s", rpcHost)

    // 1. 构建Basic Authentication头部
    auth := rpcUser + ":" + rpcPass
    basicAuthHeader := "Basic " + base64.StdEncoding.EncodeToString([]byte(auth))

    // 2. 构造JSON-RPC请求体
    requestBody := RPCRequest{
        JSONRPC: "1.0",           // 比特币RPC通常使用JSON-RPC 1.0
        Method:  "getblockcount", // 要调用的方法
        Params:  []interface{}{}, // getblockcount方法没有参数
        ID:      1,               // 任意请求ID
    }

    jsonBytes, err := json.Marshal(requestBody)
    if err != nil {
        fmt.Printf("Error marshalling request: %v\n", err)
        return
    }

    // 3. 创建HTTP客户端和请求
    client := &http.Client{}
    req, err := http.NewRequest("POST", rpcURL, bytes.NewBuffer(jsonBytes))
    if err != nil {
        fmt.Printf("Error creating request: %v\n", err)
        return
    }

    // 设置HTTP头部
    req.Header.Set("Content-Type", "application/json")
    req.Header.Set("Authorization", basicAuthHeader)

    // 4. 发送请求
    resp, err := client.Do(req)
    if err != nil {
        fmt.Printf("Error sending request: %v\n", err)
        return
    }
    defer resp.Body.Close() // 确保关闭响应体

    // 5. 读取并解析响应
    bodyBytes, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        fmt.Printf("Error reading response body: %v\n", err)
        return
    }

    if resp.StatusCode != http.StatusOK {
        fmt.Printf("RPC call failed with status %d: %s\n", resp.StatusCode, string(bodyBytes))
        return
    }

    var rpcResponse RPCResponse
    err = json.Unmarshal(bodyBytes, &rpcResponse)
    if err != nil {
        fmt.Printf("Error unmarshalling response: %v\n", err)
        return
    }

    if rpcResponse.Error != nil {
        fmt.Printf("RPC error: %v\n", rpcResponse.Error)
        return
    }

    // 比特币的getblockcount通常返回整数，JSON解析时可能为float64
    blockCount, ok := rpcResponse.Result.(float64)
    if !ok {
        fmt.Printf("Unexpected result type for getblockcount: %T, value: %v\n", rpcResponse.Result, rpcResponse.Result)
        return
    }

    fmt.Printf("Current Bitcoin block count: %.0f\n", blockCount)
}