grpc的特性

@GrpcGlobalServerInterceptor
@Slf4j
public class LogInterceptor implements ServerInterceptor {

    @Override
    public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> serverCall, Metadata metadata, ServerCallHandler<ReqT, RespT> serverCallHandler) {
        log.info(serverCall.getMethodDescriptor().getFullMethodName());
        return serverCallHandler.startCall(serverCall, metadata);
    }
}

@GrpcGlobalClientInterceptor
@Slf4j
public class LogInterceptor implements ClientInterceptor {

    @Override
    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
        log.info("global .... LogInterceptor"+method.getFullMethodName());
        return next.newCall(method, callOptions);
    }
}

AdRpcGrpc.AdRpcBlockingStub stub = AdRpcGrpc.newBlockingStub(serverChannel);
        AdInfo.AdId adId = AdInfo.AdId.newBuilder().setId(id).build();
        AdInfo.Ad ad = stub
                .withDeadline(Deadline.after(100, TimeUnit.MILLISECONDS))
                .withInterceptors(log2Interceptor)
                .getAd(adId);

AdInfo.Ad ad = stub
                .withDeadline(Deadline.after(100, TimeUnit.MILLISECONDS))
                .withInterceptors(log2Interceptor)
                .getAd(adId);

responseObserver.onError(new StatusException(Status.NOT_FOUND));