gRPC ServerInterceptor返回异常后，如何替换为含错误码的合法响应？

我为gRPC服务器实现了一个负责验证所有入站请求的ServerInterceptor。当请求无有效令牌时，该拦截器会关闭调用并向客户端抛出异常，代码示例如下：

public class UserAuthenticationInterceptor implements ServerInterceptor {

  ...

  @Override
  public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
      ServerCall<ReqT, RespT> serverCall,
      Metadata metadata,
      ServerCallHandler<ReqT, RespT> serverCallHandler) {
    boolean canAuthenticateUser = authenticateUser(...);
    if (canAuthenticateUser) {
      // Pass request to gRPC server
      ...
    } else {
      // Reject request
      serverCall.close(
          Status.UNAUTHENTICATED.withDescription("The provided Firebase token is invalid."),
          new Metadata());
      return new ServerCall.Listener() {};
    }
  }

  ...
}

但我的gRPC服务器遵循的规范是绝不向客户端抛出异常，而是返回包含错误码的合法消息proto。请问是否可以捕获ServerInterceptor抛出的异常，并用合法消息替代返回？我知道可以编写ClientInterceptor处理此类响应，但这违背了客户端无需感知服务端异常的初衷。

我想到了几种潜在方案：

1. 实现一个能处理异常的ServerCall.Listener（是否可行？）
2. 将未通过验证的请求转发给gRPC服务器，由服务返回含错误码的消息proto
3. （最后手段）在ClientInterceptor中捕获异常

方案1：实现异常处理的ServerCall.Listener（可行） #

你可以自定义ServerCall的包装类，重写close()方法，把gRPC的错误状态转换为符合规范的业务响应消息，再通过正常流程返回。因为当前拦截器是主动调用serverCall.close()返回错误，并非抛出异常，所以需要拦截这个关闭操作。

示例思路：

public class ErrorHandlingServerCall<ReqT, RespT> extends ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT> {
    private final RespT errorResponse;

    protected ErrorHandlingServerCall(ServerCall<ReqT, RespT> delegate, RespT errorResponse) {
        super(delegate);
        this.errorResponse = errorResponse;
    }

    @Override
    public void close(Status status, Metadata trailers) {
        if (!status.isOk()) {
            // 发送预定义的错误响应消息
            sendMessage(errorResponse);
            // 以OK状态关闭调用，避免客户端收到异常
            super.close(Status.OK, trailers);
        } else {
            super.close(status, trailers);
        }
    }
}

在拦截器中，验证失败时创建对应的错误响应，用包装类替换原ServerCall，再返回正常的Listener。不过这种方式需要适配不同服务方法的响应类型，可能需要统一错误消息结构或结合泛型处理。

方案2：将未通过验证的请求转发给服务端处理（推荐） #

这是最贴合服务规范的做法：拦截器不直接终止调用，而是把验证结果通过上下文传递给后续的服务方法，由服务方法根据结果返回合法的错误消息proto。

示例调整：

// 定义上下文键
private static final Context.Key<Boolean> AUTH_PASSED = Context.key("auth_passed");

@Override
public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
    ServerCall<ReqT, RespT> serverCall,
    Metadata metadata,
    ServerCallHandler<ReqT, RespT> serverCallHandler) {
    boolean canAuthenticateUser = authenticateUser(...);
    // 将验证结果存入上下文
    Context context = Context.current().withValue(AUTH_PASSED, canAuthenticateUser);
    return Contexts.interceptCall(context, serverCall, metadata, serverCallHandler);
}

服务实现方法中处理：

@Override
public void yourServiceMethod(YourRequest request, StreamObserver<YourResponse> responseObserver) {
    Boolean authPassed = AUTH_PASSED.get();
    if (authPassed == null || !authPassed) {
        YourResponse errorResp = YourResponse.newBuilder()
            .setErrorCode(ErrorCode.UNAUTHENTICATED)
            .setErrorMessage("The provided Firebase token is invalid.")
            .build();
        responseObserver.onNext(errorResp);
        responseObserver.onCompleted();
        return;
    }
    // 执行正常业务逻辑
}

这种方式完全符合“返回合法消息”的要求，客户端无需感知任何异常逻辑，所有响应都是标准的proto消息。

方案3：在ClientInterceptor中处理（不推荐） #

正如你所说，这种方式会把服务端的错误处理逻辑转嫁到客户端，违背了“客户端无需感知服务端异常”的初衷，还会增加客户端的复杂度，只有在前两种方案都无法实施时才考虑作为最后手段。

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