scala – 端到端的反应流式RESTful服务(通过HTTP进行背压)

发布时间：2020-12-16 18:18:32 所属栏目：安全来源：网络整理

导读：我一直试图在网上澄清这个问题一段时间没有成功,所以我会试着在这里问一下. 我想找到一些资源或示例,其中显示了我如何构建端到端完全反压的REST服务客户端.我的意思是,我希望看到,给定一个实现Reactive Streams的REST客户端(无论是在Akka,JS还是其他),我将拥

我一直试图在网上澄清这个问题一段时间没有成功,所以我会试着在这里问一下.

我想找到一些资源或示例,其中显示了我如何构建端到端完全反压的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个独立的流桥接一个“流”？这是我的主要怀疑和困惑.

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

解决方法

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

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

1)一个是Roland Kuhn’s talk on ScalaDays SF 2015：
http演示的背压在本次演讲的第44分钟左右开始.

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

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

我希望这有帮助！

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!