如何在Panache的Mutiny流水线中回滚后返回失败信息

你的代码存在两个核心问题：一是通过subscribe()触发事务回滚操作会脱离当前Uni链，可能导致事务状态处理和后续逻辑不同步；二是标记回滚后仍返回persist(mess)的成功结果，上层调用者会误以为数据已保存，实际事务已回滚。

要实现「满足条件时回滚事务并返回失败信息」的需求，最佳实践是：

• 保持Mutiny链式调用风格，避免在链内使用subscribe()
• 标记事务回滚后，通过Uni.failure()抛出明确的业务异常，让返回的Uni进入失败状态

实现步骤与示例代码 #

1. 定义自定义业务异常（让失败原因更清晰）

public class InvalidMessageException extends RuntimeException {
    public InvalidMessageException(String message) {
        super(message);
    }
}

2. 修改save方法

public Uni<Mess> save(Mess mess) {
    return Panache.withTransaction(() -> {
        if ("Hello World".equals(mess.message)) {
            // 链式处理事务回滚，并返回失败信号
            return Panache.currentTransaction()
                    .invoke(Transaction::markForRollback)
                    .invoke(() -> Log.info("Transaction is marked for roll-back"))
                    .flatMap(ignored -> Uni.failure(new InvalidMessageException("消息'Hello World'不允许保存，事务已回滚")));
        }
        // 正常逻辑：持久化数据
        return persist(mess);
    });
}

关键细节说明 #

• 用invoke()替代subscribe()：确保事务回滚操作在当前Uni的上下文内执行，和后续的失败返回保持同步，避免异步割裂。
• Uni.failure()直接生成失败信号：上层调用save()方法时，可以通过onFailure()捕获InvalidMessageException，明确处理失败场景。
• 自定义异常的优势：相比通用异常，业务方可以直接通过异常类型判断失败原因，无需解析错误信息。

简化版（如果不需要日志） #

如果不需要额外的日志输出，代码可以进一步简化：

public Uni<Mess> save(Mess mess) {
    return Panache.withTransaction(() -> {
        if ("Hello World".equals(mess.message)) {
            return Panache.currentTransaction()
                    .invoke(Transaction::markForRollback)
                    .flatMap(ignored -> Uni.failure(new InvalidMessageException("无效消息，事务已回滚")));
        }
        return persist(mess);
    });
}

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