无法在 Spring Boot pubsub 应用程序中正确处理异常

Question

这是我遇到问题的代码：

try {
    publisher.publish(payload).get();
} catch (com.google.api.gax.rpc.DeadlineExceededException e) {
    LOGGER.error("com.google.api.gax.rpc.DeadlineExceededException occured: " + e.getCause());
} catch (com.google.api.gax.rpc.NotFoundException e) {
    LOGGER.error("com.google.api.gax.rpc.NotFoundException occured: " + e.getCause());
} catch (com.google.api.gax.rpc.ApiException e) {
    LOGGER.error("com.google.api.gax.rpc.ApiException occured: " + e.getCause());
} catch (io.grpc.StatusRuntimeException e) {
    LOGGER.error("io.grpc.StatusRuntimeException occured: " + e.getCause());
} catch (java.lang.RuntimeException e) {
    LOGGER.error("RuntimeException occured: " + e.getCause());
} catch (java.util.concurrent.ExecutionException e) {
    LOGGER.error("java.util.concurrent.ExecutionException occured: " + e.getCause()); // my program cursor always come to this point
} catch (Exception e) {
    LOGGER.error("Exception occured: " + e.getCause());
}

而 ExecutionException catch 的 getCause 是：

java.util.concurrent.ExecutionException 发生： com.google.api.gax.rpc.NotFoundException： io.grpc.StatusRuntimeException: NOT_FOUND: 找不到资源

如果您看到我已经将“com.google.api.gax.rpc.NotFoundException”的捕获放在第二个捕获中，那么为什么它进入了 ExcutionException 捕获。

由于这种性质，我无法为客户编写适当的消息来解决。

如果有人可以提供帮助，请提前致谢。

Answer 1

当 publisher.publish(payload).get() 被执行时，它会抛出 java.util.concurrent.ExecutionException ex= new com.google.api.gax.rpc.NotFoundException() 即 java.util. util.concurrent.ExecutionException 但 com.google.api.gax.rpc.NotFoundException 的对象。因此在 try catch 中，当引用检查要执行哪个 catch 块时，它无法通过 api.gax.rpc.NotFoundException() 因为 cactch 仅捕获相同或超类，因此它稍后被捕获，但由于对象是由 com. google.api.gax.rpc.NotFoundException 所以 getCause 被覆盖，当你执行它时，对象方法被调用。

分辨率：例如

try{

}
catch(Exception e){
            throw (e.getClass()).cast(e);

}

你可以把这个 catch 块放在 java.util.concurrent.ExecutionException 中。