放心测试 IO 线程中的反应性夸克阻塞

Question

我有一个quarkus应用程序，我正在尝试使用Restasured进行测试，但在测试时出现了以下错误：

[org.jbo.res.rea.ser.cor.Runtime ExceptionMapper]（vert. x-事件循环线程-1）IO线程上发生阻塞操作。这可能意味着您需要使用@io.smallrye.common.annotation.块来注释my.package.MyContler#更新（类my.package.My请求Dto）。或者，您可以注释类my.package.我的控制器，使类上的每个方法都阻塞，或者注释javax.ws.rs.core.应用程序类的子类，使整个应用程序阻塞

如果我运行这个应用程序并使用postman手动测试，这似乎不会发生，所以这似乎是一个测试设置的问题。

我的测试如下：

@QuarkusTest
public class MyTest {
  @Test
  @TestReactiveTransaction
  public void test_A() {
              Response response = given()
                      .when()
                      .accept(MediaTypes.JSON_TYPE)
                      .contentType(MediaTypes.JSON_TYPE)
                      .body("{myRequestJsonHere}")
                      .patch("/path/to/api")
                      .then()
                      .extract().response();
      // asserts

  }
}

控制器内部：

@Path("/path/to/api")
@ApplicationScoped
public class MyController{
  @Inject MyService service;

  @PATCH
  public Uni<MyResultType> update(@NotNull @RequestBody @Valid MyRequestDto request) {
     return service.update(request);
  }
}

我的服务：

@ApplicationScoped
public class MyService {
  @Inject MyRepository repository;

  @Transactional
  public Uni<MyResultType> update(MyRequestDto request) {
    return repository.findAll().firstResult()
       .onItem().transform(l -> mapping here))
       .flatMap(repository::persistAndFlush);
  }
}

我的存储库：

public interface MyRepository extends PanacheRepository<MyResultType> {
}

我也尝试将完整的测试内容包装在UniAsserter.execute（（） -

我是否需要进行更多设置以确保正确使用线程？




Answer 1

我相信，当您进行一次数据库访问时，您的线程应该被定义为阻塞。

正如您的错误消息所说，您可以在方法或类上包含一个@Blocking注释。

Quarkus 关于阻塞线程的指南 使用 RESTEASY 反应编写 REST 服务

我猜你的班级可能是这样的：

import io.smallrye.common.annotation.Blocking;

@Path("/path/to/api")
@ApplicationScoped
public class MyController{
  @Inject MyService service;

  @Blocking
  @PATCH
  public Uni<MyResultType> update(@NotNull @RequestBody @Valid MyRequestDto request) {
     return service.update(request);
  }
}

Answer 2

匿名用户

< code>@Transactional不适用于Reactive Panache或Hibernate Reactive。您可以使用< code > @ react ivetransactional 或< code > panache . with transaction 。

您不应该使用< code > @ TestReactiveTransactional 进行测试。您正在模拟Rest调用，没有理由打开事务。我认为正在发生的事情是，您正在启动一个反应式事务，然后RestAssure将调用REST API并阻塞客户端，直到收到结果。我怀疑这是导致问题的原因。

您可以将测试的代码更改为：

@QuarkusTest
public class MyTest {

  @Test
  public void test_A() {
              Response response = given()
                      .when()
                      .accept(MediaTypes.JSON_TYPE)
                      .contentType(MediaTypes.JSON_TYPE)
                      .body("{myRequestJsonHere}")
                      .patch("/path/to/api")
                      .then()
                      .extract().response();
  }
}

服务变成：

@ApplicationScoped
public class MyService {
  @Inject MyRepository repository;

  @ReactiveTransactional
  public Uni<MyResultType> update(MyRequestDto request) {
    return repository
       .findAll()
       .firstResult()
       .map(l -> /* update the entity... */ );
  }
}

只有在创建新实体时才需要持久化。如果需要，可以将其添加回去。