Akka Websocket服务器推送在java

Question

我有一个在阿卡的Websocket实现，客户端可以发送一个简单的请求，服务器可以回复，但我想知道如何自发地发送一条消息从服务器到客户端阿卡？

Answer 1

我想通了，如何做到这一点：

首先，你需要做的ActorPublisher将邮件推送到客户端。其次，您需要创建一个使用Source.actorPublisher（Props.create（yourActorPublisher.class））的Flow，您将创建的流传递给handleWebSocketMessages路由。

我们邮件推送到客户端，您只需要发布的ActorRef和yourActorRef.tell（yourMessage，ActorRef.noSender（））