Play Framework 2.5.4 异步休眠操作答案

【问题标题】：Play Framework 2.5.4 Async Hibernate operationsPlay Framework 2.5.4 异步休眠操作
【发布时间】：2016-12-14 08:45:24
【问题描述】：

如何使用 Akka 通过 Hibernate 对数据库执行操作而不阻塞 Web 客户端？

更新：

原来错误是由 dao.get() 方法引起的。我将 start() 方法更改为从数据库中获取一个实际对象而不是 id，现在我没有收到任何错误，但什么也没发生（正如我之前所说，它卡在 em.merge() 上）。

public CompletionStage<Result> start(SomeObject object) {
    ExecutionContext ec = Akka.system().dispatchers().lookup("akka.actor.db-context");
    return CompletableFuture.supplyAsync(() -> doStuff(object), play.libs.concurrent.HttpExecution.fromThread(ec))
            .thenApply(i -> ok("Got result: " + i));
}

过时：

如果我尝试类似：

@Transactional
public CompletionStage<Result> start(Long id) {
    ExecutionContext ec = Akka.system().dispatchers().lookup("akka.actor.db-context");
    return CompletableFuture.supplyAsync(() -> doStuff(dao.get(id)), play.libs.concurrent.HttpExecution.fromThread(ec))
            .thenApply(i -> ok("Got result: " + i));
}

doStuff 只执行 entityManager.merge()，我得到：

[CompletionException: org.hibernate.SessionException: 会话是关闭！]

或

[CompletionException: java.lang.IllegalStateException: EntityManager 已关闭]

当我使用下面的代码启动上面的过程时：

@Transactional
public Result mainMethod() {
    List<SomeObject> allObjects= dao.getAll();
    int size = allObjects.size();
    for(int i = 0; i < size; i++) {
        start(allObjects.get(i).getId());
    }
    return ok("Started");
}

然后新创建的线程（actors）在尝试数据库操作时进入无限循环。

谢谢！

完整的堆栈跟踪：

play.api.http.HttpErrorHandlerExceptions$$anon$1：执行异常[[CompletionException：org.hibernate.SessionException：会话已关闭！]] 在 play.api.http.HttpErrorHandlerExceptions$.throwableToUsefulException(HttpErrorHandler.scala:280) 在 play.api.http.DefaultHttpErrorHandler.onServerError(HttpErrorHandler.scala:206) 在 play.api.GlobalSettings$class.onError(GlobalSettings.scala:160) 在 play.api.DefaultGlobal$.onError(GlobalSettings.scala:188) 在 play.api.http.GlobalSettingsHttpErrorHandler.onServerError(HttpErrorHandler.scala:98) 在 play.core.server.netty.PlayRequestHandler$$anonfun$2$$anonfun$apply$1.applyOrElse(PlayRequestHandler.scala:100) 在 play.core.server.netty.PlayRequestHandler$$anonfun$2$$anonfun$apply$1.applyOrElse(PlayRequestHandler.scala:99) 在 scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scala:344) 在 scala.concurrent.Future$$anonfun$recoverWith$1.apply(Future.scala:343) 在 scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) 在 play.api.libs.iteratee.Execution$trampoline$.executeScheduled(Execution.scala:109) 在 play.api.libs.iteratee.Execution$trampoline$.execute(Execution.scala:71) 在 scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40) 在 scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248) 在 scala.concurrent.Promise$class.complete(Promise.scala:55) 在 scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:153) 在 scala.concurrent.java8.FuturesConvertersImpl$P.accept(FutureConvertersImpl.scala:94) 在 scala.concurrent.java8.FuturesConvertersImpl$P.accept(FutureConvertersImpl.scala:89) 在 java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) 在 java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) 在 java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 在 java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595) 在 play.core.j.HttpExecutionContext$$anon$2.run(HttpExecutionContext.scala:56) 在 akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) 在 akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:405) 在 scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 在 scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 在 scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 在 scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 引起：java.util.concurrent.CompletionException： org.hibernate.SessionException：会话已关闭！在 java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) 在 java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) 在 java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592) ...省略了7个常见的框架原因： org.hibernate.SessionException：会话已关闭！在 org.hibernate.internal.AbstractSessionImpl.errorIfClosed(AbstractSessionImpl.java:133) 在 org.hibernate.internal.SessionImpl.setCacheMode(SessionImpl.java:1455) 在 org.hibernate.jpa.spi.AbstractEntityManagerImpl.find(AbstractEntityManagerImpl.java:1144) 在 org.hibernate.jpa.spi.AbstractEntityManagerImpl.find(AbstractEntityManagerImpl.java:1068) 在 daos.dao.get(dao.java:45) 在 controllers.DemoController.lambda$start$0(DemoController.java:195) 在 java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) ...省略了7个常用框架

