okhttp3.Request.body()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(606)

本文整理了Java中okhttp3.Request.body方法的一些代码示例，展示了Request.body的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request.body方法的具体详情如下：
包路径：okhttp3.Request
类名称：Request
方法名：body

Request.body介绍

暂无

代码示例

代码示例来源：origin: square/okhttp

  1. private boolean requestIsUnrepeatable(IOException e, Request userRequest) {
  2.  return userRequest.body() instanceof UnrepeatableRequestBody
  3.    || e instanceof FileNotFoundException;
  4. }

代码示例来源：origin: com.squareup.okhttp3/okhttp

  1. private boolean requestIsUnrepeatable(IOException e, Request userRequest) {
  2.  return userRequest.body() instanceof UnrepeatableRequestBody
  3.    || e instanceof FileNotFoundException;
  4. }

代码示例来源：origin: square/okhttp

  1. CacheHttpURLConnection(Response response) {
  2.  super(response.request().url().url());
  3.  this.request = response.request();
  4.  this.response = response;
  5.  // Configure URLConnection inherited fields.
  6.  this.connected = true;
  7.  this.doOutput = request.body() != null;
  8.  this.doInput = true;
  9.  this.useCaches = true;
  10.  // Configure HttpUrlConnection inherited fields.
  11.  this.method = request.method();
  12. }

代码示例来源：origin: square/okhttp

  1. @Override public Response intercept(Chain chain) throws IOException {
  2.  Request originalRequest = chain.request();
  3.  if (originalRequest.body() == null || originalRequest.header("Content-Encoding") != null) {
  4.   return chain.proceed(originalRequest);
  5.  }
  6.  Request compressedRequest = originalRequest.newBuilder()
  7.    .header("Content-Encoding", "gzip")
  8.    .method(originalRequest.method(), gzip(originalRequest.body()))
  9.    .build();
  10.  return chain.proceed(compressedRequest);
  11. }

代码示例来源：origin: stackoverflow.com

  1. OkHttpClient okClient = new OkHttpClient();
  2. okClient.interceptors().add(new Interceptor() {
  3.    @Override
  4.    public Response intercept(Interceptor.Chain chain) throws IOException {
  5.      Request original = chain.request();
  6.      // Request customization: add request headers
  7.      Request.Builder requestBuilder = original.newBuilder()
  8.          .header("Authorization", token)
  9.          .method(original.method(), original.body());
  10.      Request request = requestBuilder.build();
  11.      return chain.proceed(request);
  12.    }
  13. });

代码示例来源：origin: stackoverflow.com

  1. OkHttpClient okClient = new OkHttpClient.Builder()
  2.      .addInterceptor(
  3.        new Interceptor() {
  4.         @Override
  5.         public Response intercept(Interceptor.Chain chain) throws IOException {
  6.            Request original = chain.request();
  7.            // Request customization: add request headers
  8.            Request.Builder requestBuilder = original.newBuilder()
  9.                .header("Authorization", token)
  10.                .method(original.method(), original.body());
  11.            Request request = requestBuilder.build();
  12.            return chain.proceed(request);
  13.          }
  14.        })
  15.      .build();

代码示例来源：origin: stackoverflow.com

  1. private static String bodyToString(final Request request){
  3.   try {
  4.     final Request copy = request.newBuilder().build();
  5.     final Buffer buffer = new Buffer();
  6.     copy.body().writeTo(buffer);
  7.     return buffer.readUtf8();
  8.   } catch (final IOException e) {
  9.     return "did not work";
  10.   }
  11. }

代码示例来源：origin: amitshekhariitbhu/Fast-Android-Networking

  1. @Override
  2. public Response intercept(Chain chain) throws IOException {
  3.   Request originalRequest = chain.request();
  4.   if (originalRequest.body() == null || originalRequest.header("Content-Encoding") != null) {
  5.     return chain.proceed(originalRequest);
  6.   }
  7.   Request compressedRequest = originalRequest.newBuilder()
  8.       .header("Content-Encoding", "gzip")
  9.       .method(originalRequest.method(), forceContentLength(gzip(originalRequest.body())))
  10.       .build();
  11.   return chain.proceed(compressedRequest);
  12. }

