参与者初始化连接到websocket的Akka流。这是通过使用可以发送消息的Source.actorRef来完成的,然后由webSocketClientFlow处理这些消息并由Sink.foreach使用。Failure(e) => log.error("Test Websocket closed with an error\n", e)当play框架重新编译时,它关闭TestActor,但不关闭Akka这是否意味着我需要手动关闭流,例如,将用Source.act
我想做的是--演员A要求演员B给我一个信息,然后等待一个人回来。但是,演员B给A的不是一条信息,而是其中的四条。Actor A Future正确完成,但3条rest消息被计算为死信。为什么?是这样的吗?我的意思是,演员A有一个适当的处理程序,为什么信死了呢?INFO ForkJoinPool-2-worker-7得到的结果是po