Go RPC 默认同步阻塞,但可通过 goroutine + channel 封装实现伪异步;client.Go() 是标准库提供的异步接口,返回 *rpc.Call 并在完成后写入 Done channel。

Go 语言标准库的 net/rpc 默认是同步阻塞调用,但可以通过封装实现“伪异步”——即调用发起后不等待响应,由回调或 channel 接收结果。严格来说,Go RPC 本身不原生支持异步(如 HTTP/2 的流式 multiplexing 或 gRPC 的 streaming),但结合 goroutine 和 channel 可以高效模拟异步行为,兼顾简洁性与可控性。
用 goroutine + channel 封装异步调用
这是最常用、最轻量的方式:把同步调用丢进 goroutine,结果通过 channel 返回。
- 定义一个返回
chan *rpc.Call的包装函数,内部启动 goroutine 执行client.Go() -
client.Go()是标准库提供的异步接口,它立即返回*rpc.Call,并在完成后写入其Donechannel - 你可以监听
call.Done,或自己建带缓冲的 result channel 避免 goroutine 泄漏
示例:
func AsyncCall(client *rpc.Client, method string, args interface{}, reply interface{}) ch := make(chan *rpc.Call, 1)go func() {
call := client.Go(method, args, reply, nil)
ch }()
return ch
}
使用 context 控制超时与取消
异步不等于放任不管。真实场景中必须支持超时、主动取消和错误归因。
立即学习“go语言免费学习笔记(深入)”;
- 不要只依赖底层 TCP 超时;在
client.Go()后,用select等待call.Done或ctx.Done() - 将
context.Context传入 goroutine,并在调用前检查ctx.Err(),避免无效发起 - 若 RPC 方法本身支持 context(需自定义 server handler 或换用 gRPC),可透传取消信号到服务端
批量调用与并发控制
多个 RPC 请求同时发出时,需防止单机打爆连接或服务端过载。
- 用
semaphore(如golang.org/x/sync/semaphore)限制并发请求数 - 对一批相似请求,考虑合并为单次 RPC(例如批量查 ID 列表),减少网络开销
- 用
sync.WaitGroup+ channel 收集多个异步结果,再统一处理
升级到 gRPC(推荐长期方案)
如果项目允许重构,gRPC 原生支持真正的异步调用(Unary Client Stream / Async Unary),且自带负载均衡、TLS、超时、重试、指标等能力。
- Client 端用
ctx发起调用,返回grpc.CallOption可控行为 - 支持
WithBlock()、WithTimeout()、WithPerRPCCredentials()等精细配置 - 配合
grpc-go的拦截器,轻松实现日志、熔断、链路追踪
标准库 net/rpc 适合小工具或内网简单通信;高可用、多语言、需可观测性的系统,应优先选 gRPC。
基本上就这些。不用强求“完全异步”,关键是让调用不卡主流程、能及时失败、结果可预期。Go 的 channel 和 goroutine 已经提供了足够灵活的组合能力。










