请求出现 ERROR: rpcx: client protocol error: unexpected EOF

[gy0624ww]

问题： 客户端请求返回结果后会出现： 2024/03/22 10:18:49 client.go:764: ERROR: rpcx: client protocol error: unexpected EOF

请问是哪里的问题，因为是本机内部rpc调用，下面设置的时长不应该会出现超时断开的情况吧 @smallnest 辛苦帮忙看一下，这个是什么错误？下面代码配置的参数哪里有问题？

客户端代码如下：

func main() {
        // fmt.Println("client rpcx")
        // // rpcx client
        var oaid string
        flag.StringVar(&oaid, "oaid", "", "The Oaid to lookup")
        flag.Parse()
        d, _ := client.NewPeer2PeerDiscovery("tcp@"+"127.0.0.1:8972", "")
        opt := client.DefaultOption
        opt.CompressType = protocol.Gzip
        opt.SerializeType = protocol.MsgPack
        opt.Retries = 1
        opt.ConnectTimeout = 160 * time.Millisecond

        xclient := client.NewXClient("DeviceCrownFilter", client.Failfast, client.RandomSelect, d, opt)

        args := LookupRequest{
                Oaid: oaid,
        }

        for {
                reply := &LookupResponse{}
                err := xclient.Call(context.Background(), "Lookup", args, reply)
                if err != nil {
                        log.Println("failed to call: %v", err)
                }
                log.Printf("%s: %v", args.Oaid, reply.Exist)
                time.Sleep(300 * time.Millisecond)
        }
}

服务端代码配置如下：

engine := server.NewServer(
        server.WithReadTimeout(time.Duration(30)*time.Millisecond),
        server.WithWriteTimeout(time.Duration(30)*time.Millisecond),
    )

    filter.F = filter.NewCuckooFilter()
    fs := rpcx.NewFilterService(filter.F)
    // 路由初始化
    router := rpcx.NewRouter(fs)

    return rpcx.NewServer(engine, router)

[smallnest]

你这不是300 > 160 导致超时了？

[gy0624ww]

您发送给我的邮件 我已经收到了 所以，请您放心吧

[gy0624ww]

你这不是300 > 160 导致超时了？

这个160不是拨号的超时时间吗？ for循环之前就连上了呀。 他和for循环里的请求间隔有什么关系呢？for循环里也没close之前的连接

[smallnest]

对，不是超时问题。 这个错误是服务端把链接关闭，导致客户端报错

[gy0624ww]

对，不是超时问题。 这个错误是服务端把链接关闭，导致客户端报错

嗯，原因找到了，是服务端设置的readtimeout ，因为客户端设置了sleep,服务端等待下次请求超时导致的。

最终解决是客户端设置了心跳，并且心跳间隔小于服务端的readtimeout 多谢

[gy0624ww]

您发送给我的邮件 我已经收到了 所以，请您放心吧