问题描述
说:
ActorPublisher和ActorSubscriber不能与远程actor一起使用,因为如果丢失了Reactive Streams协议(例如请求)的信号,则流可能会死锁。
"ActorPublisher and ActorSubscriber cannot be used with remote actors, because if signals of the Reactive Streams protocol (e.g. request) are lost the the stream may deadlock."
确实这意味着akka流不是位置透明的吗?如何使用akka流设计客户端和服务器位于不同计算机上的可感知背压的客户端-服务器系统?
Does this mean akka stream is not location transparent? How do I use akka stream to design a backpressure-aware client-server system where client and server are on different machines?
我必须对某些东西有误解。谢谢您的澄清。
I must have misunderstood something. Thanks for any clarification.
推荐答案
目前,它们严格来说是 local 设施。
您可以将其连接到TCP接收器/源,尽管如此,它也将使用TCP施加反压(这是Akka Http所做的)。
They are strictly a local facility at this time. You can connect it to an TCP sink/source and it will apply back-pressure using TCP as well though (that's what Akka Http does).
这篇关于akka流ActorSubscriber不适用于远程actor的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!