scala - 端到端响应式(Reactive)流 RESTful 服务(又名 Back-Pressure over HTTP)

Question

这个问题我在网上想澄清了一段时间没有成功，所以我会试着在这里问一下。

我想找到一些资源或示例，其中展示了如何构建端到端的完全背压 REST 服务 + 客户端。我的意思是，我希望看到，给定一个实现 Reactive Streams 的 REST 客户端(无论是在 Akka、JS 还是其他中)，我将拥有(并且能够“可视化”)整个过程中处理的背压构建的 REST 服务器，例如使用 Akka-Http。

明确地说，我正在寻找类似于以下谈话的内容(但我找不到幻灯片或视频来确认):http://oredev.org/2014/sessions/reactive-streaming-restful-applications-with-akka-http

我对我看到的大多数示例的疑问是，我可以找到很多 REST 服务(服务器)在后端使用 Akka Http 和 Akka 流的情况，但我不确定背压是否通过 HTTP“通信”和 REST，如果客户端正在实现响应式流。在这种情况下，我会通过 TCP/HTTP 桥接单个“流”还是只有 2 个独立的流？这是我的主要怀疑和困惑。

希望我足够清楚，有人能够对此事有所了解。
无论如何，谢谢!

Answer 1

您来对地方了，可以向 Akka 提问 :-)

我知道有两个演讲展示了使用 http 时背压机制如何真正工作的演示。

1) 一个是 Roland Kuhn’s talk on ScalaDays SF 2015 :
http 演示的背压从本次演讲的第 44 分钟开始。

2) My talk from ScalarConf Warsaw 2015 .溪流部分在 18 分钟左右开始，
并且在第 24 分钟左右可以看到反压演示。它显示了“快速处理”和“慢速处理”服务器，您可以在其中看到
curl 客户端在上传文件时被背压(我以文件为例，因为它是一个很好的“大请求”)。

由于 TCP 内置机制，背压传播到客户端 - 在服务器端，我们根本不从套接字读取
直到需求可用，这会导致背压正确传播。

我希望这有帮助!