Go RPC超时需手动实现，推荐用context.WithTimeout外置封装goroutine调用并select等待结果或超时，兼顾通用性与可靠性。
在 Go 的 RPC 调用中，超时控制不是由 net/rpc 包原生支持的，必须借助底层连接或上下文（context）手动实现。最可靠、推荐的方式是使用 context.WithTimeout 包裹 RPC 调用，并配合支持上下文的传输层（如 HTTP 或自定义 TCP 封装），或对底层连接设置读写 deadline。
使用 context 控制 RPC 调用超时（推荐）
标准 net/rpc 的 Client.Call 和 Go 方法本身不接收 context.Context，但你可以将超时逻辑“外置”：启动 goroutine 执行 RPC，同时用 select 等待结果或超时。这是最通用、不依赖 RPC 协议改动的做法。
示例：
// client 调用带超时
func callWithTimeout(client *rpc.Client, serviceMethod string, args, reply interface{}, timeout time.Duration) error {
done := make(chan error, 1)
go func() {
done <- client.Call(serviceMethod, args, reply)
}()
select {
case err := <-done:
return err
case <-time.After(timeout):
return fmt.Errorf("rpc call timeout after %v", timeout)
}
}
注意：该方式不会自动中断正在执行的 RPC 请求（比如网络卡住），但能及时向调用方返回超时错误，避免协程长期阻塞。
立即学习“go语言免费学习笔记（深入）”；
为底层 TCP 连接设置读写 deadline
如果 RPC 基于 TCP（默认），可在建立连接后，对 net.Conn 显式调用 SetDeadline、SetReadDeadline 或 SetWriteDeadline。RPC 客户端在读响应或写请求时会受此限制。
关键点：
- 需在
rpc.NewClient(conn)之前设置 deadline（或封装 Dial 函数） - 每次调用前都应重设 deadline（因为一次 RPC 可能包含写请求 + 读响应）
- 建议使用
SetReadDeadline和SetWriteDeadline分别控制，更精准
示例（客户端连接初始化）：
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
return err
}
// 设置初始读写 deadline（可动态更新）
conn.SetReadDeadline(time.Now().Add(5 * time.Second))
conn.SetWriteDeadline(time.Now().Add(5 * time.Second))
client := rpc.NewClient(conn)
升级到 gRPC 或使用支持 Context 的 RPC 框架
原生 net/rpc 设计较老，缺乏现代特性。若项目允许，迁移到 gRPC 是更优解——它原生基于 HTTP/2，所有 RPC 方法都接受 context.Context，超时、取消、拦截器等开箱即用。
例如：
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
resp, err := client.GetUser(ctx, &pb.GetUserRequest{Id: 123})
其他轻量替代方案如 kitex（字节开源）、twirp 也全面支持 context，适合需要生产级稳定性和可观测性的场景。
服务端也应设置处理超时（防御性设计）
仅客户端超时不够。若某方法因死循环、锁竞争或外部依赖卡住，服务端可能持续占用资源。应在 handler 内部监听 context（如果使用支持 context 的框架），或用 time.AfterFunc 主动中断长时间运行逻辑。
例如，在自定义 RPC handler 中：
func (s *Server) Echo(r *http.Request, req *EchoReq, resp *EchoResp) error {
// 若请求带 timeout header 或从 context 解析出 deadline，可在此检查
ctx := r.Context()
done := make(chan struct{})
go func() {
defer close(done)
// 实际业务逻辑（可能耗时）
time.Sleep(10 * time.Second)
resp.Msg = req.Msg
}()
select {
case <-done:
return nil
case <-ctx.Done():
return ctx.Err() // 如 context.DeadlineExceeded
}
}
不复杂但容易忽略