LE：

尝试过：

ExecutionContext ec = Akka.system().dispatchers().lookup("akka.actor.db-context");
return CompletableFuture.supplyAsync(() -> jpa.withTransaction("default", true, ()-> doStuff(dao.get(id))), play.libs.concurrent.HttpExecution.fromThread(ec))
                .thenApply(i -> ok("Got result: " + i));

我得到了同样的错误。

【问题讨论】：

也许我做错了，所以我更简单的问题是：如何使用 Play 的 Akka Actors 使非 Web 客户端阻止数据库操作？例如，启动一些更新操作，将某些字段设置为某些值，而无需让发送控制器操作的客户端等待结果（因为它与用户无关）。

标签： java hibernate playframework playframework-2.5

【解决方案1】：

我使用@asch 的建议解决了这个问题：

控制器：

    @Inject
    private JPAApi jpa;
    [...]
    return CompletableFuture.supplyAsync(() -> jpa.withTransaction("default", false, ()-> doStuff(objectDAO.get(id))), play.libs.concurrent.HttpExecution.fromThread(ec))
                .thenApply(i -> ok("Got result: " + i));

并且在doStuff方法类中：

    private static final JPAApi jpaApi = Play.current().injector().instanceOf(JPAApi.class);
    [...]
    jpaApi.withTransaction(() -> {
        EntityManager em = jpaApi.em();
        em.merge(object);
    });
    [...]

【讨论】：

【解决方案2】：

@Transactional 注释在同步方法上。我猜您需要在异步块内进行事务。您可以使用 jpa 方法 withTransaction 代替注释。它的签名（来自Play java api）

/**
 * Run a block of code in a JPA transaction.
 *
 * @param name The persistence unit name
 * @param readOnly Is the transaction read-only?
 * @param block Block of code to execute
 * @param <T> type of result
 * @return code execution result
 */
public <T> T withTransaction(String name, boolean readOnly, Supplier<T> block);

应该是这样的：

在控制器中注入 JPAApi：
```
@Inject
JPAApi jpa;
```

通过调用 jpa 实现异步执行器：

 jpa.withTransaction("default", true, ()->doStuff(dao.get(id)), play.libs.concurrent.HttpExecution.fromThread(ec))
    .thenApply(i -> ok("Got result: " + i)));

注意 withTransaction 调用中的第二个参数 true 用于只读操作（在您的情况下）。

将 DAO 类更改为也使用注入的 JPAAPi。

【讨论】：

嗨，我找不到任何带有该签名的“withTransaction”方法。
我编辑了答案 - 添加了 API 文档的签名和链接。我在我的项目中使用这种方法，只是我同步执行。我更喜欢它而不是 @Transactional 注释（不要忘记删除它！）。
您是否删除了两个 @Transactional 注释（您的 sn-ps 中有 2 个）。可能 JPA 应该被注入到异步方法本身的范围内。
是的，我确实删除了注释。我将尝试不同的注射并在此处发布结果。谢谢。
我尝试了不同的方法，比如将 JPAApi 作为参数发送到方法，将方法移动到另一个类并为每个进程创建一个新实例 + 注入 JPAApi 等，但我仍然得到同样的错误。