okhttp3.RequestBody类的使用及代码示例

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

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

RequestBody介绍

暂无

代码示例

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

String post(String url, String json) throws IOException {
 RequestBody body = RequestBody.create(JSON, json);
 Request request = new Request.Builder()
   .url(url)
   .post(body)
   .build();
 try (Response response = client.newCall(request).execute()) {
  return response.body().string();
 }
}

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

@Override public void writeTo(BufferedSink sink) throws IOException {
  delegate.writeTo(sink);
 }
}

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

@Override public MediaType contentType() {
 return body.contentType();
}

代码示例来源：origin: google/data-transfer-project

rawFolder.put("@microsoft.graph.conflictBehavior", "rename");
Request.Builder requestBuilder = new Request.Builder().url(createFolderUrl);
requestBuilder.header("Authorization", "Bearer " + authData.getToken());
requestBuilder.post(
  RequestBody.create(
    MediaType.parse("application/json"), objectMapper.writeValueAsString(rawFolder)));
try (Response response = client.newCall(requestBuilder.build()).execute()) {
 int code = response.code();
 if (code >= 200 && code <= 299) {
  ResponseBody body = response.body();
  if (body == null) {
  Map<String, Object> responseData = objectMapper.readValue(body.bytes(), Map.class);
  String folderId = (String) responseData.get("id");
  if (folderId == null) {

代码示例来源：origin: testcontainers/testcontainers-java

@Override
@SneakyThrows
public <T> T post(Object entity, TypeReference<T> typeReference) {
  Request request = requestBuilder
    .post(RequestBody.create(MediaType.parse("application/json"), objectMapper.writeValueAsBytes(entity)))
    .build();
  try (Response response = execute(request)) {
    String inputStream = response.body().string();
    return objectMapper.readValue(inputStream, typeReference);
  }
}

代码示例来源：origin: fabric8io/kubernetes-client

/**
 * Create a resource.
 * @param resource
 * @param outputType
 * @param <T>
 * @param <I>
 * @return
 * @throws ExecutionException
 * @throws InterruptedException
 * @throws KubernetesClientException
  * @throws IOException
  */
protected <T, I> T handleCreate(I resource, Class<T> outputType) throws ExecutionException, InterruptedException, KubernetesClientException, IOException {
 RequestBody body = RequestBody.create(JSON, JSON_MAPPER.writeValueAsString(resource));
 Request.Builder requestBuilder = new Request.Builder().post(body).url(getNamespacedUrl(checkNamespace(resource)));
 return handleResponse(requestBuilder, outputType, Collections.<String, String>emptyMap());
}

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

Response okHttpResponse;
try {
  Request.Builder builder = new Request.Builder().url(request.getUrl());
  addHeadersToRequestBuilder(builder, request);
  final RequestBody requestBody = request.getMultiPartRequestBody();
  final long requestBodyLength = requestBody.contentLength();
  builder = builder.post(new RequestProgressBody(requestBody, request.getUploadProgressListener()));
  if (request.getCacheControl() != null) {
    builder.cacheControl(request.getCacheControl());
  if (request.getOkHttpClient() != null) {
    request.setCall(request.getOkHttpClient()
        .newBuilder()
        .cache(sHttpClient.cache())
        .build()
        .newCall(okHttpRequest));
  } else {
    request.setCall(sHttpClient.newCall(okHttpRequest));

代码示例来源：origin: apache/nifi

@Override
 public void run() {
  try {
   final int port = ((HandleHttpRequest) runner.getProcessor()).getPort();
   MultipartBody multipartBody = new MultipartBody.Builder()
    .setType(MultipartBody.FORM)
    .addFormDataPart("p1", "v1")
    .addFormDataPart("p2", "v2")
    .addFormDataPart("file1", "my-file-text.txt", RequestBody.create(MediaType.parse("text/plain"), createTextFile("my-file-text.txt", "Hello", "World")))
    .addFormDataPart("file2", "my-file-data.json", RequestBody.create(MediaType.parse("application/json"), createTextFile("my-file-text.txt", "{ \"name\":\"John\", \"age\":30 }")))
    .addFormDataPart("file3", "my-file-binary.bin", RequestBody.create(MediaType.parse("application/octet-stream"), generateRandomBinaryData(100)))
    .build();
   Request request = new Request.Builder()
   .url(String.format("http://localhost:%s/my/path", port))
   .post(multipartBody).build();
   OkHttpClient client =
     new OkHttpClient.Builder()
      .readTimeout(3000, TimeUnit.MILLISECONDS)
      .writeTimeout(3000, TimeUnit.MILLISECONDS)
     .build();
   try (Response response = client.newCall(request).execute()) {
    Assert.assertTrue(String.format("Unexpected code: %s, body: %s", response.code(), response.body().string()), response.isSuccessful());
   }
  } catch (final Throwable t) {
   t.printStackTrace();
   Assert.fail(t.toString());
  }
 }
});

代码示例来源：origin: crossoverJie/cim

@Override
public void sendGroupMsg(GroupReqVO groupReqVO) throws Exception {
  JSONObject jsonObject = new JSONObject();
  jsonObject.put("msg",groupReqVO.getMsg());
  jsonObject.put("userId",groupReqVO.getUserId());
  RequestBody requestBody = RequestBody.create(mediaType,jsonObject.toString());
  Request request = new Request.Builder()
      .url(groupRouteRequestUrl)
      .post(requestBody)
      .build();
  Response response = okHttpClient.newCall(request).execute() ;
  try {
    if (!response.isSuccessful()){
      throw new IOException("Unexpected code " + response);
    }
  }finally {
    response.body().close();
  }
}

代码示例来源：origin: apache/nifi

mapper.readTree(jsonString);
} catch (IOException e) {
  logger.error("Flow file content is not valid JSON, penalizing and transferring to failure.",
RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), sb.toString());
final Response getResponse;
try {
final int statusCode = getResponse.code();
  ResponseBody responseBody = getResponse.body();
  try {
    final byte[] bodyBytes = responseBody.bytes();
      new Object[]{statusCode, getResponse.message()});
  session.transfer(flowFilesToTransfer, REL_RETRY);
  context.yield();

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void call(final Stream stream, final AlertCondition.CheckResult result) throws AlarmCallbackException {
  final Map<String, Object> event = Maps.newHashMap();
  event.put("stream", stream);
  event.put("check_result", result);
  final byte[] body;
  try {
    body = objectMapper.writeValueAsBytes(event);
  } catch (JsonProcessingException e) {
    throw new AlarmCallbackException("Unable to serialize alarm", e);
  }
  final String url = configuration.getString(CK_URL);
  final HttpUrl httpUrl = HttpUrl.parse(url);
  if (httpUrl == null) {
    throw new AlarmCallbackException("Malformed URL: " + url);
  }
  final Request request = new Request.Builder()
      .url(httpUrl)
      .post(RequestBody.create(CONTENT_TYPE, body))
      .build();
  try (final Response r = httpClient.newCall(request).execute()) {
    if (!r.isSuccessful()) {
      throw new AlarmCallbackException("Expected successful HTTP response [2xx] but got [" + r.code() + "].");
    }
  } catch (IOException e) {
    throw new AlarmCallbackException(e.getMessage(), e);
  }
}

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

public boolean submitQp(String username, int qp) throws IOException
{
  HttpUrl url = RuneLiteAPI.getApiBase().newBuilder()
    .addPathSegment("chat")
    .addPathSegment("qp")
    .addQueryParameter("name", username)
    .addQueryParameter("qp", Integer.toString(qp))
    .build();
  Request request = new Request.Builder()
    .post(RequestBody.create(null, new byte[0]))
    .url(url)
    .build();
  try (Response response = RuneLiteAPI.CLIENT.newCall(request).execute())
  {
    return response.isSuccessful();
  }
}

代码示例来源：origin: fabric8io/kubernetes-client

/**
 * Send an http patch and handle the response.
 * @param current
 * @param updated
 * @param type
 * @param <T>
 * @return
 * @throws ExecutionException
 * @throws InterruptedException
 * @throws KubernetesClientException
  * @throws IOException
  */
protected <T> T handlePatch(T current, T updated, Class<T> type) throws ExecutionException, InterruptedException, KubernetesClientException, IOException {
 JsonNode diff = JsonDiff.asJson(patchMapper().valueToTree(current), patchMapper().valueToTree(updated));
 RequestBody body = RequestBody.create(JSON_PATCH, JSON_MAPPER.writeValueAsString(diff));
 Request.Builder requestBuilder = new Request.Builder().patch(body).url(getResourceUrl(checkNamespace(updated), checkName(updated)));
 return handleResponse(requestBuilder, type, Collections.<String, String>emptyMap());
}

代码示例来源：origin: com.squareup.keywhiz/keywhiz-client

private String httpPost(HttpUrl url, Object content) throws IOException {
 RequestBody body = RequestBody.create(JSON, mapper.writeValueAsString(content));
 Request request = new Request.Builder()
   .url(url)
   .post(body)
   .addHeader(HttpHeaders.CONTENT_TYPE, JSON.toString())
   .build();
 return makeCall(request);
}

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

+ (connection != null ? " " + connection.protocol() : "");
if (!logHeaders && hasRequestBody) {
 requestStartMessage += " (" + requestBody.contentLength() + "-byte body)";
  if (requestBody.contentType() != null) {
   logger.log("Content-Type: " + requestBody.contentType());
  if (requestBody.contentLength() != -1) {
   logger.log("Content-Length: " + requestBody.contentLength());
 } else {
  Buffer buffer = new Buffer();
  requestBody.writeTo(buffer);
  MediaType contentType = requestBody.contentType();
  if (contentType != null) {
   charset = contentType.charset(UTF8);
   logger.log(buffer.readString(charset));
   logger.log("--> END " + request.method()
     + " (" + requestBody.contentLength() + "-byte body)");
  } else {
   logger.log("--> END " + request.method() + " (binary "
     + requestBody.contentLength() + "-byte body omitted)");
  logger.log("<-- END HTTP (encoded body omitted)");
 } else {
  BufferedSource source = responseBody.source();

代码示例来源：origin: testcontainers/testcontainers-java

@Override
@SneakyThrows
public InputStream post(Object entity) {
  Request request = requestBuilder
    .post(RequestBody.create(MediaType.parse("application/json"), objectMapper.writeValueAsBytes(entity)))
    .build();
  return execute(request).body().byteStream();
}

代码示例来源：origin: apache/nifi

@Override
 public void run() {
  try {
   final int port = ((HandleHttpRequest) runner.getProcessor()).getPort();
   MultipartBody multipartBody = new MultipartBody.Builder()
    .setType(MultipartBody.FORM)
    .addFormDataPart("p1", "v1")
    .addFormDataPart("p2", "v2")
    .addFormDataPart("file1", "my-file-text.txt", RequestBody.create(MediaType.parse("text/plain"), createTextFile("my-file-text.txt", "Hello", "World")))
    .addFormDataPart("file2", "my-file-data.json", RequestBody.create(MediaType.parse("application/json"), createTextFile("my-file-text.txt", "{ \"name\":\"John\", \"age\":30 }")))
    .addFormDataPart("file3", "my-file-binary.bin", RequestBody.create(MediaType.parse("application/octet-stream"), generateRandomBinaryData(100)))
    .build();
   Request request = new Request.Builder()
   .url(String.format("http://localhost:%s/my/path", port))
   .post(multipartBody).build();
   OkHttpClient client =
     new OkHttpClient.Builder()
      .readTimeout(20000, TimeUnit.MILLISECONDS)
      .writeTimeout(20000, TimeUnit.MILLISECONDS)
     .build();
   try (Response response = client.newCall(request).execute()) {
    responseCode.set(response.code());
   }
  } catch (final Throwable t) {
   t.printStackTrace();
   Assert.fail(t.toString());
  }
 }
});

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

MediaType contentType = body.contentType();
 if (contentType != null) {
  requestBuilder.header("Content-Type", contentType.toString());
 long contentLength = body.contentLength();
 if (contentLength != -1) {
  requestBuilder.header("Content-Length", Long.toString(contentLength));
  requestBuilder.removeHeader("Transfer-Encoding");
 } else {
  requestBuilder.header("Transfer-Encoding", "chunked");
Response networkResponse = chain.proceed(requestBuilder.build());
HttpHeaders.receiveHeaders(cookieJar, userRequest.url(), networkResponse.headers());
Response.Builder responseBuilder = networkResponse.newBuilder()
  .request(userRequest);
  && "gzip".equalsIgnoreCase(networkResponse.header("Content-Encoding"))
  && HttpHeaders.hasBody(networkResponse)) {
 GzipSource responseBody = new GzipSource(networkResponse.body().source());
 Headers strippedHeaders = networkResponse.headers().newBuilder()
   .removeAll("Content-Encoding")

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

Request request = new Request.Builder()
  .url(requestUri.toString())
  .method(
    "POST",
    RequestBody.create(MediaType.parse("text/plain"), requestText))
  .build();
String originalBodyData = "Success!";
  .protocol(Protocol.HTTP_1_1)
  .code(200)
  .body(ResponseBody.create(MediaType.parse("text/plain"), originalBodyData))
  .build();
Response filteredResponse =
  .responseHeadersReceived(any(NetworkEventReporter.InspectorResponse.class));
String filteredResponseString = filteredResponse.body().string();
String interceptedOutput = capturedOutput.toString();

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

long contentLength = request.body().contentLength();
   CountingSink requestBodyOut =
     new CountingSink(httpCodec.createRequestBody(request, contentLength));
   BufferedSink bufferedRequestBody = Okio.buffer(requestBodyOut);
   request.body().writeTo(bufferedRequestBody);
   bufferedRequestBody.close();
   realChain.eventListener().requestBodyEnd(call, requestBodyOut.successfulCount);
Response response = responseBuilder.build();
int code = response.code();
if (code == 100) {
 response = responseBuilder.build();
 code = response.code();
 response = response.newBuilder()
   .body(Util.EMPTY_RESPONSE)
   .build();
if ((code == 204 || code == 205) && response.body().contentLength() > 0) {
 throw new ProtocolException(
   "HTTP " + code + " had non-zero Content-Length: " + response.body().contentLength());

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

RequestBody

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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