测量每个流的 gRPC 带宽答案

【问题标题】：Measure gRPC bandwidth per stream测量每个流的 gRPC 带宽
【发布时间】：2018-05-18 16:37:41
【问题描述】：

我有一个用 Go 编写的 gRPC 服务，它运行时间很长。我想要一种方法来测量每个流的网络/带宽使用情况，并将该信息提供给prometheus。

我找到了grpc.StreamServerInterceptor，但据我所知，它无法让您访问编组的消息（我需要弄清楚它的大小）。

我找到了this第三方中间件，但是好像没有导出任何网络相关信息。

【问题讨论】：

【解决方案1】：

您可以在 gRPC servers 和 clients 上设置 stats.Handler。您可以在提供的上下文中放置您需要的任何标签。

然后gRPC 将使用stats.OutPayload 或stats.InPayload 调用处理程序的HandleRPC 方法，其中包含消息（原始和编码）、其未压缩和线路长度以及时间戳。

【讨论】：

这是完美的
我需要一种方法来确定有效负载来自哪个流。我想我需要以某种方式标记上下文，但我不知道在哪里做。
您的stats.Handler 的TagConn 和TagRPC 方法应该使用有关连接和RPC 的信息进行调用。您应该将与您相关的位放入您返回的Context 中，并且Context（或基于它的位）应该在HandleConn 和HandleRPC 方法调用中传递给您的处理程序获取。
如果TagRPC参数中包含请求消息就好了。
HandleRPC 将为您提供消息。 TagRPC 旨在提供元数据，例如这是什么方法。