从android调用grpc google endpoints 导致来自nginx esp的HTTP状态代码400

1 回答

• 0

  我们发现了这个问题，它是在我们的grpc日志记录拦截器上，如果我们通过调用headers.toString（）来记录Metadata，它就会失败 .

  这很奇怪，因为它仅对谷歌 Cloud endpoints 失败 . 而toString（）改变了一些东西是非常奇怪的，我将在grpc-java github上打开一个问题 .

  Our simple interceptor

  package com.myproject.android.common.api.grpc.interceptor;
  
  import android.util.Log;
  
  import io.grpc.CallOptions;
  import io.grpc.Channel;
  import io.grpc.ClientCall;
  import io.grpc.ClientInterceptor;
  import io.grpc.ForwardingClientCall;
  import io.grpc.ForwardingClientCallListener;
  import io.grpc.Metadata;
  import io.grpc.MethodDescriptor;
  
  /**
  * Interceptor that log (via Android logger) gRPC request and response contents.
  * <p>
  * The content might be truncated if too long.
  * </p>
  * Created on 18/10/2017.
  */
  public class GrpcLoggingInterceptor implements ClientInterceptor {
      private static final String TAG = GrpcLoggingInterceptor.class.getSimpleName();
  
      @Override
      public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
          return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {
  
              @Override
              public void sendMessage(ReqT message) {
                  Log.v(TAG, "--> [REQUEST] " + method.getFullMethodName() + ": \n" + message.toString());
                  super.sendMessage(message);
              }
  
              @Override
              public void start(Listener<RespT> responseListener, Metadata headers) {
  //                Log.v(TAG, "--> [HEADERS] " + headers.toString()); // /!\ DO NOT LOG METADATA: causes error 400 on GCP
                  ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT> listener = new
                          ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(responseListener) {
                              @Override
                              public void onMessage(RespT message) {
                                  Log.v(TAG, "<-- [RESPONSE] " + method.getFullMethodName() + " (" + message.toString().length() + " bytes): \n" + message.toString());
                                  super.onMessage(message);
                              }
                          };
                  super.start(listener, headers);
              }
          };
      }
  }
  

  回复于 2024-05-04T01:32:17+08:00