在使用Go语言进行网络编程时，net/rpc及其JSON编码的变体rpc/jsonrpc包为开发者提供了便捷的远程过程调用（RPC）机制。然而，当尝试使用jsonrpc.Dial连接到如Bitcoin Core等外部、非Go语言实现的RPC服务时，开发者可能会遇到一些意料之外的问题，特别是关于连接认证和协议兼容性方面。
Go标准库rpc/jsonrpc的限制：认证与地址格式
初学者尝试连接带有认证信息的RPC服务时，常会直观地将用户名和密码嵌入到连接地址中，例如user:pass@localhost:8332。但Go的rpc/jsonrpc.Dial函数在处理此类地址时会报错，提示dial tcp user:pass@localhost:8332: too many colons in address。
这个错误并非Go语言的bug，而是其底层net.Dial函数对地址格式的严格要求所致。net.Dial期望的地址格式通常是host:port或IP:port，它不负责解析和处理地址中嵌入的认证信息（如user:pass@）。在Go的标准RPC框架中，认证机制需要通过其他方式实现，例如在建立连接后通过RPC方法传递凭证，或者在更底层的传输层（如HTTP）进行认证。
对于外部服务，尤其是那些基于HTTP协议的JSON-RPC服务，认证通常是通过HTTP请求头（如Authorization）来实现的，而不是通过TCP连接字符串。
立即学习“go语言免费学习笔记（深入）”；
协议兼容性：一个常见误区
除了认证问题，另一个更根本且常被忽视的问题是协议兼容性。Go标准库的rpc/jsonrpc包虽然名称中带有“jsonrpc”，但它实现的并非通用的HTTP-based JSON-RPC协议（如JSON-RPC 1.0或2.0 over HTTP POST），而是Go语言RPC框架内部使用的、基于JSON编码的一种特定协议。
这意味着：
- Go的rpc/jsonrpc服务器：期望客户端使用Go的rpc/jsonrpc.Dial连接，并遵循其特有的请求/响应结构和编码方式。
- 外部JSON-RPC服务（如Bitcoin Core）：通常实现的是标准的JSON-RPC协议，通过HTTP POST请求发送JSON有效载荷，并期望HTTP响应中包含JSON格式的结果。它们之间存在本质的协议差异。
因此，即使能够解决地址格式问题，直接使用jsonrpc.Dial去连接一个非Go语言实现的、基于HTTP的JSON-RPC服务（如Bitcoin Core），也会因为协议不兼容而导致通信失败。Go的rpc/jsonrpc客户端会尝试发送其特有的RPC请求结构，而服务器则无法理解并正确解析。
正确的实践方法：连接外部HTTP-based JSON-RPC服务
要正确连接像Bitcoin Core这样的外部HTTP-based JSON-RPC服务，我们需要放弃Go标准库的rpc/jsonrpc包，转而使用Go的net/http包来构建标准的HTTP请求。以下是连接Bitcoin Core RPC的示例代码，它展示了如何手动构建JSON-RPC请求体和添加HTTP Basic认证：
package main
import (
"bytes"
"encoding/base64"
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
"time"
)
// RPCRequest represents a standard JSON-RPC 1.0 or 2.0 request
type RPCRequest struct {
JSONRPC string `json:"jsonrpc,omitempty"` // For JSON-RPC 2.0
ID int `json:"id"`
Method string `json:"method"`
Params []interface{} `json:"params"`
}
// RPCResponse represents a standard JSON-RPC 1.0 or 2.0 response
type RPCResponse struct {
JSONRPC string `json:"jsonrpc,omitempty"` // For JSON-RPC 2.0
Result json.RawMessage `json:"result"`
Error *RPCError `json:"error"`
ID int `json:"id"`
}
// RPCError represents a JSON-RPC error object
type RPCError struct {
Code int `json:"code"`
Message string `json:"message"`
}
func main() {
// Bitcoin RPC connection details
rpcUser := "your_rpc_username" // Replace with your Bitcoin RPC username
rpcPass := "your_rpc_password" // Replace with your Bitcoin RPC password
rpcHost := "localhost"
rpcPort := "8332" // Default Bitcoin RPC port
// Construct the RPC URL
rpcURL := fmt.Sprintf("http://%s:%s", rpcHost, rpcPort)
// Create a JSON-RPC request for "getblockcount"
request := RPCRequest{
JSONRPC: "1.0", // Bitcoin Core often uses JSON-RPC 1.0
ID: 1,
Method: "getblockcount",
Params: []interface{}{}, // No parameters for getblockcount
}
// Marshal the request struct to JSON
requestBody, err := json.Marshal(request)
if err != nil {
fmt.Printf("Error marshaling request: %v\n", err)
return
}
// Create a new HTTP client
client := &http.Client{
Timeout: 10 * time.Second, // Set a timeout for the request
}
// Create a new HTTP POST request
req, err := http.NewRequest("POST", rpcURL, bytes.NewBuffer(requestBody))
if err != nil {
fmt.Printf("Error creating request: %v\n", err)
return
}
// Add HTTP Basic Authentication header
auth := rpcUser + ":" + rpcPass
basicAuth := base64.StdEncoding.EncodeToString([]byte(auth))
req.Header.Set("Authorization", "Basic "+basicAuth)
req.Header.Set("Content-Type", "application/json") // Important for JSON-RPC
// Send the request
resp, err := client.Do(req)
if err != nil {
fmt.Printf("Error sending request: %v\n", err)
return
}
defer resp.Body.Close() // Ensure the response body is closed
// Read the response body
responseBody, err := ioutil.ReadAll(resp.Body)
if err != nil {
fmt.Printf("Error reading response body: %v\n", err)
return
}
// Check HTTP status code
if resp.StatusCode != http.StatusOK {
fmt.Printf("HTTP Error: %s, Response: %s\n", resp.Status, responseBody)
return
}
// Unmarshal the JSON-RPC response
var rpcResponse RPCResponse
err = json.Unmarshal(responseBody, &rpcResponse)
if err != nil {
fmt.Printf("Error unmarshaling response: %v\n", err)
return
}
// Check for RPC errors
if rpcResponse.Error != nil {
fmt.Printf("RPC Error: Code %d, Message: %s\n", rpcResponse.Error.Code, rpcResponse.Error.Message)
return
}
// Process the result
var blockCount float64 // Bitcoin's getblockcount returns a number
err = json.Unmarshal(rpcResponse.Result, &blockCount)
if err != nil {
fmt.Printf("Error unmarshaling result: %v\n", 
