go - RPC有超时机制吗？

Question

如果 RPC 没有超时机制，如果它试图调用已关闭的服务器的 RPC 方法，我该如何“终止”RPC 调用？

Answer 1

您可以使用 channels实现超时模式:

import "time"

c := make(chan error, 1)
go func() { c <- client.Call("Service", args, &result) } ()
select {
  case err := <-c:
    // use err and result
  case <-time.After(timeoutNanoseconds):
    // call timed out
}

select 将阻塞，直到 client.Call 返回或 timeoutNanoseconds 过去。