代码示例来源：origin: SonarSource/sonarqube

  1. private Response followPostRedirect(Response response, PostRequest postRequest) {
  2.  String location = response.header("Location");
  3.  if (location == null) {
  4.   throw new IllegalStateException(format("Missing HTTP header 'Location' in redirect of %s", response.request().url()));
  5.  }
  6.  HttpUrl url = response.request().url().resolve(location);
  7.  // Don't follow redirects to unsupported protocols.
  8.  if (url == null) {
  9.   throw new IllegalStateException(format("Unsupported protocol in redirect of %s to %s", response.request().url(), location));
  10.  }
  11.  Request.Builder redirectRequest = response.request().newBuilder();
  12.  redirectRequest.post(response.request().body());
  13.  response.body().close();
  14.  return doCall(prepareOkHttpClient(noRedirectOkHttpClient, postRequest), redirectRequest.url(url).build());
  15. }

代码示例来源：origin: square/okhttp

  1. if (request.body() instanceof OutputStreamRequestBody) {
  2.  OutputStreamRequestBody requestBody = (OutputStreamRequestBody) request.body();
  3.  request = requestBody.prepareToSendRequest(request);

代码示例来源：origin: square/okhttp

  1. networkInterceptor.proceed();
  2. OutputStreamRequestBody requestBody = (OutputStreamRequestBody) call.request().body();
  3. if (requestBody != null) requestBody.outputStream().close();

代码示例来源：origin: jeasonlzy/okhttp-OkGo

  1. private void bodyToString(Request request) {
  2.     try {
  3.       Request copy = request.newBuilder().build();
  4.       RequestBody body = copy.body();
  5.       if (body == null) return;
  6.       Buffer buffer = new Buffer();
  7.       body.writeTo(buffer);
  8.       Charset charset = getCharset(body.contentType());
  9.       log("\tbody:" + buffer.readString(charset));
  10.     } catch (Exception e) {
  11.       OkLogger.printStackTrace(e);
  12.     }
  13.   }
  14. }

代码示例来源：origin: square/okhttp

  1. Request.Builder requestBuilder = userRequest.newBuilder();
  2. RequestBody body = userRequest.body();
  3. if (body != null) {
  4.  MediaType contentType = body.contentType();

代码示例来源：origin: facebook/stetho

  1. @Nullable
  2. @Override
  3. public byte[] body() throws IOException {
  4.  RequestBody body = mRequest.body();
  5.  if (body == null) {
  6.   return null;
  7.  }
  8.  OutputStream out = mRequestBodyHelper.createBodySink(firstHeaderValue("Content-Encoding"));
  9.  BufferedSink bufferedSink = Okio.buffer(Okio.sink(out));
  10.  try {
  11.   body.writeTo(bufferedSink);
  12.  } finally {
  13.   bufferedSink.close();
  14.  }
  15.  return mRequestBodyHelper.getDisplayBody();
  16. }

代码示例来源：origin: square/okhttp

  1. @Override public void writeRequestHeaders(Request request) throws IOException {
  2.  if (stream != null) return;
  3.  boolean hasRequestBody = request.body() != null;
  4.  List<Header> requestHeaders = http2HeadersList(request);
  5.  stream = connection.newStream(requestHeaders, hasRequestBody);
  6.  // We may have been asked to cancel while creating the new stream and sending the request
  7.  // headers, but there was still no stream to close.
  8.  if (canceled) {
  9.   stream.closeLater(ErrorCode.CANCEL);
  10.   throw new IOException("Canceled");
  11.  }
  12.  stream.readTimeout().timeout(chain.readTimeoutMillis(), TimeUnit.MILLISECONDS);
  13.  stream.writeTimeout().timeout(chain.writeTimeoutMillis(), TimeUnit.MILLISECONDS);
  14. }

代码示例来源：origin: SonarSource/sonarqube

  1. @Test
  2. public void upload() throws IOException {
  3.  ArgumentCaptor<Request> requestCaptor = ArgumentCaptor.forClass(Request.class);
  4.  settings.setProperty(SONAR_TELEMETRY_URL.getKey(), TELEMETRY_URL);
  5.  underTest.start();
  6.  underTest.upload(JSON);
  7.  verify(okHttpClient).newCall(requestCaptor.capture());
  8.  Request request = requestCaptor.getValue();
  9.  assertThat(request.method()).isEqualTo("POST");
  10.  assertThat(request.body().contentType()).isEqualTo(MediaType.parse("application/json; charset=utf-8"));
  11.  Buffer body = new Buffer();
  12.  request.body().writeTo(body);
  13.  assertThat(body.readUtf8()).isEqualTo(JSON);
  14.  assertThat(request.url().toString()).isEqualTo(TELEMETRY_URL);
  15. }

代码示例来源：origin: SonarSource/sonarqube

  1. @Test
  2.  public void opt_out() throws IOException {
  3.   ArgumentCaptor<Request> requestCaptor = ArgumentCaptor.forClass(Request.class);
  4.   settings.setProperty(SONAR_TELEMETRY_URL.getKey(), TELEMETRY_URL);
  5.   underTest.start();
  7.   underTest.optOut(JSON);
  9.   verify(okHttpClient).newCall(requestCaptor.capture());
  10.   Request request = requestCaptor.getValue();
  11.   assertThat(request.method()).isEqualTo("DELETE");
  12.   assertThat(request.body().contentType()).isEqualTo(MediaType.parse("application/json; charset=utf-8"));
  13.   Buffer body = new Buffer();
  14.   request.body().writeTo(body);
  15.   assertThat(body.readUtf8()).isEqualTo(JSON);
  16.   assertThat(request.url().toString()).isEqualTo(TELEMETRY_URL);
  17.  }
  18. }

