Play Framework - 是不是可以在 Play 中结合使用 Promise 和 WebSocket？

Posted 2023-02-16

【中文标题】Play Framework - 是不是可以在 Play 中结合使用 Promise 和 WebSocket？

【英文标题】：Play Framework - Is it possible to combine use of Promise and WebSocket in Play?Play Framework - 是否可以在 Play 中结合使用 Promise 和 WebSocket？

【发布时间】：2013-08-24 16:49:01

【问题描述】：

我正在使用带有 Java 的 Play 2.0.1。 到目前为止，我已经使用 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 使用从数据库中检索到的新/修改信息来更新页面。 所以我使用 Chat 示例来做到这一点（甚至简化，因为我只想使用传出通道：服务器到客户端）。我在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。

可以在 Play 中结合使用 Promise 和 WebSocket 吗？也许我错过了使用它？

【问题讨论】：

如果在new WS() 中使用路径的“硬编码”值会怎样？

【参考方案1】：

我不相信你可以使用 web socket 的 promise。但是，您可以使用 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();
        
    ;