RPC有超时机制吗？

Question

如果RPC没有超时机制,如果它试图调用已关闭的服务器的RPC方法,如何"终止"RPC调用？

Answer 1

您可以使用通道来实现超时模式:

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经过.