代码示例来源：origin: square/okhttp

  1. @Override public OutputStream getOutputStream() throws IOException {
  2.  OutputStreamRequestBody requestBody = (OutputStreamRequestBody) buildCall().request().body();
  3.  if (requestBody == null) {
  4.   throw new ProtocolException("method does not support a request body: " + method);
  5.  }
  6.  // If this request needs to stream bytes to the server, build a physical connection immediately
  7.  // and start streaming those bytes over that connection.
  8.  if (requestBody instanceof StreamedRequestBody) {
  9.   connect();
  10.   networkInterceptor.proceed();
  11.  }
  12.  if (requestBody.isClosed()) {
  13.   throw new ProtocolException("cannot write request body after response has been read");
  14.  }
  15.  return requestBody.outputStream();
  16. }

代码示例来源：origin: web3j/web3j

  1. @Override
  2. public okhttp3.Response intercept(Chain chain) throws IOException {
  3.   Request request = chain.request();
  4.   this.requestBody = request.body();
  5.   okhttp3.Response response = new okhttp3.Response.Builder()
  6.       .request(chain.request())
  7.       .protocol(Protocol.HTTP_2)
  8.       .code(200)
  9.       .message("")
  10.       .build();
  11.   return response;
  12. }

代码示例来源：origin: com.squareup.okhttp3/okhttp

  1. @Override public void writeRequestHeaders(Request request) throws IOException {
  2.  if (stream != null) return;
  3.  boolean hasRequestBody = request.body() != null;
  4.  List<Header> requestHeaders = http2HeadersList(request);
  5.  stream = connection.newStream(requestHeaders, hasRequestBody);
  6.  // We may have been asked to cancel while creating the new stream and sending the request
  7.  // headers, but there was still no stream to close.
  8.  if (canceled) {
  9.   stream.closeLater(ErrorCode.CANCEL);
  10.   throw new IOException("Canceled");
  11.  }
  12.  stream.readTimeout().timeout(chain.readTimeoutMillis(), TimeUnit.MILLISECONDS);
  13.  stream.writeTimeout().timeout(chain.writeTimeoutMillis(), TimeUnit.MILLISECONDS);
  14. }

内容来源于网络，如有侵权，请联系作者删除！

request

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com