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: %vn", err)         return     }      // 3. 创建HTTP客户端和请求     client := &http.Client{}     req, err := http.NewRequest("POST", rpcURL, bytes.NewBuffer(jsonBytes))     if err != nil {         fmt.Printf("Error creating request: %vn", 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: %vn", err)         return     }     defer resp.Body.Close() // 确保关闭响应体      // 5. 读取并解析响应     bodyBytes, err := ioutil.ReadAll(resp.Body)     if err != nil {         fmt.Printf("Error reading response body: %vn", err)         return     }      if resp.StatusCode != http.StatusOK {         fmt.Printf("RPC call failed with status %d: %sn", resp.StatusCode, string(bodyBytes))         return     }      var rpcResponse RPCResponse     err = json.Unmarshal(bodyBytes, &rpcResponse)     if err != nil {         fmt.Printf("Error unmarshalling response: %vn", err)         return     }      if rpcResponse.Error != nil {         fmt.Printf("RPC error: %vn", rpcResponse.Error)         return     }      // 比特币的getblockcount通常返回整数，JSON解析时可能为float64     blockCount, ok := rpcResponse.Result.(float64)     if !ok {         fmt.Printf("Unexpected result type for getblockcount: %T, value: %vn", rpcResponse.Result, rpcResponse.Result)         return     }      fmt.Printf("Current Bitcoin block count: %.0fn", blockCount) }