端到端的反应流RESTful服务(也称为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,如果客户端正在实现Reactive Streams.在这种情况下,我是否可以通过TCP/HTTP或仅仅2个独立的流桥接一个"流"？这是我的主要怀疑和困惑.

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

Answer 1

你到了正确的地方问阿卡问题:-)

我知道有两个演讲,演示了使用http时背压机制是如何工作的演示.

1)一个是Roland Kuhn关于ScalaDays SF 2015的演讲:关于http演示的背压开始于本演讲的第44分钟.

2)我在ScalarConf华沙2015的演讲.溪流部分在18分钟左右开始,背压演示在第24分钟左右开始.它显示了一个"快速处理"和"慢速处理"服务器,您可以在其中看到卷曲客户端在上载文件时被反压(我使用文件作为示例,因为它是一个很好的"大请求").

由于TCP内置机制,背压传播到客户端 - 在服务器端,我们只是在需求可用之前不会从套接字读取,这会导致背压正常传播.

我希望这有帮助!