Axon框架：处理状态存储聚合中的数据库异常

Question

• 异常处理表示“@exceptionHandler将只处理从同一个类中的消息处理函数引发的异常”
• 消息拦截文档说：“用@exceptionHandler注释的函数将被视为处理程序拦截器，只有在异常结果时才会调用该函数。例如，为此目的使用注释函数允许您作为引发的数据库/服务异常的结果引发更特定于域的异常。”

但我不能让它起作用。我尝试添加异常处理程序，如下所示：

    @ExceptionHandler
    public void handle(ConstraintViolationException ex) throws Exception {
        if (ex.getMessage().contains("UNQ_COMPANY_ID") || ex.getMessage().contains("UNQ_PLAN_NAME")) {
            throw new DomainException("Plan name and company id must be unique");
        }
        throw ex;
    }

但不调用此方法。我尝试将异常处理程序方法放在聚合和单独的命令处理程序类上，尝试添加ResultType=ConstraintViolationException.class，并尝试捕获其他类型的异常，包括exception、RuntimeException、AxonServerRemoteCommandHandlingException等。

我可以在日志输出中看到错误：

org.axonframework.axonserver.connector.commandd.axonserverremoteCommandHandlingException：远程消息处理组件引发异常：org.hibernate.exception.constraintViolationException：Call not execute语句

是否可以在状态存储的聚合中捕获数据库异常？如果是，有人能指出我做错了什么吗？

语句“一个@ExceptionHandler将只处理同一个类中消息处理函数引发的异常”使我怀疑是否需要创建一个自定义存储库类（而不是使用默认的GenericJParepository)，但这似乎需要做更多的工作。

更新：通过向@CommandHandler方法添加UnitofWork参数，并使用它注册回滚回调，我大致完成了我想要的任务，如下所示：

        uow.onRollback(unit -> {
            DefaultUnitOfWork duow = (DefaultUnitOfWork) unit;
            Throwable ex = duow.getExecutionResult().getExceptionResult();
            while (ex != null) {
                if (ex.getMessage().contains("UNQ_PLAN_NAME")) {
                    throw new RuntimeException("Plan name must be unique");
                }
                ex = ex.getCause();
            }
        });

但这似乎有点冗长，也限制了我只能抛出未经检查的异常。不过，这也不是正确的方法，因为我假设@exceptionHandler注释的目的是消除对上述代码的需求。

Answer 1

这当然是可行的。

实际上，我能给你的最好的指针是，如果代码示例可以在那里看到关于分布式异常的示例。

通常，正如您在共享日志中看到的，“原始”异常被包装成AxonServerRemoteCommandHandlingException，这意味着您必须处理该异常。这样，您几乎可以向该类的detail字段添加任何内容，例如添加指示您有constraintViolationException（或ERROR_CODE，就像HTTP协议那样），您可以在另一边展开它。