在 Java 中将 CompletionStage 合并到 play framework 动作中

Question

我尝试在游戏框架中结合 CompletionStages，然后 return 像 ok() 这样的结果。这是我的设置：

AccountDao 有两个方法:

public CompletionStage<Account> getUserByEmail(String email) {
    return supplyAsync(() -> ebeanServer.find(Account.class).setUseCache(true).where().eq(EMAIL, email).findOne(), executionContext).thenApply(account -> {
        return account;
    });
}

public CompletionStage<Void> updateAccount(Account account) throws OptimisticLockException{
    return runAsync(() -> {
        ebeanServer.update(account);
    }, executionContext);
}

然后我让我的控制器执行以下操作：

public CompletionStage<Result> editAccount() {
    Map<String, String[]> form_values = request().body().asFormUrlEncoded();
    return CompletableFuture.completedFuture(ok());
}

所以现在在操作中我想首先执行 getUserByEmail 然后我想设置一些值并使用 updateAccount 方法更新它。我如何在不阻塞播放上下文的情况下将这两个阶段结合起来？我用 thenCompose 和 combine 尝试了不同的设置，但我不明白......

这是我的尝试之一：

public CompletionStage<Result> editAccount() {
    Map<String, String[]> form_values = request().body().asFormUrlEncoded();
    accountDao.getUserByEmail(session().get("accountEmail")).thenCompose(x -> accountDao.updateAccount(x).thenApplyAsync(account -> {
        return ok("Going to save account edits");
    }, httpExecutionContext.current()));
    return CompletableFuture.completedFuture(ok("Fehler am Ende"));
}

这里的问题是，我无法访问之前的帐户 (x)，因为我无法将其设置为功能...像这样：

public CompletionStage<Result> editAccount() {
    Map<String, String[]> form_values = request().body().asFormUrlEncoded();
    accountDao.getUserByEmail(session().get("accountEmail")).thenCompose(x -> {
        //Update vars in x and then save to database
        accountDao.updateAccount(x);
    }.thenApplyAsync(account -> {
        return ok("Going to save account edits");
    }, httpExecutionContext.current()));
    return CompletableFuture.completedFuture(ok("Fehler am Ende"));
}

这里我得到错误：这个表达式的目标类型必须是一个函数式接口并且播放说我必须在函数末尾包含 return 语句！

我就是不明白...谢谢你的帮助！

@Marimuthu Madasamy 那不是我想要的。在您的 awnser 中，我会更新帐户两次。在 accountDao.updateAccount(account) 和 accountDao.saveAccount(account) 中的 etime；我想要这样的东西：

return accountDao.getUserByEmail("mail").thenCompose(account -> {
       account.setName("NewName");
       accountDao.save(account);
    } .thenApplyAsync(voidInput -> {
        return ok("Account saved");
    }, httpExecutionContext.current()));

在这种情况下，仅更新一次帐户并且仅return httpExecutionContext

上的结果

Answer 1

如果我对你的问题的理解正确，你想在 updateAccount(account) 方法调用后访问（保存？）帐户。

由于 updateAccount 方法 returns CompletionStage<Void>，当您在此阶段调用 thenApplyAsync 时，输入类型只会是 Void 而不是 Account。但是使用以下代码，假设 updateAccount 通过您的文本 "update vars in x":

改变帐户，您仍然可以访问从 getUserByEmail 返回的帐户

public CompletionStage<Result> editAccount() {
    return accountDao
            .getUserByEmail(email)
            .thenCompose(account -> accountDao.updateAccount(account)
                    .thenApplyAsync(voidInput -> {
                        // here you still have access to the `account` from `getUserByEmail` method
                        accountDao.saveAccount(account);
                        return ok("Account saved");
                    }, httpExecutionContext.current());
}

Answer 2

好的，在 Marimuthu Madasamy 的支持下，我在这里找到了自己的遮阳棚！谢谢。我试着解释一下。首先是代码：

public CompletionStage<Result> editAccount() {
    Map<String, String[]> form_values = request().body().asFormUrlEncoded();
    return accountDao.getUserByEmail(session().get("accountEmail")).thenApply(account -> {
        System.out.println("Async get Account / "+Thread.currentThread());
        account.setCompany(form_values.get("company")[0]);
        return accountDao.updateAccount(account);
    }).thenApplyAsync(account -> {
        System.out.println("Async resutl / "+Thread.currentThread());
        return ok("Account saved normal");
    }, httpExecutionContext.current()).exceptionally(e ->{
        System.out.println("Async exception / "+Thread.currentThread());
        System.out.println(e.getLocalizedMessage());
        return ok(e.getLocalizedMessage());
    });
}

好的，首先我执行 accountDao.getUserByEmail() 正如你在我的 awnser 顶部看到的这个 returns CompletionStage 并在我的数据库执行上下文中执行。接下来使用 thenApply 我得到结果并执行下一个异步方法。我使用 thenApply 代替 thenApplyAsync，因此下一次调用也使用数据库执行上下文执行，而无需显式设置。在 accountDao.updateAccount() 之后，我在 httpExecutionContext 上执行下一阶段以重播结果或异常退出！我真的希望它很清楚并能帮助一些人！

在 Java 中将 CompletionStage 合并到 play framework 动作中

Combine CompletionStage in play framework action in Java

java

database

playback

completable-future

completion-stage