akka流ActorSubscriber不适用于远程actor [英] akka stream ActorSubscriber does not work with remote actors

问题描述

http： //doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-integrations.html 说：

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的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！