Quarkus服务层使用Mutiny处理多异常的问题求助

你的问题核心在于异常转换后被后续无过滤的异常处理器重复捕获：当第一个onFailure(ConstraintViolationException.class).transform()将原异常转换为自定义的AccountAlreadyExistsException后，这个新异常会被后续无任何类型过滤的onFailure().transform()再次捕获，导致两个处理逻辑都被执行。

同时，使用recoverWithItem()/recoverWithUni()时出现多异常，大概率是因为你没有通过Uni.createFrom().failure()正确返回失败信号，而是直接抛出异常导致的。

下面提供两种可行的解决方案：

方案一：调整链式异常处理的过滤条件 #

在通用异常处理的onFailure()中添加过滤规则，排除已经被处理过的异常类型（包括原异常和转换后的自定义异常），确保只有未被处理的异常才会进入通用逻辑：

public Uni<AuthResponse> persistUser(User user) {
    return Panache.withTransaction(user::persist)
            .onItem().transform(success -> {
                log.info("Successfully created user, email: {}", user.getEmail());
                return new AuthResponse(user);
            })
            // 处理唯一约束异常
            .onFailure(ConstraintViolationException.class)
            .transform(ex -> handleUserCreationError(user.getEmail()))
            // 仅处理非约束异常、非已转换的自定义异常
            .onFailure(ex -> !(ex instanceof ConstraintViolationException || ex instanceof AccountAlreadyExistsException))
            .transform(ex -> handleGeneralPersistenceError(ex, user.getEmail()));
}

方案二：合并异常处理逻辑到单个recoverWithUni() #

将所有异常判断逻辑集中到一个recoverWithUni()块中，这样可以避免链式处理的捕获顺序问题，逻辑更清晰：

public Uni<AuthResponse> persistUser(User user) {
    return Panache.withTransaction(user::persist)
            .onItem().transform(success -> {
                log.info("Successfully created user, email: {}", user.getEmail());
                return new AuthResponse(user);
            })
            .onFailure()
            .recoverWithUni(ex -> {
                if (ex instanceof ConstraintViolationException) {
                    // 处理唯一约束异常，返回失败的Uni
                    Throwable customEx = handleUserCreationError(user.getEmail());
                    return Uni.createFrom().failure(customEx);
                } else {
                    // 处理通用持久化异常
                    Throwable customEx = handleGeneralPersistenceError(ex, user.getEmail());
                    return Uni.createFrom().failure(customEx);
                }
            });
}

关键说明 #

1. 关于recoverWithUni()的正确用法：必须通过Uni.createFrom().failure()返回失败信号，而不是直接抛出异常，否则会导致额外的异常抛出。
2. 方案选择建议：方案二更适合复杂的异常分支判断，逻辑集中易维护；方案一适合简单的异常分类场景，保持链式调用的风格。

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