多部分中的okhttp loggin拦截器

2 回答

• -2

  从Okttp和Retrofit查看Multipart上传内容的方法是使用Facebook的Stetho，并将StethoInterceptor添加到Okhttp Logger

  https://github.com/facebook/stetho

  它将Android应用程序的网络请求放入您的开发机器的chrome检查器中 .

  回复于 2024-04-28T01:40:59+08:00
• 6

  它似乎是日志拦截器中的一个错误 .

  我能够解决这个问题买调试日志拦截器 . 问题是多部分的身体太大而且itercepter不能同时显示这么大的身体 . 它需要逐行打印 . 这是在okhttp 3.4.1中使用多部分的日志记录拦截器的修改版本：

  final class HttpLoggingInterceptor2 implements Interceptor {
  private static final Charset UTF8 = Charset.forName("UTF-8");
  
  public enum Level {
      /**
       * No logs.
       */
      NONE,
      /**
       * Logs request and response lines.
       * <p/>
       * <p>Example:
       * <pre>{@code
       * --> POST /greeting http/1.1 (3-byte body)
       *
       * <-- 200 OK (22ms, 6-byte body)
       * }</pre>
       */
      BASIC,
      /**
       * Logs request and response lines and their respective headers.
       * <p/>
       * <p>Example:
       * <pre>{@code
       * --> POST /greeting http/1.1
       * Host: example.com
       * Content-Type: plain/text
       * Content-Length: 3
       * --> END POST
       *
       * <-- 200 OK (22ms)
       * Content-Type: plain/text
       * Content-Length: 6
       * <-- END HTTP
       * }</pre>
       */
      HEADERS,
      /**
       * Logs request and response lines and their respective headers and bodies (if present).
       * <p/>
       * <p>Example:
       * <pre>{@code
       * --> POST /greeting http/1.1
       * Host: example.com
       * Content-Type: plain/text
       * Content-Length: 3
       *
       * Hi?
       * --> END POST
       *
       * <-- 200 OK (22ms)
       * Content-Type: plain/text
       * Content-Length: 6
       *
       * Hello!
       * <-- END HTTP
       * }</pre>
       */
      BODY
  }
  
  public interface Logger {
      void log(String message);
  
      /**
       * A {@link Logger} defaults output appropriate for the current platform.
       */
      Logger DEFAULT = new Logger() {
          @Override
          public void log(String message) {
              Platform.get().log(INFO, message, null);
          }
      };
  }
  
  public HttpLoggingInterceptor2() {
      this(Logger.DEFAULT);
  }
  
  public HttpLoggingInterceptor2(Logger logger) {
      this.logger = logger;
  }
  
  private final Logger logger;
  
  private volatile Level level = Level.NONE;
  
  /**
   * Change the level at which this interceptor logs.
   */
  public HttpLoggingInterceptor2 setLevel(Level level) {
      if (level == null) throw new NullPointerException("level == null. Use Level.NONE instead.");
      this.level = level;
      return this;
  }
  
  public Level getLevel() {
      return level;
  }
  
  @Override
  public Response intercept(Chain chain) throws IOException {
      Level level = this.level;
  
      Request request = chain.request();
      if (level == Level.NONE) {
          return chain.proceed(request);
      }
  
      boolean logBody = level == Level.BODY;
      boolean logHeaders = logBody || level == Level.HEADERS;
  
      RequestBody requestBody = request.body();
      boolean hasRequestBody = requestBody != null;
  
      Connection connection = chain.connection();
      Protocol protocol = connection != null ? connection.protocol() : Protocol.HTTP_1_1;
      String requestStartMessage = "--> " + request.method() + ' ' + request.url() + ' ' + protocol;
      if (!logHeaders && hasRequestBody) {
          requestStartMessage += " (" + requestBody.contentLength() + "-byte body)";
      }
      logger.log(requestStartMessage);
  
      if (logHeaders) {
          if (hasRequestBody) {
              // Request body headers are only present when installed as a network interceptor. Force
              // them to be included (when available) so there values are known.
              if (requestBody.contentType() != null) {
                  logger.log("Content-Type: " + requestBody.contentType());
              }
              if (requestBody.contentLength() != -1) {
                  logger.log("Content-Length: " + requestBody.contentLength());
              }
          }
  
          Headers headers = request.headers();
          for (int i = 0, count = headers.size(); i < count; i++) {
              String name = headers.name(i);
              // Skip headers from the request body as they are explicitly logged above.
              if (!"Content-Type".equalsIgnoreCase(name) && !"Content-Length".equalsIgnoreCase(name)) {
                  logger.log(name + ": " + headers.value(i));
              }
          }
  
          if (!logBody || !hasRequestBody) {
              logger.log("--> END " + request.method());
          } else if (bodyEncoded(request.headers())) {
              logger.log("--> END " + request.method() + " (encoded body omitted)");
          } else {
              Buffer buffer = new Buffer();
              requestBody.writeTo(buffer);
  
              Charset charset = Charset.forName("UTF8");// UTF8;
              MediaType contentType = requestBody.contentType();
              if (contentType != null) {
                  charset = contentType.charset(charset);
              }
  
              if (isPlaintext(buffer)) {
                  String string = buffer.clone().readString(charset);
                  String[] strings = string.split("\\r?\\n");
                  for (String subStr : strings) {
                      logger.log(subStr);
                  }
                  logger.log("--> END " + request.method()
                          + " (" + requestBody.contentLength() + "-byte body)");
              } else {
                  logger.log("--> END " + request.method() + " (binary "
                          + requestBody.contentLength() + "-byte body omitted)");
              }
          }
      }
  
      long startNs = System.nanoTime();
      Response response;
      try {
          response = chain.proceed(request);
      } catch (Exception e) {
          logger.log("<-- HTTP FAILED: " + e);
          throw e;
      }
      long tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs);
  
      ResponseBody responseBody = response.body();
      long contentLength = responseBody.contentLength();
      String bodySize = contentLength != -1 ? contentLength + "-byte" : "unknown-length";
      logger.log("<-- " + response.code() + ' ' + response.message() + ' '
              + response.request().url() + " (" + tookMs + "ms" + (!logHeaders ? ", "
              + bodySize + " body" : "") + ')');
  
      if (logHeaders) {
          Headers headers = response.headers();
          for (int i = 0, count = headers.size(); i < count; i++) {
              logger.log(headers.name(i) + ": " + headers.value(i));
          }
  
          if (!logBody || !HttpHeaders.hasBody(response)) {
              logger.log("<-- END HTTP");
          } else if (bodyEncoded(response.headers())) {
              logger.log("<-- END HTTP (encoded body omitted)");
          } else {
              BufferedSource source = responseBody.source();
              source.request(Long.MAX_VALUE); // Buffer the entire body.
              Buffer buffer = source.buffer();
  
              Charset charset = UTF8;
              MediaType contentType = responseBody.contentType();
              if (contentType != null) {
                  try {
                      charset = contentType.charset(UTF8);
                  } catch (UnsupportedCharsetException e) {
                      logger.log("");
                      logger.log("Couldn't decode the response body; charset is likely malformed.");
                      logger.log("<-- END HTTP");
  
                      return response;
                  }
              }
  
              if (!isPlaintext(buffer)) {
                  logger.log("");
                  logger.log("<-- END HTTP (binary " + buffer.size() + "-byte body omitted)");
                  return response;
              }
  
              if (contentLength != 0) {
                  logger.log("");
                  logger.log(buffer.clone().readString(charset));
              }
  
              logger.log("<-- END HTTP (" + buffer.size() + "-byte body)");
          }
      }
  
      return response;
  }
  
  /**
   * Returns true if the body in question probably contains human readable text. Uses a small sample
   * of code points to detect unicode control characters commonly used in binary file signatures.
   */
  static boolean isPlaintext(Buffer buffer) {
      try {
          Buffer prefix = new Buffer();
          long byteCount = buffer.size() < 64 ? buffer.size() : 64;
          buffer.copyTo(prefix, 0, byteCount);
          for (int i = 0; i < 16; i++) {
              if (prefix.exhausted()) {
                  break;
              }
              int codePoint = prefix.readUtf8CodePoint();
              if (Character.isISOControl(codePoint) && !Character.isWhitespace(codePoint)) {
                  return false;
              }
          }
          return true;
      } catch (EOFException e) {
          return false; // Truncated UTF-8 sequence.
      }
  }
  
  private boolean bodyEncoded(Headers headers) {
      String contentEncoding = headers.get("Content-Encoding");
      return contentEncoding != null && !contentEncoding.equalsIgnoreCase("identity");
  }
  

  }

  回复于 2024-04-28T01:40:59+08:00