昨天我在 go 中玩了 RPC 并且有一个我无法理解的行为。我编写了一个简单的 RPC 服务器,它在 VM 中运行,监听连接并为斐波那契计算提供单一方法。本地机器上的 RPC 客户端每秒向服务器询问 fibonacci(n),其中 n 是 (currentSecond*fixedMultiplicator),因此我可以产生至少稍微不同的负载。因此,在 for 循环中,客户端将在 60 秒内请求 60 个不同的值,然后重新开始。RPC 拨号在此循环之外,因此连接有些持久。当我杀死服务器时,假设 10 秒后,客户端将抛出错误,因为它无法向现在丢失的服务器发送任何内容。到目前为止,按计划工作。现在让我想到的是:当我在 61 秒后终止服务器时,尽管服务器丢失并且无法响应请求,但客户端仍会为所有请求打印出正确的结果。我什至关闭了服务器的虚拟机,所以服务器 IP 甚至不再在网络中。虽然有点有趣,但这种行为可能对实际应用程序有害(取决于您正在开发的内容)。有任何想法吗?// ############// # RPC SERVERerr := rpc.Register(service.Object)// errorcheckrpc.HandleHTTP()l, e := net.Listen("tcp", ":1301")// errorcheckgo http.Serve(l, nil)// ############// # RPC CLIENTclient, err := rpc.DialHTTP("tcp", "192.168.2.111:1301")// errorcheckvar divCall *rpc.Callfor { <-time.After(time.Duration(1 * time.Second)): n := time.Now().Second() * 90000000 log.Debug("n=", n) args := &services.FibonacciArgs{N: n} var reply int divCall = client.Go("Fibonacci.Calculate", args, &reply, nil) go func() { replyCall := <-divCall.Done r := replyCall.Reply.(*int) log.Debug("reply: ", r) }()}回答在 Linux 和 Windows 上运行代码后,我注意到了不同的结果。在 Linux 上,回复将始终是适当的零值(在我的情况下为 0)。另一方面,在 Windows 上,回复似乎已被缓存。要走的路是@cnicutar的提示。在 RPC 调用后检查错误值并相应地处理内容。永远不要盲目相信回复。
1 回答
暮色呼如
TA贡献1853条经验 获得超9个赞
您不检查代码中的错误:
divCall = client.Go("Fibonacci.Calculate", args, &reply, nil)
go func() {
replyCall := <-divCall.Done
// -- Must check replyCall.Error here --.
r := replyCall.Reply.(*int)
log.Debug("reply: ", r)
}()
也就是说,我认为这种行为很奇特,可能还有更多。
- 1 回答
- 0 关注
- 235 浏览
添加回答
举报
0/150
提交
取消
