不同线程上的Quarkus事务

Question

我有一个带有异步endpoint的quarkus应用程序，它创建一个具有默认属性的实体，在request方法中启动一个新线程，并执行一个长期运行的作业，然后返回该实体作为响应供客户端跟踪。

@POST
@Transactional
public Response startJob(@NonNull JsonObject request) {
        // create my entity
        JobsRecord job = new JobsRecord();
        // set default properties
        job.setName(request.getString("name"));

        // make persistent
        jobsRepository.persist(job);
        
        // start the long running job on a different thread
        Executor.execute(() -> longRunning(job));

        return Response.accepted().entity(job).build();
    }

此外，长时间运行的作业将在实体运行时对其进行更新，因此它也必须是事务性的。但是，数据库实体没有得到更新。

这些是我面临的问题：

1. 收到以下警告:

ARJUNA012094: Commit of action id 0:ffffc0a80065:f2db:5ef4e1c7:0 invoked while multiple threads active within it.
ARJUNA012107: CheckedAction::check - atomic action 0:ffffc0a80065:f2db:5ef4e1c7:0 commiting with 2 threads active!

我尝试使用@transaction(value=txtype.requires_new)但没有用。

我尝试在longrunning上使用API方法，而不是在指南中提到的@transactional方法，如下所示：

@Inject UserTransaction transaction;
.
.
.
try {
    transaction.begin();
    jobsRecord.setStatus("Complete");
    jobsRecord.setCompletedOn(new Timestamp(System.currentTimeMillis()));
    transaction.commit();
} catch (Exception e) {
    e.printStackTrace();
    transaction.rollback();
}

但随后出现错误:ARJUNA016051:线程已与事务关联！和ARJUNA016079:事务回滚状态为:ActionStatus.Committed

我再次尝试了声明性方法和基于API的方法，这次启用了上下文传播。但还是没有运气。

最后，基于第三种方法，我认为在Http请求处理程序上保留@transactional并保持longrunning不使用声明性或基于API的事务方法是可行的。但是，数据库仍然没有得到更新。

显然，我误解了JTA和上下文传播的工作原理（以及其他方面）。

有没有一种方法（甚至设计模式）可以让我在quarkus web应用程序中异步更新数据库实体？还有，为什么我采取的任何方法都没有效果呢？

使用quarkus 1.4.1.final,ext：[agroal,cdi,flyway,hibernate-orm,hibernate-orm,panache,hibernate-validator,kubernetes-client,mutiny,narayana-jta,rest-client,resteasy,resteasy-jackson,resteasy-mutiny,smallrye-context-propagation,smallrye-health,smallrye-openapi,swagger-ui]

Answer 1

您应该从您的JAX-RS资源方法返回一个异步类型，然后事务上下文将在异步阶段执行时可用。在quarkus指南中有一些关于上下文传播的相关文档。

首先，我会看一个反应性的例子，比如入门快速入门。尝试用@transactional注释每个资源endpoint，异步代码将与事务上下文一起运行。