2016-03-04 76 views
3

我有一個在阿卡的Websocket實現,客戶端可以發送一個簡單的請求,服務器可以回覆,但我想知道如何自發地發送一條消息從服務器到客戶端阿卡?Akka Websocket服務器推送在java

回答

1

我想通了,如何做到這一點:

首先,你需要做的ActorPublisher將郵件推送到客戶端。其次,您需要創建一個使用Source.actorPublisher(Props.create(yourActorPublisher.class))的Flow,您將創建的流傳遞給handleWebSocketMessages路由。

我們郵件推送到客戶端,您只需要發佈的ActorRef和yourActorRef.tell(yourMessage,ActorRef.noSender())

+0

達米安嗨Push消息!你能否分享完整的工作代碼?我正在嘗試做同樣的事情,但無法繼續。 –