Создать веб-сокет с игровым фреймворком 2.6

Question

Я пытаюсь сделать следующее с Play Framework 2.6:

1. Браузер нацелен на сервер, и веб-сокет создается
2. Позже (после выполнения какого-либо другого запроса)сервер отправляет сообщение в браузер через ранее созданный веб-сокет

1) Это можно легко сделать с помощью маршрута:

public WebSocket socket() {
    return WebSocket.Text.accept(request -> {
        // Log events to the console
        Sink<String, ?> in = Sink.foreach(System.out::println);

        // Send a single 'Hello!' message and then leave the socket open
        Source<String, ?> out = Source.single("Hello!").concat(Source.maybe());

        return Flow.fromSinkAndSource(in, out);
    });
}

и веб-сокет может быть сохранен на стороне сервера..

2) Но тогда как я могу отправлять данные через веб-сокет?(запущенная сторона сервера)

Это было легко сделать с 2.5, но документация не очень полезна для игры 2.6.

Спасибо

Answer 1

Мне удалось реализовать websocket с помощью Актеров Akka .На первом шаге определите актера, который будет обрабатывать сообщения

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);
    }
}

Этот актер будет создан для каждого клиента.ActorRef out отправит сообщение подключенному клиенту.В этом примере ответ отправляется клиенту на каждое строковое сообщение, переданное WebSocketActor.

Теперь определите конечную точку API, чтобы открыть доступ к веб-сокету для клиентов.Определите ActorFlow, который будет создавать новый экземпляр актера при новом подключении

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

Согласно исходный код ActorFlow создает актеров с именем flowActor.Таким образом, чтобы отправить сообщение в веб-сокеты где-нибудь в коде, мы можем найти актеров по их пути .Это будет транслировать сообщение всем подключенным клиентам

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

К сожалению, я не нашел простого способа изменить имя по умолчанию ActorFlow, но, возможно, этот ответ может помочь вам play-scala-akka-websockets-change-actor-path .

Также вы можете проверить проект play-java-websocket-example из примеров playframework.