com.squareup.okhttp.RequestBody.create()方法的使用及代码示例

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

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

RequestBody.create介绍

暂无

代码示例

代码示例来源：origin: chentao0707/SimplifyReader

private static RequestBody createRequestBody(Request r) throws AuthFailureError {
    final byte[] body = r.getBody();
    if (body == null) return null;

    return RequestBody.create(MediaType.parse(r.getBodyContentType()), body);
  }
}

代码示例来源：origin: Javen205/IJPay

@Override
public String postSSL(String url, String data, String certPath, String certPass) {
  com.squareup.okhttp.RequestBody body = com.squareup.okhttp.RequestBody.create(CONTENT_TYPE_FORM, data);
  com.squareup.okhttp.Request request = new com.squareup.okhttp.Request.Builder().url(url).post(body).build();
  InputStream inputStream = null;
  try {
    // 移动到最开始，certPath io异常unlock会报错
    lock.lock();
    KeyStore clientStore = KeyStore.getInstance("PKCS12");
    inputStream = new FileInputStream(certPath);
    clientStore.load(inputStream, certPass.toCharArray());
    KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
    kmf.init(clientStore, certPass.toCharArray());
    KeyManager[] kms = kmf.getKeyManagers();
    SSLContext sslContext = SSLContext.getInstance("TLSv1");
    sslContext.init(kms, null, new SecureRandom());
    httpsClient.setSslSocketFactory(sslContext.getSocketFactory());
    com.squareup.okhttp.Response response = httpsClient.newCall(request).execute();
    if (!response.isSuccessful())
      throw new RuntimeException("Unexpected code " + response);
    return response.body().string();
  } catch (Exception e) {
    throw new RuntimeException(e);
  } finally {
    IOUtils.closeQuietly(inputStream);
    lock.unlock();
  }
}

代码示例来源：origin: Javen205/IJPay

@Override
public String postSSL(String url, String data, String certPass, InputStream certFile) {
  com.squareup.okhttp.RequestBody body = com.squareup.okhttp.RequestBody.create(CONTENT_TYPE_FORM, data);
  com.squareup.okhttp.Request request = new com.squareup.okhttp.Request.Builder().url(url).post(body).build();
  InputStream inputStream = certFile;
  try {
    // 移动到最开始，certPath io异常unlock会报错
    lock.lock();
    KeyStore clientStore = KeyStore.getInstance("PKCS12");
    clientStore.load(certFile, certPass.toCharArray());
    KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
    kmf.init(clientStore, certPass.toCharArray());
    KeyManager[] kms = kmf.getKeyManagers();
    SSLContext sslContext = SSLContext.getInstance("TLSv1");
    sslContext.init(kms, null, new SecureRandom());
    httpsClient.setSslSocketFactory(sslContext.getSocketFactory());
    com.squareup.okhttp.Response response = httpsClient.newCall(request).execute();
    if (!response.isSuccessful())
      throw new RuntimeException("Unexpected code " + response);
    return response.body().string();
  } catch (Exception e) {
    throw new RuntimeException(e);
  } finally {
    IOUtils.closeQuietly(inputStream);
    lock.unlock();
  }
}

代码示例来源：origin: TommyLemon/APIJSON

@Override
protected Exception doInBackground(Void... params) {
  try {
    String url = StringUtil.getNoBlankString(url_);
    OkHttpClient client = getHttpClient(url);
    if (client == null) {
      return new Exception(TAG + ".post  AsyncTask.doInBackground  client == null >> return;");
    }
    RequestBody requestBody = RequestBody.create(TYPE_JSON, request);
    result = getResponseJson(client, new Request.Builder()
    .addHeader(KEY_TOKEN, getToken(url)).url(StringUtil.getNoBlankString(url))
    .post(requestBody).build());
  } catch (Exception e) {
    Log.e(TAG, "post  AsyncTask.doInBackground  try {  result = getResponseJson(..." +
        "} catch (Exception e) {\n" + e.getMessage());
    return e;
  }
  return null;
}

代码示例来源：origin: commonsguy/cw-omnibus

