我已经设法实现websocket 。首先定义将处理消息的actor

public class WebSocketActor extends AbstractActor {

    private final ActorRef out;

    @Inject
    public WebSocketActor(ActorRef out) {
        this.out = out;
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(String.class, message ->
                        out.tell("Sending message at " + LocalDateTime.now().toString(), self())
                )
                .build();
    }

    public static Props props(final ActorRef out) {
        return Props.create(WebSocketActor.class, out);
    }
}

将根据客户端创建此actor。ActorRef out将向已连接的客户端发送消息。在此示例中，响应将在传递给的每个字符串消息上发送给客户端WebSocketActor。

现在定义API端点以打开对客户端websocket的访问。定义将在新连接上创建actor的新实例的ActorFlow

public WebSocket ws() {
    return WebSocket.Text.accept(request -> ActorFlow.actorRef((out) -> WebSocketActor.props(out), actorSystem, materializer));
}

根据源代码， ActorFlow创建具有flowActor名称的actor 。因此，要在代码中的某处向websockets发送消息，我们可以通过其路径找到actor 。这将向所有连接的客户端广播消息

actorSystem.actorSelection("/user/*/flowActor").tell("Hello", ActorRef.noSender());

不幸的是我没有找到改变ActorFlow默认名称的简单方法。