我试图了解akka提供的IO。我针对这个问题开始了另一个问题。
我找到了一个关于如何使用 akka IO的简单示例。我重新实现它并启动它。现在我想知道为什么只打印会话的第一条消息。有人可以解释一下state(socket)(Chunk(bytes))
正在做什么以及我如何向另一个Actor
人发送消息ActorSystem
吗?
编辑
我发现,演员只需要一个输入并通过将其打印到控制台来处理它。这引出了另一个问题:我怎样才能让演员接受多个输入并处理它们?我通过 putty 连接到服务器,如果我按回车键一次,它会按预期处理输入,但如果我发送另一行输入,它只会存储输入。我必须在哪里运行flatMap
,以便处理下一行输入?我在箱子里面试过了Read(socket, bytes)
,但没有用。