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，可以控制连接阶段的超时。

示例代码：

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()
done := make(chan error, 1)
go func() {
var reply string
err := client.Call("Service.Method", "args", &reply)
done <- err
}()
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()
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 控制，两者结合才能完整处理超时问题。