Play Framework 2.5.4异步Hibernate操作

Question

如何使用Akka在使用Hibernate的db上执行操作而不阻塞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));
}

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

@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");
}

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

谢谢！

尝试使用：

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));

我得到了同样的错误。

Answer 1

@Transactional注释位于同步方法上。我想您需要一个异步块内的事务。您可以使用for 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用于只读操作（在您的例子中）。