golang的rpc调用需手动实现超时控制，因net/rpc包不直接支持；2. 连接超时通过net.DialTimeout设置，防止TCP连接无限等待；3. 调用超时使用context.WithTimeout结合channel和select，避免Call阻塞；4. 可封装CallWithTimeout函数统一处理超时，确保连接和调用阶段均受控。
在使用 golang 进行 RPC 调用时，连接超时是一个必须处理的问题。如果不设置合理的超时机制，客户端可能会无限期等待，导致资源耗尽或请求堆积。Golang 的 net/rpc 包本身不直接支持超时控制，需要开发者自行封装。
理解 RPC 超时的类型
在处理 RPC 客户端连接超时前，先区分两种常见超时：
- 连接超时（Dial Timeout）：客户端建立 TCP 连接时等待服务器响应的时间。
- 调用超时（Call Timeout）：客户端发送请求后等待返回结果的时间。
两者都需要设置，否则在网络异常或服务不可达时会阻塞。
设置连接超时
使用 net.DialTimeout 替代默认的 rpc.Dial，可以控制连接阶段的超时。
立即学习“go语言免费学习笔记（深入）”；
示例代码：
conn, err := net.DialTimeout("tcp", "localhost:8080", 5*time.Second) if err != nil { log.Fatal("连接超时:", err) } client := rpc.NewClient(conn)
这里设置了 5 秒的连接超时，超过时间未建立连接则返回错误。
实现调用超时（Call Timeout）
由于 client.Call() 是同步阻塞调用，需结合 context 或 channel + select 实现超时控制。
推荐使用 context 方式：
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel() <p>done := make(chan error, 1) go func() { var reply string err := client.Call("Service.Method", "args", &reply) done <- err }()</p><p>select { case <-ctx.Done(): log.Println("调用超时") return case err := <-done: if err != nil { log.Println("调用失败:", err) } else { log.Println("调用成功") } }
这种方式能有效防止 Call 长时间阻塞。
封装带超时的 RPC 客户端
为简化使用，可封装一个支持超时的 RPC 调用函数：
func CallWithTimeout(client *rpc.Client, serviceMethod string, args interface{}, reply interface{}, timeout time.Duration) error { ctx, cancel := context.WithTimeout(context.Background(), timeout) defer cancel() <pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">done := make(chan error, 1) go func() { done <- client.Call(serviceMethod, args, reply) }() select { case <-ctx.Done(): return fmt.Errorf("RPC 调用超时 (%v)", timeout) case err := <-done: return err }
}
之后所有调用都可以统一使用该函数，确保不会因网络问题卡住。
基本上就这些。关键点是：连接阶段用 DialTimeout，调用阶段用 context 控制，两者结合才能完整处理超时问题。