【发布时间】:2018-05-11 14:36:40
【问题描述】:
假设我有一个来源:
val source = Source(List(1,2,3))
如何像演员一样向消息来源发送消息?
sourceActor ! 4
【问题讨论】:
标签: scala akka akka-stream
假设我有一个来源:
val source = Source(List(1,2,3))
如何像演员一样向消息来源发送消息?
sourceActor ! 4
【问题讨论】:
标签: scala akka akka-stream
你不能像这样使用简单的基于集合的源。你需要另一个像Source.actorRef 或Source.queue。请记住,使用Source.actorRef 不会给您带来背压,并且通过网络远程发送的消息可能会丢失(由于参与者通信的最多一次传递语义)。
另外,在 Akka 文档中有关于集成演员的 an entire section。
【讨论】:
Source.actorRef 是该源的ActorRef 表示。