"MaxConcurrentStreams“服务器选项是否等同于grpc-python中的"maximum_concurrent_rpcs”？

Question

我正在实现一个grpc服务器(在go中)，其中我需要响应某种类型的服务器忙/不可用消息，以防我的服务器已经在为设置的最大数量的RPC(当前)提供服务。

我在前面使用grpc-python实现了一个grpc服务器，其中我结合使用了maximum_concurrent_rpcs和threadpool中的最大线程数。我在grpc-go中寻找类似的东西。我能找到的最接近的是服务器设置，它可以通过调用MaxConcurrentStreams返回的ServerOptions来设置。我的应用程序只支持unary RPCs，我不确定此设置是否适用于此设置。

我只是想强制执行/设置服务器可以处理的活动并发请求的最大数量。设置maxConcurrentStreams可以吗?或者我应该考虑在我的代码本身中这样做(我已经为它做了一些基本的实现，但我更愿意使用grpc-go提供的东西)？

Answer 1

我以前从未使用过MaxConcurrentStreams，因为对于高负载服务，您通常希望最大限度地利用您的硬件，而这种限制似乎没有意义。也许使用此设置可以实现您的目标，但您需要调查一下，在实现MaxConcurrentStreams时会返回哪种类型的错误。我认为这应该是GRPC的传输错误，而不是您自己的错误，所以您将无法控制错误消息和代码。