scala - Akka Streams 的 ActorPublisher 作为 Web 响应的源 - 背压如何工作

Question

我使用 akka-streams' ActorPublisher actor 作为每个连接的流式传输 Source 数据被发送到传入的 WebSocket 或 HTTP 连接.

ActorPublisher 的 contract是通过提供需求 - 下游可以接受的元素数量来定期请求数据。如果需求为 0，我不应该发送更多元素。我观察到如果我缓冲元素，当消费者速度慢时，缓冲区大小在 1 到 60 之间波动，但大部分在 40-50 附近。

为了流式传输，我使用 akka-http 将 WebSocket 输出和 HttpResponse 数据设置为 Message< 的 Source 的能力s(或 ByteStrings)。

我想知道在这种情况下背压是如何工作的——当我通过网络将数据流式传输到客户端时。这些数字究竟是如何计算出来的？它会检查网络级别发生的情况吗？

Answer 1

对于您的问题“在这种情况下背压如何工作”，我能找到的最接近的来自 the documentation :

Akka HTTP is streaming all the way through, which means that the back-pressure mechanisms enabled by Akka Streams are exposed through all layers–from the TCP layer, through the HTTP server, all the way up to the user-facing HttpRequest and HttpResponse and their HttpEntity APIs.

至于“这些数字是如何计算的”，我认为是specified in the configuration settings .