Play Framework. Можно ли совмещать использование Promise и WebSocket в Play?

Я использую Play 2.0.1 с Java. До этого момента я загружал страницу, отображающую данные из базы данных, используя Promise. Вот исходный код контроллера:

public static Result index() {
    // Generate the page
    final MainPage page = new MainPage();

    Promise<MainPage> promiseMainPage = Akka.future(
            new Callable<MainPage>() {
                public MainPage call() throws Exception {
                    page.generate();
                    return page;
                }
            });

    return async(promiseMainPage.map(new Function<MainPage, Result>() {
            @Override
            public Result apply(MainPage mainPage) throws Throwable {
                return ok(views.html.index.render(mainPage));
            }
     }));
}

Все это прекрасно работает; обещанная страница отправляется в браузер, пока сервер не блокирует запрос к базе данных (выполняемый в page.generate()) для завершения. Однако теперь я хотел бы использовать WebSocket для обновления страницы новой/измененной информацией, полученной из БД. Поэтому я использовал пример с чатом именно для этого (даже в упрощенном виде, поскольку я хотел бы использовать только исходящий канал: от сервера к клиенту). Я добавил следующее в конец index.scala.html:

<script type="text/javascript" charset="utf-8">

    $(function() {
    var WS = window['MozWebSocket'] ? MozWebSocket : WebSocket;
    var socket = new WS("@(routes.Application.webSocket().webSocketURL(request))");

    var receiveEvent = function(event) {
        var data = JSON.parse(event.data);

        var connectionStatus = data["connectionStatus"];
        var connectionStatusHtml = '<font color="red">* Not connected</font>';
        if (connectionStatus != undefined) {
            connectionStatusHtml = '<font color="blue">' + connectionStatus + '</font>';
        }

        $('#connectionStatus').html(connectionStatusHtml);
    }

    socket.onmessage = receiveEvent;
    })

</script>

Я обновил файл routes и создал обработчик запроса webSocket().

На данный момент, когда я пытаюсь просмотреть страницу, я получаю следующую ошибку от игры:

[error] play - Waiting for a promise, but got an error: null
java.lang.RuntimeException: null
    at play.libs.F$Promise$2.apply(F.java:113) ~[play_2.9.1.jar:2.0.1]
    at akka.dispatch.Future$$anonfun$map$1.liftedTree3$1(Future.scala:625) ~[akka-actor.jar:2.0.1]
    at akka.dispatch.Future$$anonfun$map$1.apply(Future.scala:624) ~[akka-actor.jar:2.0.1]
    at akka.dispatch.Future$$anonfun$map$1.apply(Future.scala:621) ~[akka-actor.jar:2.0.1]
    at akka.dispatch.DefaultPromise.akka$dispatch$DefaultPromise$$notifyCompleted(Future.scala:943) [akka-actor.jar:2.0.1]
    at akka.dispatch.DefaultPromise$$anonfun$tryComplete$1$$anonfun$apply$mcV$sp$4.apply(Future.scala:920) [akka-actor.jar:2.0.1]

Это происходит в return ok(views.html.index.render(mainPage));. Комментирование сценария из HTML-файла решает эту проблему, но, конечно, WebSocket не откроется.

Можно ли совмещать использование Promise и WebSocket в Play? Может быть, я скучаю по нему?


java websocket promise playframework playframework-2.0
person Aviel    schedule 24.08.2013    source источник
comment
Что произойдет, если вы используете жестко заданное значение пути в new WS()?   -  person Salem    schedule 24.04.2014

Ответы (1)


arrow_upward
1
arrow_downward

Я не верю, что вы можете использовать обещание с веб-сокетом. Однако вы можете использовать Akka для выполнения задачи в фоновом режиме. Например, следующий код должен позволить Akka выполнять более длительную операцию (запрос к базе данных) в фоновом режиме:

public static WebSocket<String> webSocket() {
    return new WebSocket<String>() {
        public void onReady(final WebSocket.In<String> in, final WebSocket.Out<String> out) {
            in.onMessage(new F.Callback<String>() {
                public void invoke(String event) {
                    Akka.system().scheduler().scheduleOnce(
                            Duration.Zero(),
                            new Runnable() {
                                public void run() {
                                    String result = foo(event);
                                    out.write(result);
                                }
                            },
                            Akka.system().dispatcher()
                    );
                }
            });
            //Handle in.onClose();
        }
    };
}
person jdroot    schedule 25.06.2014