private void uploadBackup(File backup) throws IOException {
 Request request=new Request.Builder()
  .url(URL_CREATE_BACKUP)
  .post(RequestBody.create(JSON, "{}"))
  .build();
 Response response=OKHTTP_CLIENT.newCall(request).execute();
   .put(RequestBody.create(ZIP, backup))
   .build();
  response=OKHTTP_CLIENT.newCall(request).execute();

代码示例来源：origin: Javen205/IJPay

@Override
public String post(String url, String params) {
  com.squareup.okhttp.RequestBody body = com.squareup.okhttp.RequestBody.create(CONTENT_TYPE_FORM, params);
  com.squareup.okhttp.Request request = new com.squareup.okhttp.Request.Builder().url(url).post(body).build();
  return exec(request);
}

代码示例来源：origin: spotify/apollo

.map(MediaType::parse)
   .orElse(DEFAULT_CONTENT_TYPE);
 return RequestBody.create(contentType, payload);
});

代码示例来源：origin: TommyLemon/APIJSON

@Override
protected Exception doInBackground(Void... params) {
  try {
    String url = StringUtil.getNoBlankString(url_);
    OkHttpClient client = getHttpClient(url);
    if (client == null) {
      return new Exception(TAG + ".post  AsyncTask.doInBackground  client == null >> return;");
    }
    String body = JSON.toJSONString(request);
    Log.d(TAG, "\n\n<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<\n post  url = " + url_ + "\n request = \n" + body);
    
    RequestBody requestBody = RequestBody.create(TYPE_JSON, body);
    result = getResponseJson(client, new Request.Builder()
        .addHeader(KEY_TOKEN, getToken(url)).url(StringUtil.getNoBlankString(url))
        .post(requestBody).build());
    Log.d(TAG, "\n post  result = \n" + result + "\n >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>\n\n");
  } catch (Exception e) {
    Log.e(TAG, "post  AsyncTask.doInBackground  try {  result = getResponseJson(..." +
        "} catch (Exception e) {\n" + e.getMessage());
    return e;
  }
  return null;
}

代码示例来源：origin: Javen205/IJPay

@Override
public String upload(String url, File file, String params) {
  com.squareup.okhttp.RequestBody fileBody = com.squareup.okhttp.RequestBody
      .create(com.squareup.okhttp.MediaType.parse("application/octet-stream"), file);
  com.squareup.okhttp.MultipartBuilder builder = new com.squareup.okhttp.MultipartBuilder()
      .type(com.squareup.okhttp.MultipartBuilder.FORM).addFormDataPart("media", file.getName(), fileBody);
  if (StrKit.notBlank(params)) {
    builder.addFormDataPart("description", params);
  }
  com.squareup.okhttp.RequestBody requestBody = builder.build();
  com.squareup.okhttp.Request request = new com.squareup.okhttp.Request.Builder().url(url).post(requestBody)
      .build();
  return exec(request);
}

代码示例来源：origin: Javen205/IJPay

@Override
public InputStream download(String url, String params) {
  com.squareup.okhttp.Request request;
  if (StrKit.notBlank(params)) {
    com.squareup.okhttp.RequestBody body = com.squareup.okhttp.RequestBody.create(CONTENT_TYPE_FORM,
        params);
    request = new com.squareup.okhttp.Request.Builder().url(url).post(body).build();
  } else {
    request = new com.squareup.okhttp.Request.Builder().url(url).get().build();
  }
  try {
    com.squareup.okhttp.Response response = httpClient.newCall(request).execute();
    if (!response.isSuccessful())
      throw new RuntimeException("Unexpected code " + response);
    return response.body().byteStream();
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}

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

.method(
    "POST",
    RequestBody.create(MediaType.parse("text/plain"), requestText))
  .build();
String originalBodyData = "Success!";

代码示例来源：origin: aa112901/remusic

String json = "{\"params\": \"9NdyZTlp0Q/f1E1ora4tGM0uLYXqh7MD0mk7632ilWQvRDPZ02UkHrGFUccwW4HZYpacpPnmE+oMr/HI/vhuQvg8zYKgDP6NOaXG8nKDJpQTfOAiXT5KDrJOvb7ejSj/\",  " +
    "\"encSecKey\": \"ae878167c394a959699c025a5c36043d0ae043c42d7f55fe4d1191c8ac9f3abe285b78c4a25ed6d9394a0ba0cb83a9a62de697199bd337f1de183bb07d6764a051495ea873ad615bb0a7e69f44d9168fc78ed1d61feb142ad06679dce58257ee9005756a18032ff499a4e24f7658bb59de2219f21f568301d43dba500e0c2d3b\"}";
RequestBody requestBody = RequestBody.create(MediaType.parse("JSON"), json);
Log.e("post", "p");
Request request = new Request.Builder()

代码示例来源：origin: chentao0707/SimplifyReader

builder.post(RequestBody.create(MediaType.parse(request.getPostBodyContentType()), postBody));

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

compressed.length, decompressed.length);
RequestBody compressedBody = RequestBody.create(
  MediaType.parse("text/plain"),
  compress(decompressed));

