ServerInterceptor gRPC未捕获Quarkus中SmallRye Mutiny反应异常

Question

我有两个可用的gRPCendpoint和一个ServerInterceptor，它应该在抛出异常时拦截异常。

gRPC服务定义如下：

@GrpcService
public class AccountsResource implements AccountsApiService {

    @Inject
    AccountsService accountsService;

    @Override
    public Uni<GetTppPlatformGroupIdResponse> getTppPlatformGroupId(Empty request) {
        Context.Key<String> tppIamClientIdKey = Constant.TPP_IAM_CLIENT_ID_CONTEXT_KEY;
        String tppIamClientId = tppIamClientIdKey.get(Context.current());

        return Uni.createFrom().item(() -> accountsService.getTppPlatformGroupIdResponse(tppIamClientId))
                .runSubscriptionOn(Infrastructure.getDefaultExecutor());
    }
}

gRPC服务使用SmallRye Mutiny Responsive来处理请求。

其他帖子解释说，应该重写onHalfClose方法，并插入try/catch块来捕获自定义异常，然后映射到StatusRuntimeException gRPC可以使用的状态。我尝试了以下方法：

@ApplicationScoped
@GlobalInterceptor
public class ExceptionInterceptor implements ServerInterceptor {

    private static final Logger LOG = LogManager.getLogger(ExceptionInterceptor.class);

    @Override
    public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> serverCall, Metadata metadata, ServerCallHandler<ReqT, RespT> serverCallHandler) {
        ServerCall.Listener<ReqT> listener = serverCallHandler.startCall(serverCall, metadata);
        return new ExceptionHandlingServerCallListener<>(listener, serverCall, metadata);
    }

    private class ExceptionHandlingServerCallListener<ReqT, RespT> extends ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT> {
        private ServerCall<ReqT, RespT> serverCall;
        private Metadata metadata;

        ExceptionHandlingServerCallListener(ServerCall.Listener<ReqT> listener, ServerCall<ReqT, RespT> serverCall, Metadata metadata) {
            super(listener);
            this.serverCall = serverCall;
            this.metadata = metadata;
        }

        @Override
        public void onHalfClose() {
            try {
                super.onHalfClose();
            } catch (Throwable ex) {
                handleException(ex, serverCall, metadata);
            }
        }

        @Override
        public void onReady() {
            try {
                super.onReady();
            } catch (Throwable ex) {
                handleException(ex, serverCall, metadata);
            }
        }
    }

handleException方法将Throwable映射到StatusRuntimeException，并抛出StatusRuntimeException。

到目前为止还不错，并且在运行应用程序并模拟自定义异常时，ExceptionInterceptor确实输入了onHalf关闭方法。但是，即使抛出了异常，它也不会进入catch块。此错误消息被记录到控制台：

2022-01-24 12:07:36232警告[io.qua.grp.run.ServerCalls]（executor-thread-0）gRPC服务引发了StatusRuntimeException以外的异常

如何修复此问题？




Answer 1

使用此https://github.com/grpc/grpc-kotlin/issues/141，它位于kotlin中，但可以适应java。