go语言标准库rpc/jsonrpc在连接外部服务时常遇认证失败和协议不兼容问题。本文深入探讨jsonrpc.Dial不支持连接字符串中直接包含用户密码的原因，并指出其实现的是Go语言特有的RPC协议，而非常见的http-based JSON-RPC。文章将指导开发者如何正确地与如Bitcoin等外部RPC服务进行交互，强调使用标准HTTP客户端并手动处理认证与请求体的重要性，以避免常见的连接错误，确保高效可靠的远程过程调用。
在使用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: %vn", 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: %vn", 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: %vn", 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: %vn", err) return } // Check HTTP status code if resp.StatusCode != http.StatusOK { fmt.Printf("HTTP Error: %s, Response: %sn", 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: %vn", err) return } // Check for RPC errors if rpcResponse.Error != nil { fmt.Printf("RPC Error: Code %d, Message: %sn", 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: %vn",