代码示例来源：origin: spinnaker/kayenta

RequestBody body = RequestBody.create(MediaType.parse("application/json"), json);
retry.retry(() -> remoteService.post(ownerApp, configType, objectKey, body), MAX_RETRIES, RETRY_BACKOFF);

代码示例来源：origin: cn-ljb/rxjava_for_android

/**
 * 初始化Body类型请求参数
 * init Body type params
 */
private RequestBody initRequestBody(Map<String, Object> params) {
  MultipartBuilder bodyBuilder = new MultipartBuilder().type(MultipartBuilder.FORM);
  Set<Map.Entry<String, Object>> entries = params.entrySet();
  for (Map.Entry<String, Object> entry : entries) {
    String key = entry.getKey();
    Object value = entry.getValue();
    if (value instanceof File) {
      File file = (File) value;
      try {
        FileNameMap fileNameMap = URLConnection.getFileNameMap();
        String mimeType = fileNameMap.getContentTypeFor(file.getAbsolutePath());
        XgoLog.w("mimeType::" + mimeType);
        bodyBuilder.addFormDataPart(key, file.getName(), RequestBody.create(MediaType.parse(mimeType), file));
      } catch (Exception e) {
        e.printStackTrace();
        XgoLog.e("mimeType is Error !");
      }
    } else {
      XgoLog.w(key + "::" + value);
      bodyBuilder.addFormDataPart(key, value.toString());
    }
  }
  return bodyBuilder.build();
}

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

private static RequestBody toBody(Object bean) {
  try {
    RequestBody body = RequestBody.create(JSON, writeMapper.writeValueAsString(bean));
    return body;
  } catch (JsonProcessingException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: com.squareup.retrofit/converter-gson

@Override public RequestBody convert(T value) throws IOException {
  Buffer buffer = new Buffer();
  Writer writer = new OutputStreamWriter(buffer.outputStream(), UTF_8);
  try {
   gson.toJson(value, type, writer);
   writer.flush();
  } catch (IOException e) {
   throw new AssertionError(e); // Writing to Buffer does no I/O.
  }
  return RequestBody.create(MEDIA_TYPE, buffer.readByteString());
 }
}

代码示例来源：origin: com.squareup.retrofit/converter-moshi

@Override public RequestBody convert(T value) throws IOException {
  Buffer buffer = new Buffer();
  try {
   adapter.toJson(buffer, value);
  } catch (IOException e) {
   throw new AssertionError(e); // Writing to Buffer does no I/O.
  }
  return RequestBody.create(MEDIA_TYPE, buffer.readByteString());
 }
}

代码示例来源：origin: boredream/DesignResCollection

@Override
public void onResourceReady(final byte[] resource, GlideAnimation<? super byte[]> glideAnimation) {
  // 上传图片
  RequestBody requestBody = RequestBody.create(MediaType.parse("image/jpeg"), resource);
  Observable<FileUploadResponse> observable = service.fileUpload(filename, requestBody);
  ObservableDecorator.decorate(observable)
      .subscribe(call);
}

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

RequestBody

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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