Quarkus中Vertx executeBlocking缺失currentContext及MDC使用问题

问题分析 #

你在Quarkus启动事件中调用Vertx.executeBlocking()时遇到两个核心问题：

1. 调用getOrCreateContext().executeBlocking()后，Vertx.currentContext()返回null——因为getOrCreateContext()创建的上下文并未绑定到executeBlocking使用的工作线程上，工作线程默认不会关联任何Vertx上下文。
2. 即使直接使用_vertx.executeBlocking()，JBoss MDC的操作会被VertxMDC桥接至"null context"映射——VertxMDC依赖Vertx上下文来存储MDC数据，没有绑定上下文的工作线程无法正确维护MDC的隔离与传递。

解决方案 #

1. 手动绑定Vertx上下文到阻塞线程 #

通过Context.push()方法将Vertx上下文绑定到工作线程，利用try-with-resources自动解绑，避免线程污染：

void onStart(@Observes StartupEvent ev) {
    for (String tenantId : _coreStore.listTenants()) {
        Context vertxContext = _vertx.getOrCreateContext();
        _vertx.executeBlocking(() -> {
            // 绑定上下文到当前线程，自动关闭时解绑
            try (AutoCloseable contextHolder = vertxContext.push()) {
                MDC.put("tenant-id", tenantId);         
                startGateways(tenantId);         
                return null;
            } catch (Exception e) {
                throw new RuntimeException("初始化网关失败", e);
            }
        });
    }
}

这样Vertx.currentContext()会返回绑定的上下文，VertxMDC就能正确关联MDC数据到该上下文。

2. 使用Quarkus Vertx上下文工具类 #

利用Quarkus提供的VertxContextSupport，确保任务在Vertx上下文环境中发起，再切换到阻塞线程：

import io.quarkus.vertx.core.runtime.VertxContextSupport;

void onStart(@Observes StartupEvent ev) {
    for (String tenantId : _coreStore.listTenants()) {
        // 确保在Vertx上下文环境中发起阻塞任务，同步等待完成
        VertxContextSupport.subscribeAndAwait(() -> 
            _vertx.executeBlocking(() -> {
                MDC.put("tenant-id", tenantId);         
                startGateways(tenantId);         
                return null;
            })
        );
    }
}

subscribeAndAwait会等待阻塞任务完成，适合启动阶段需要同步初始化的场景。

3. 切换到Quarkus官方MDC扩展 #

Quarkus提供了quarkus-logging-mdc扩展，自动处理Vertx事件循环与工作线程间的MDC传递，无需手动绑定上下文：

1. 添加依赖（pom.xml）：

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-logging-mdc</artifactId>
</dependency>

2. 使用Quarkus的MDC类：

import io.quarkus.logging.mdc.MDC;

void onStart(@Observes StartupEvent ev) {
    for (String tenantId : _coreStore.listTenants()) {
        _vertx.executeBlocking(() -> {
            MDC.put("tenant-id", tenantId);         
            startGateways(tenantId);         
            return null;
        });
    }
}

该扩展会自动在工作线程中关联MDC数据，无需手动处理Vertx上下文。

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