我有一個處理 WebSocket 請求的 Play 應用程序。路由文件包含這一行：GET /testsocket controllers.HomeController.defaultRoomSocket一個已經工作的同步版本如下所示：（改編自 2.7.x 文檔）public WebSocket defaultRoomSocket() { return WebSocket.Text.accept( request -> ActorFlow.actorRef(MyWebSocketActor::props, actorSystem, materializer)); }如https://www.playframework.com/documentation/2.7.x/JavaWebSockets#Accepting-a-WebSocket-asynchronously所述，我將簽名更改為public CompletionStage<WebSocket> defaultRoomSocket(){ //returning a CompletionStage here, using the "ask pattern" //to get the needed Flow from an other Actor}從這里我遇到了以下問題：Cannot use a method returning java.util.concurrent.CompletionStage[play.mvc.WebSocket] as a Handler for requests此外，正如文檔所建議的那樣，“WebSocket”沒有類型參數。接受 WebSocket 請求異步的合適方法是什么？
1 回答
翻翻過去那場雪
TA貢獻2065條經驗 獲得超14個贊
文檔確實需要更新，我認為在#5055 的websockets 重構中遺漏了一些位。
要獲得異步處理，您應該使用acceptOrResult以 aCompletionStage作為返回類型而不是流的方法。然后可以使用函數式編程助手 ( ) 返回 aResult或 Akka?。事實上，下面是該方法的實現方式：FlowF.Eitheraccept
public?WebSocket?accept(Function<Http.RequestHeader,?Flow<In,?Out,??>>?f)?{?
??return?acceptOrResult(
???????request?->?CompletableFuture.completedFuture(F.Either.Right(f.apply(request))));
}如您所見，它所做的只是調用帶有completedFuture.
為了完全使其異步并達到我認為你想要實現的目標，你會做這樣的事情：
public WebSocket ws() {
? ? return WebSocket.Json.acceptOrResult(request -> {
? ? ? ? if (sameOriginCheck(request)) {
? ? ? ? ? ? final CompletionStage<Flow<JsonNode, JsonNode, NotUsed>> future = wsFutureFlow(request);
? ? ? ? ? ? final CompletionStage<Either<Result, Flow<JsonNode, JsonNode, ?>>> stage = future.thenApply(Either::Right);
? ? ? ? ? ? return stage.exceptionally(this::logException);
? ? ? ? } else {
? ? ? ? ? ? return forbiddenResult();
? ? ? ? }
? ? });
}
@SuppressWarnings("unchecked")
private CompletionStage<Flow<JsonNode, JsonNode, NotUsed>> wsFutureFlow(Http.RequestHeader request) {
? ? long id = request.asScala().id();
? ? UserParentActor.Create create = new UserParentActor.Create(Long.toString(id));
? ? return ask(userParentActor, create, t).thenApply((Object flow) -> {
? ? ? ? final Flow<JsonNode, JsonNode, NotUsed> f = (Flow<JsonNode, JsonNode, NotUsed>) flow;
? ? ? ? return f.named("websocket");
? ? });
}
private CompletionStage<Either<Result, Flow<JsonNode, JsonNode, ?>>> forbiddenResult() {
? ? final Result forbidden = Results.forbidden("forbidden");
? ? final Either<Result, Flow<JsonNode, JsonNode, ?>> left = Either.Left(forbidden);
? ? return CompletableFuture.completedFuture(left);
}
private Either<Result, Flow<JsonNode, JsonNode, ?>> logException(Throwable throwable) {
? ? logger.error("Cannot create websocket", throwable);
? ? Result result = Results.internalServerError("error");
? ? return Either.Left(result);
}
（這取自play-java-websocket-example，這可能很有趣）
如您所見，它首先經過幾個階段，然后返回 websocket 連接或 HTTP 狀態。
添加回答
舉報
0/150
提交
取消