gRPC 中客户端流控制的原理是什么？

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《gRPC 中客户端流控制的原理是什么？》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我想知道 Go 中的客户端流 gRPC 服务中的流量控制是如何工作的。

具体来说，我有兴趣知道何时会在客户端块中调用 stream.SendMsg() 函数？根据文档：

SendMsg() 会阻塞，直到： 有足够的流量控制来调度 m 的传输，或者......

那么流的流控机制规范是怎样的呢？例如，如果负责从流中读取消息的服务器端代码读取消息的速度不够快，那么什么时候会调用 SendMsg() 块？

服务器是否实现了某种反压机制来告诉客户端它还没有准备好接收更多数据？与此同时，在反压信号之前已经成功发送的所有消息都在哪里排队？

解决方案

grpc流控是基于http2流控： https://httpwg.org/specs/rfc7540.html#FlowControl

会有背压。 仅当有足够的流控制窗口时消息才会成功发送，否则 sendmsg() 将阻塞。

接收端发出的信号不是增加反压，而是释放反压。这就像说“现在我准备好接收另外 1mb 的消息，发送它们”。

这是 flow control 的另一种解释

http/2 流量控制是一项可防止应用程序被数据淹没的功能。使用流量控制时：

• 每个 http/2 连接和请求都有一个可用的缓冲区窗口。缓冲窗口是应用程序一次可以接收多少数据。
• 如果缓冲区窗口已满，则激活流量控制。激活后，发送应用程序将暂停发送更多数据。
• 一旦接收应用程序处理完数据，缓冲区窗口中的空间就可用。发送应用程序恢复发送数据。

接收大消息时，流量控制可能会对性能产生负面影响。如果缓冲区窗口小于传入消息有效负载，或者客户端和服务器之间存在延迟，则可以以开始/停止突发的方式发送数据。

流量控制性能问题可以通过增加缓冲区窗口大小来解决。

• 客户端：通过dial option的withinitialwindowsize和withinitialconnwindowsize设置窗口

  // withinitialwindowsize returns a dialoption which sets the value for initial
  // window size on a stream. the lower bound for window size is 64k and any value
  // smaller than that will be ignored.
  func withinitialwindowsize(s int32) dialoption {
      return newfuncdialoption(func(o *dialoptions) {
          o.copts.initialwindowsize = s
      })
  }
  
  // withinitialconnwindowsize returns a dialoption which sets the value for
  // initial window size on a connection. the lower bound for window size is 64k
  // and any value smaller than that will be ignored.
  func withinitialconnwindowsize(s int32) dialoption {
      return newfuncdialoption(func(o *dialoptions) {
          o.copts.initialconnwindowsize = s
      })
  }
  

• 服务器端：通过initialwindowsize和initialconnwindowsize为server options设置窗口

  // InitialWindowSize returns a ServerOption that sets window size for stream.
  // The lower bound for window size is 64K and any value smaller than that will be ignored.
  func InitialWindowSize(s int32) ServerOption {
      return newFuncServerOption(func(o *serverOptions) {
          o.initialWindowSize = s
      })
  }
  
  // InitialConnWindowSize returns a ServerOption that sets window size for a connection.
  // The lower bound for window size is 64K and any value smaller than that will be ignored.
  func InitialConnWindowSize(s int32) ServerOption {
      return newFuncServerOption(func(o *serverOptions) {
          o.initialConnWindowSize = s
      })
  }
  
  

建议：

• 如果 grpc 服务经常接收大于 96 kb（kestrel 的默认流窗口大小）的消息，请考虑增加连接和流窗口大小。
• 连接窗口大小应始终等于或大于流窗口大小。流是连接的一部分，发送者受到两者的限制。

有关流量控制工作原理的更多信息，请参阅 HTTP/2 Flow Control

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~