Playframework websocket從服務器到瀏覽器的實時流式傳輸

Question

我正在嘗試使用playframework不斷地將數據從web服務器傳輸到瀏覽器。我創建從例如documentation

這裏基於一個示例代碼是代碼段我有

public static WebSocket<String> sockHandler() { 
    return new WebSocket<String>() { 
     // called when the websocket is established 
     public void onReady(WebSocket.In<String> in, final WebSocket.Out<String> out) { 
      // register a callback for processing instream events 
      in.onMessage(new F.Callback<String>() { 
       public void invoke(String event) { 
        Logger.info(event); 
       } 
      }); 


      int i = 0; 
      while(i<20){ 
       Logger.info("Sending message "); 
       try{ 
        Thread.sleep(1000); 
       }catch (Exception e){ 
        Logger.error("Exception " ,e); 
       } 

       out.write("Sending message " + i++ + "\n"); 

      } 
     } 
    }; 
} 

在瀏覽器中，寫入了信息不立即在每次迭代之後接收。在循環完成後，瀏覽器會立即收到消息。

是否有一種方法可以在每次迭代後清除流？或者是否有更好的示例/文檔來將實時數據從websocket服務器傳輸到瀏覽器..？

謝謝， 拉賈。

Answer 1

我強烈建議你看看this sample。

它使用Websockets和Akka actors。演員系統不是很難理解，Akka documentation是一個很好的開始！