Quarkus响应式POST接口异步持久化报Session is closed错误如何解决

你遇到的HR000060: Session is closed错误核心是Hibernate Reactive的会话生命周期和请求上下文绑定导致的：
Reactive Panache默认使用的Hibernate会话和当前HTTP请求的上下文绑定，当接口方法返回响应后，请求上下文会被立即销毁，绑定的会话也会同步关闭。你在代码中直接对持久化的Uni执行subscribe()后立刻返回202响应，后台异步执行的持久化逻辑实际运行时，对应的会话已经被关闭，因此抛出会话已关闭的异常。

以下是两种可直接落地的实现方案：

方案1：手动管理独立会话（最稳妥） #

直接注入Mutiny.SessionFactory手动开启独立于请求上下文的会话和事务，生命周期自主管控，不受请求结束影响：
首先注入会话工厂：

@Inject
Mutiny.SessionFactory sessionFactory;

调整接口实现：

@POST
public Uni<Response> createInBackground(Fruit fruit) {
    // 开启独立会话执行持久化，不受请求上下文生命周期限制
    sessionFactory.withTransaction((session, tx) -> session.persist(fruit))
        .subscribe().with(
            unused -> LOG.log(Level.INFO, "Fruit saved successfully!"),
            // 必须添加失败回调，否则后台持久化异常无法感知
            failure -> LOG.log(Level.SEVERE, "Fruit save failed", failure)
        );
    return Uni.createFrom().item(Response.accepted().build());
}

方案2：抽取独立事务方法 #

将持久化逻辑抽取到独立的Bean中，通过事务注解生成代理来管控独立事务：

1. 新建独立存储Bean

@ApplicationScoped
public class FruitService {
    // 该注解会为方法开启独立的事务和会话
    @WithTransaction
    public Uni<Void> asyncSaveFruit(Fruit fruit) {
        return fruit.persist();
    }
}

2. 调整接口实现

@Inject
FruitService fruitService;

@POST
public Uni<Response> createInBackground(Fruit fruit) {
    fruitService.asyncSaveFruit(fruit)
        .subscribe().with(
            unused -> LOG.log(Level.INFO, "Fruit saved successfully!"),
            failure -> LOG.log(Level.SEVERE, "Fruit save failed", failure)
        );
    return Uni.createFrom().item(Response.accepted().build());
}

• 如果业务对持久化可靠性要求高，不建议直接使用内存异步的方案，服务重启或异常退出时未执行的持久化任务会丢失，可结合本地消息表、MQ队列等组件实现高可靠异步持久化。
• 所有异步订阅逻辑必须添加异常处理回调，避免后台任务失败无感知导致的数据丢失。

内容的提问来源于stack exchange，提问作者quarkus_coder