Quarkus中处理超时/延迟事件的最佳实现方式是什么

你的业务场景完全可以通过Quarkus底层依赖的Vert.x事件总线+定时器能力实现，以下是可直接落地的实现步骤：

前置依赖 #

首先在pom.xml中引入必要依赖：

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-vertx</artifactId>
</dependency>
<!-- 若使用响应式REST客户端可额外引入 -->
<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-rest-client-reactive</artifactId>
</dependency>

核心实现逻辑 #

1. 基本原理 #

调用外部REST接口前注册一个指定延迟的定时器，定时器触发时发送超时事件；如果在延迟时间内拿到REST接口响应，直接取消该定时器，超时事件就不会触发，两种场景最终都会进入下一流程。

2. 完整代码示例 #

import io.quarkus.vertx.ConsumeEvent;
import io.vertx.core.Vertx;
import jakarta.inject.Inject;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import org.eclipse.microprofile.rest.client.inject.RestClient;
import java.util.UUID;

@Path("/business")
public class BusinessProcessService {

    @Inject
    Vertx vertx;
    @RestClient
    ExternalRemoteService externalRemoteService;
    // 自定义超时事件的监听地址
    private static final String TIMEOUT_EVENT_TOPIC = "business:process-timeout";
    // 超时阈值，单位毫秒，示例为3秒，可通过配置文件注入
    private static final long PROCESS_TIMEOUT_MS = 3000L;

    @GET
    @Path("/start")
    public void startBusinessProcess() {
        // 生成当前流程唯一标识，可传递到后续流程做链路追踪
        String requestId = UUID.randomUUID().toString();
        
        // 注册超时定时器，返回的timerId用于后续取消操作
        long timeoutTimerId = vertx.setTimer(PROCESS_TIMEOUT_MS, timer -> {
            // 定时器触发说明超时，发送超时事件
            vertx.eventBus().send(TIMEOUT_EVENT_TOPIC, requestId);
        });

        // 异步调用外部REST服务，避免阻塞IO线程
        externalRemoteService.getRemoteResponse()
            .onItem().invoke(remoteResp -> {
                // 提前拿到响应，先取消超时定时器
                vertx.cancelTimer(timeoutTimerId);
                // 执行正常流程的下一环节
                runNextProcess(requestId, remoteResp);
            })
            .onFailure().invoke(err -> {
                // 调用报错也取消定时器，按需处理异常后进入下一环节
                vertx.cancelTimer(timeoutTimerId);
                runNextProcess(requestId, null);
            });
    }

    // 超时事件消费者，仅超时未取消定时器时触发
    @ConsumeEvent(TIMEOUT_EVENT_TOPIC)
    public void handleProcessTimeout(String requestId) {
        // 超时场景直接进入下一流程，无需校验REST调用结果
        runNextProcess(requestId, null);
    }

    /**
     * 下一流程统一入口，兼容正常返回和超时场景
     * @param requestId 流程唯一标识
     * @param remoteResp REST接口返回结果，超时场景为null
     */
    private void runNextProcess(String requestId, Object remoteResp) {
        // 你的下一环节业务逻辑
    }
}

注意事项 #

• 本方案默认适用于单机场景，如果是分布式集群部署，建议替换为消息队列（Kafka、RabbitMQ）的延迟消息能力实现跨节点的超时事件控制
• 优先使用响应式REST客户端，若使用阻塞式REST客户端，需要将调用逻辑提交到Worker线程池执行，避免阻塞Event Loop线程
• 超时阈值建议配置在配置文件中，通过@ConfigProperty注入，不需要硬编码

轻量替代方案（无事件总线需求可选） #

如果不需要复杂的事件管控，直接使用SmallRye Fault Tolerance提供的@Timeout注解实现更简单：

import org.eclipse.microprofile.faulttolerance.Timeout;
import java.time.temporal.ChronoUnit;

@Timeout(value = 3, unit = ChronoUnit.SECONDS)
public Uni<Object> callRemoteWithTimeout() {
    return externalRemoteService.getRemoteResponse();
}

调用时捕获超时异常，无论正常返回还是超时都进入下一流程即可。

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