Quarkus REST服务后台执行长任务无阻塞方案求助

你的核心需求是实现REST接口返回响应后，异步执行耗时任务且不阻塞请求链路，以下是针对你代码问题的修复方案和最佳实践：

方案一：使用@ConsumeEvent(blocking = true)处理阻塞任务 #

如果daoBooking.markSeatsAsPrinted是阻塞式调用，最直接的方式是给消费事件的方法添加blocking=true注解，让Quarkus自动将任务提交到worker线程池执行，无需手动处理Uni订阅：

import io.quarkus.vertx.ConsumeEvent;
import org.jboss.logging.Logger;

@ApplicationScoped
public class TestResource {
    private static final Logger LOG = Logger.getLogger(TestResource.class);

    @Inject
    private DaoBooking daoBooking;

    // 添加blocking=true，让Quarkus用worker线程执行阻塞任务
    @ConsumeEvent(value = "greeting", blocking = true)
    public void markSeatsAsPrinted(String bookingId) {
        LOG.info("Received markSeatsAsPrinted event");
        LOG.info("Start long running mark tickets as printed job");
        try {
            daoBooking.markSeatsAsPrinted(bookingId);
        } catch (FileMakerException e) {
            LOG.error("Failed to mark seats as printed for booking: " + bookingId, e);
        }
        LOG.info("End long running mark tickets as printed job");
    }
}

为什么这能解决问题：

• blocking=true告诉Quarkus该事件处理是阻塞的，会将任务分配到专门的worker线程池，不会占用Vert.x的EventLoop线程（该线程负责处理REST请求响应）。
• eventBus.requestAndForget发送消息后立即返回，REST接口无需等待任务完成即可返回PdfTicket。

方案二：在void消费方法中正确订阅Uni #

如果你需要用Mutiny的Uni处理逻辑，必须手动订阅Uni（Mutiny遵循惰性执行原则，不订阅则代码不会运行），同时指定在executor线程执行：

import io.quarkus.vertx.ConsumeEvent;
import io.smallrye.mutiny.Uni;
import org.jboss.logging.Logger;

@ApplicationScoped
public class TestResource {
    private static final Logger LOG = Logger.getLogger(TestResource.class);

    @Inject
    private DaoBooking daoBooking;

    @Inject
    ManagedExecutor executor;

    @ConsumeEvent("greeting")
    public void markSeatsAsPrinted(String bookingId) {
        LOG.info("Received markSeatsAsPrinted event");
        Uni.createFrom().voidItem()
           .invoke(() -> {
               LOG.info("Start long running mark tickets as printed job");
               try {
                   daoBooking.markSeatsAsPrinted(bookingId);
               } catch (FileMakerException e) {
                   LOG.error("Failed to mark seats as printed for booking: " + bookingId, e);
               }
               LOG.info("End long running mark tickets as printed job");
           })
           .emitOn(executor) // 指定在executor线程执行阻塞逻辑
           .subscribe().with(
               () -> LOG.debug("Background task completed successfully for booking: " + bookingId),
               err -> LOG.error("Background task failed for booking: " + bookingId, err)
           ); // 必须订阅才能触发Uni执行
    }
}

你之前的问题根源：

• 当消费方法返回void时，你创建了Uni但没有调用subscribe()，导致Mutiny不会执行Uni中的逻辑，所以只看到Received markSeatsAsPrinted event日志，而没有执行任务代码。
• 当消费方法返回Uni<Boolean>时，虽然Uni会执行，但如果阻塞逻辑没有正确切换到worker线程，可能会占用EventLoop线程导致REST响应延迟。

额外注意事项 #

• 避免在EventLoop线程执行阻塞任务：如果不使用blocking=true或emitOn(executor)，阻塞任务会占用处理REST请求的EventLoop线程，导致整个服务性能下降。
• 异常处理：务必捕获并记录任务中的异常，避免静默失败。
• 任务可靠性：如果需要确保任务一定执行（比如服务重启后不丢失），可以考虑使用Quarkus的消息队列扩展替代EventBus——EventBus是内存级的，服务重启后未处理的消息会丢失。

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