Quarkus 3.0.0.CR2中Hibernate Reactive Panache仓库模式查询报错求助

错误原因 #

1. Session/EntityManager is closed #

核心问题是Hibernate Reactive会话生命周期未覆盖完整响应式操作链。Quarkus中Hibernate Reactive会话绑定到请求上下文，若异步流还在处理时请求上下文提前销毁（比如并发操作导致会话被提前释放、上下文传播失效），就会触发该异常。你的场景中多次发起响应式查询，若未通过flatMap等链式调用管理异步流，而是并行执行多个Uni，会导致会话被其中某个操作提前关闭，剩余操作访问已关闭的会话。

2. NoSuchElementException #

该异常通常出现在使用single()、first()这类要求返回非空结果的操作时，查询未找到匹配数据但代码未处理空值场景。在你的随机报错场景中，大概率是会话提前关闭导致查询结果流中断，或是并发情况下数据未及时提交，使得查询返回空结果，而代码直接调用了期望非空的操作方法。

解决方案 #

1. 确保响应式操作的上下文与会话传播正确 #

• 所有响应式查询必须通过flatMap链式调用，而非并行执行多个Uni。Hibernate Reactive会话并非线程安全，并行操作会导致会话状态紊乱。示例：

  // 错误：并行执行多个查询
  Uni<List<Animal>> uni1 = animalRepo.findByOwnerName(name);
  Uni<List<Animal>> uni2 = animalRepo.findByOwnerAge(age);
  Uni.combine().all().unis(uni1, uni2).combinedWith(...);
  
  // 正确：链式调用确保会话上下文连续
  animalRepo.findByOwnerName(name)
      .flatMap(animals -> animalRepo.findByOwnerAge(age)
          .map(ageAnimals -> {
              animals.addAll(ageAnimals);
              return animals;
          })
      );
  

• 在仓库或服务方法上添加@WithSession（Panache专用）或@ReactiveTransactional注解，强制会话在整个响应式流中保持活跃。

2. 处理空结果场景，避免强制非空操作 #

将所有期望返回单个结果的查询，从single()改为optional()或singleResult().ifPresent(...)，显式处理空值情况：

// 错误：无空值处理
return ownerRepo.find("name", name).single();

// 正确：处理空值
return ownerRepo.find("name", name).singleResult()
    .onItem().ifNull().failWith(() -> new NotFoundException("Owner not found"));

3. 确保使用响应式事务注解 #

替换普通的@Transactional为@ReactiveTransactional，确保事务在响应式流中正确管理，避免事务提前提交导致会话关闭：

@ReactiveTransactional
public Uni<List<Animal>> getOwnerAnimals(String ownerName) {
    return ownerRepo.find("name", ownerName).singleResult()
        .flatMap(owner -> animalRepo.find("owner", owner).list())
        .flatMap(animals -> animalRepo.find("owner.age", owner.getAge()).list()
            .map(ageAnimals -> {
                animals.addAll(ageAnimals);
                return animals;
            })
        );
}

4. 单元测试的响应式上下文处理 #

确保测试方法返回Uni类型，Quarkus测试框架会自动处理异步操作的上下文：

@Test
public Uni<Void> testOwnerAnimals() {
    return animalService.getOwnerAnimals("Melani")
        .onItem().invoke(animals -> assertNotNull(animals))
        .replaceWithVoid();
}

内容的提问来源于stack exchange，提问作者Luka Juršnik