Vertx多测试类共享服务执行冻结问题及优化方案咨询

问题原因 #

批量运行测试时出现冻结的核心原因是JUnit 4中父类的静态成员会被所有子类共享：

• BaseTest中的contextRule是静态ClassRule，所有继承它的测试类会共用同一个RunTestOnContext实例，也就是同一个Vertx实例。
• 第一个测试类执行@AfterClass时调用vertx.close()关闭了Vertx实例；第二个测试类执行@BeforeClass时，尝试在已关闭的Vertx上部署Verticle，异步部署操作永远无法完成，导致测试阻塞冻结。
• 配置的Timeout规则失效，是因为超时检测依赖Vertx的事件循环，而Vertx已经关闭，事件循环停止，无法触发超时逻辑。

优化方案：单例Vertx实例共享（无需多次启动Verticle） #

我们可以手动管理Vertx实例的生命周期，确保全局只初始化一次，所有测试类共享服务，最后统一关闭。

方案1：基于父类的单例初始化 #

修改BaseTest，通过原子标记控制Vertx仅初始化一次：

@RunWith(VertxUnitRunner.class)
public abstract class BaseTest {
    private static final AtomicBoolean initialized = new AtomicBoolean(false);
    private static Vertx vertx;
    static HelloService service;

    @ClassRule
    public static final Timeout timeout = Timeout.seconds(2);

    @BeforeClass
    public static void setupClass(TestContext context) {
        if(initialized.compareAndSet(false, true)) {
            // 仅第一次初始化时创建Vertx并部署Verticle
            vertx = Vertx.vertx();
            vertx.exceptionHandler(context.exceptionHandler());
            vertx.deployVerticle(new HelloVerticle(), context.asyncAssertSuccess(result -> {
                Assertions.assertThat(result).isNotBlank();
            }));
            service = HelloService.createProxy(vertx, VERTX_HELLO_SERVICE);
        } else {
            // 后续测试类复用已初始化的Vertx
            vertx.exceptionHandler(context.exceptionHandler());
        }
    }

    @AfterClass
    public static void teardownClass(TestContext context) {
        // 仅当所有测试执行完成后关闭Vertx，可结合JUnit Suite实现更严谨的全局清理
    }
}

方案2：基于JUnit Suite的全局生命周期管理（更严谨） #

通过Suite类统一控制Vertx的启动与关闭，确保所有测试共享同一个服务实例：

1. 创建全局测试Suite类：

@RunWith(Suite.class)
@Suite.SuiteClasses({HelloTest.class, Hello2Test.class})
public class AllTests {
    private static Vertx vertx;
    private static HelloService service;

    @BeforeClass
    public static void setupGlobal(TestContext context) {
        vertx = Vertx.vertx();
        vertx.exceptionHandler(context.exceptionHandler());
        vertx.deployVerticle(new HelloVerticle(), context.asyncAssertSuccess(result -> {
            Assertions.assertThat(result).isNotBlank();
        }));
        service = HelloService.createProxy(vertx, VERTX_HELLO_SERVICE);
    }

    @AfterClass
    public static void teardownGlobal(TestContext context) {
        vertx.close(context.asyncAssertSuccess());
    }

    // 提供静态方法供测试类获取共享服务
    public static HelloService getHelloService() {
        return service;
    }
}

2. 修改测试类，直接从Suite获取服务：

@RunWith(VertxUnitRunner.class)
public class HelloTest {
    @ClassRule
    public static final Timeout timeout = Timeout.seconds(2);

    @Test
    public void test(TestContext context) {
        HelloService service = AllTests.getHelloService();
        service.hello("John", context.asyncAssertSuccess(r -> {
           assertThat(r).isEqualTo("Hello John");
        }));
    }
}

这种方式可以确保Vertx和Verticle只启动一次，所有测试类共享服务，并且在所有测试完成后统一关闭，彻底解决批量运行时的冻结问题。

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