我正在构建一个具有微服务体系结构的系统,使用grpc在服务之间进行通信。在开始时,我有一个长时间运行的请求,该请求到达一个中心端点,该端点向其他服务发出大量请求。对中心服务的第一个请求依次等待,直到其他服务计算完它们的请求,然后才收到来自中心端点的响应。这可能需要几分钟才能完成。问题是,我一直收到一个grpc错误,上面写着“太多的pings”。我已经通过以下方式在我的go服务器上设置了持活参数:
ka_params := keepalive.ServerParameters{
Time: 10 * time.Second,
Timeout: 5 * time.Second,}
opts := []grpc.ServerOption{
grpc.KeepaliveParams(ka_params),
}
s = grpc.NewServer(opts...)在我的python服务器上,像这样:
opts = [("grpc.keepalive_time_ms", 10000),
("grpc.keepalive_timeout_ms", 5000),
("grpc.keepalive_permit_without_calls", True),
("grpc.http2.max_pings_without_data", 0)]
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10), options=opts)我不知道为什么我会犯太多的错误。难道不是因为保持活力而期待的吗?
发布于 2021-03-03 18:41:03
我想我找到了解决办法。问题的症结在于python和golang版本有不同的默认设置,python文档很少。
要解决这个问题,必须将python服务器上的max_ping_strikes设置为0。python服务器应该有以下选项:
opts = [("grpc.keepalive_time_ms", 10000),
("grpc.keepalive_timeout_ms", 5000),
("grpc.keepalive_permit_without_calls", True),
("grpc.http2.max_ping_strikes", 0)] 发布于 2021-03-04 07:46:43
在python服务器端,要配置可接受的保持活动时间周期,您需要将"grpc.http2.min_ping_interval_without_data_ms“设置为10秒(考虑到网络延迟,可能要高一点)。
这个参数的默认设置是5分钟,如果客户端每10秒发送一次pings,那么它将导致用"too_many_pings“发送一个GOAWAY帧。
(同时,服务器端的"grpc.keepalive_time_ms“也会导致服务器每10秒发送一次保持活动的ping。这可能不是你想要的。)
参考资料:https://github.com/grpc/grpc/blob/master/doc/keepalive.md
https://stackoverflow.com/questions/66271810
复制相似问题