Akka Websocket server push in java

Question

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

Answer 1

我想出了如何做到这一点：

首先，您需要执行 ActorPublisher 操作，将消息推送到客户端。

其次，您需要创建一个使用 Source.actorPublisher（Props.create（yourActorPublisher.class））的流，您将创建的流传递给句柄WebSocketMessages路由。

现在要将消息推送到客户端，您只需要发布者的 ActorRef 和 yourActorRef.tell（yourMessage，ActorRef.noSender（）） 推送消息