com.squareup.okhttp.Call类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(11.0k)|赞(0)|评价(0)|浏览(228)

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

Call介绍

暂无

代码示例

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

  1. /**
  2.  * @param client
  3.  * @param request
  4.  * @return
  5.  * @throws Exception
  6.  */
  7. private String getResponseJson(OkHttpClient client, Request request) throws Exception {
  8.   if (client == null || request == null) {
  9.     Log.e(TAG, "getResponseJson  client == null || request == null >> return null;");
  10.     return null;
  11.   }
  12.   Response response = client.newCall(request).execute();
  13.   return response.isSuccessful() ? response.body().string() : null;
  14. }

代码示例来源：origin: xinghongfei/LookLook

  1. private void deliveryResult(final ResultCallback callback, Request request) {
  2.   mOkHttpClient.newCall(request).enqueue(new Callback() {
  3.     @Override
  4.     public void onFailure(Request request, final IOException e) {
  5.       sendFailCallback(callback, e);
  6.     }
  7.     @Override
  8.     public void onResponse(Response response) throws IOException {
  9.       try {
  10.         String str = response.body().string();
  11.         if (callback.mType == String.class) {
  12.           sendSuccessCallBack(callback, str);
  13.         } else {
  14.           Object object = JsonUtils.deserialize(str, callback.mType);
  15.           sendSuccessCallBack(callback, object);
  16.         }
  17.       } catch (final Exception e) {
  18.         sendFailCallback(callback, e);
  19.       }
  20.     }
  21.   });
  22. }

代码示例来源：origin: wangdan/AisenWeiBo

  1. @Override
  2. public boolean cancel(boolean mayInterruptIfRunning) {
  3.   // 停止网络请求，如果不为空
  4.   try {
  5.     if (mCall != null) {
  6.       mCall.cancel();
  7.     }
  8.   } catch (Throwable e) {
  9.   }
  10.   return super.cancel(mayInterruptIfRunning);
  11. }

代码示例来源：origin: nostra13/Android-Universal-Image-Loader

  1. @Override
  2.   protected InputStream getStreamFromNetwork(String imageUri, Object extra) throws IOException {
  3.     Request request = new Request.Builder().url(imageUri).build();
  4.     ResponseBody responseBody = client.newCall(request).execute().body();
  5.     InputStream inputStream = responseBody.byteStream();
  6.     int contentLength = (int) responseBody.contentLength();
  7.     return new ContentLengthInputStream(inputStream, contentLength);
  8.   }
  9. }

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

  1. public static String getResposeString(String action1) {
  2.     try {
  3.       mOkHttpClient.setConnectTimeout(1000, TimeUnit.MINUTES);
  4.       mOkHttpClient.setReadTimeout(1000, TimeUnit.MINUTES);
  5.       Request request = new Request.Builder()
  6.           .url(action1)
  7.           .build();
  8.       Response response = mOkHttpClient.newCall(request).execute();
  9.       if (response.isSuccessful()) {
  10.         String c = response.body().string();
  11.         Log.e("billboard", c);
  12.         return c;
  13.       }
  15.     } catch (Exception e) {
  16.       e.printStackTrace();
  17.     }
  19. //       mOkHttpClient.setCookieHandler(new CookieManager(
  20. //                new PersistentCookieStore(getContext().getApplicationContext()),
  21. //                CookiePolicy.ACCEPT_ALL));
  23.     return null;
  24.   }

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

  1. public static Bitmap getBitmapStream(Context context, String url, boolean forceCache) {
  2.   try {
  3.     File sdcache = context.getExternalCacheDir();
  4.     //File cacheFile = new File(context.getCacheDir(), "[缓存目录]");
  5.     Cache cache = new Cache(sdcache.getAbsoluteFile(), 1024 * 1024 * 30); //30Mb
  6.     mOkHttpClient.setCache(cache);
  7.     mOkHttpClient.setConnectTimeout(1000, TimeUnit.MINUTES);
  8.     mOkHttpClient.setReadTimeout(1000, TimeUnit.MINUTES);
  9.     Request.Builder builder = new Request.Builder()
  10.         .url(url);
  11.     if (forceCache) {
  12.       builder.cacheControl(CacheControl.FORCE_CACHE);
  13.     }
  14.     Request request = builder.build();
  15.     Response response = mOkHttpClient.newCall(request).execute();
  16.     if (response.isSuccessful()) {
  17.       return _decodeBitmapFromStream(response.body().byteStream(), 160, 160);
  18.     }
  19.   } catch (Exception e) {
  20.     e.printStackTrace();
  21.   }
  22.   return null;
  23. }

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

  1. public static void getOut(final String url) {
  2.   try {
  3.     mOkHttpClient.setConnectTimeout(1000, TimeUnit.MINUTES);
  4.     mOkHttpClient.setReadTimeout(1000, TimeUnit.MINUTES);
  5.     Request request = new Request.Builder()
  6.         .url(url)
  7.         .build();
  8.     Response response = mOkHttpClient.newCall(request).execute();
  9.     if (response.isSuccessful()) {
  10.       FileOutputStream fo = new FileOutputStream("/storage/emulated/0/" + "gedangein" + ".json");
  11.       byte[] c = new byte[1024];
  12.       while (response.body().source().read(c) != -1) {
  13.         fo.write(c);
  14.       }
  15.     }
  16.   } catch (Exception e) {
  17.     e.printStackTrace();
  18.   }
  19. }

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

  1. @Override
  2.  public void run() {
  3.   try {
  4.    OkHttpClient client=new OkHttpClient();
  5.    Request request=new Request.Builder().url(SO_URL).build();
  6.    Response response=client.newCall(request).execute();
  8.    if (response.isSuccessful()) {
  9.     Reader in=response.body().charStream();
  10.     BufferedReader reader=new BufferedReader(in);
  11.     SOQuestions questions=
  12.       new Gson().fromJson(reader, SOQuestions.class);
  14.     reader.close();
  16.     EventBus.getDefault().post(new QuestionsLoadedEvent(questions));
  17.    }
  18.    else {
  19.     Log.e(getClass().getSimpleName(), response.toString());
  20.    }
  21.   }
  22.   catch (Exception e) {
  23.    Log.e(getClass().getSimpleName(), "Exception parsing JSON", e);
  24.   }
  25.  }
  26. }

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

  1. @Test
  2. public void testWithResponseCompression() throws IOException {
  3.  ByteArrayOutputStream capturedOutput = hookAlmostRealInterpretResponseStream(mMockEventReporter);
  4.  byte[] uncompressedData = repeat(".", 1024).getBytes();
  5.  byte[] compressedData = compress(uncompressedData);
  6.  MockWebServer server = new MockWebServer();
  7.  server.start();
  8.  server.enqueue(new MockResponse()
  9.    .setBody(new Buffer().write(compressedData))
  10.    .addHeader("Content-Encoding: gzip"));
  11.  Request request = new Request.Builder()
  12.    .url(server.url("/"))
  13.    .build();
  14.  Response response = mClientWithInterceptor.newCall(request).execute();
  15.  // Verify that the final output and the caller both saw the uncompressed stream.
  16.  assertArrayEquals(uncompressedData, response.body().bytes());
  17.  assertArrayEquals(uncompressedData, capturedOutput.toByteArray());
  18.  // And verify that the StethoInterceptor was able to see both.
  19.  Mockito.verify(mMockEventReporter)
  20.    .dataReceived(
  21.      anyString(),
  22.      eq(compressedData.length),
  23.      eq(uncompressedData.length));
  24.  server.shutdown();
  25. }

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

  1. throws IOException, AuthFailureError {
  2. OkHttpClient client = mClient.clone();
  3. int timeoutMs = request.getTimeoutMs();
  4. client.setConnectTimeout(timeoutMs, TimeUnit.MILLISECONDS);
  5. client.setReadTimeout(timeoutMs, TimeUnit.MILLISECONDS);
  6. client.setWriteTimeout(timeoutMs, TimeUnit.MILLISECONDS);
  7. Call okHttpCall = client.newCall(okHttpRequest);
  8. Response okHttpResponse = okHttpCall.execute();
  9. StatusLine responseStatus = new BasicStatusLine(parseProtocol(okHttpResponse.protocol()), okHttpResponse.code(), okHttpResponse.message());
  10. BasicHttpResponse response = new BasicHttpResponse(responseStatus);
  11. response.setEntity(entityFromOkHttpResponse(okHttpResponse));

代码示例来源：origin: BolexLiu/AutoEx

  1. public static void dogetHttp3(final String urls, final HResponse mHResponse) {
  2.     try {
  3.       OkHttpClient client = new OkHttpClient();
  4.       client.setConnectTimeout(10, TimeUnit.SECONDS);
  5.       client.setReadTimeout(60, TimeUnit.SECONDS);
  6.       Request build1 = new Request.Builder().url(urls).get().build();
  8.       Response execute = client.newCall(build1).execute();
  9.       if (execute == null || execute.body() == null) {
  10.         mHResponse.onError("没有找到任何可参考的，真可惜。");
  11.         return;
  12.       }
  13.       String string = execute.body().string();
  14.       mHResponse.onFinish(string);
  15.     } catch (IOException e) {
  16.       e.printStackTrace();
  17.       mHResponse.onError(e.getMessage());
  18.     }
  19.   }
  20. }

代码示例来源：origin: wangdan/AisenWeiBo

  1. mCall = httpClient.newCall(request);
  2. Response response = mCall.execute();
  3. if (response == null) {
  4.   throw new TaskException(TaskException.TaskError.failIOError.toString());
  5. int statusCode = response.code();
  6. if (!(statusCode == HttpURLConnection.HTTP_OK || statusCode == HttpURLConnection.HTTP_PARTIAL)) {
  7.   throw new TaskException(TaskException.TaskError.failIOError.toString());
  8.   String encoding = response.header("Content-Encoding");
  9.   if (encoding != null && !TextUtils.isEmpty(encoding) &&
  10.       "gzip".equals(encoding)) {
  11.     imageStream = new GZIPInputStream(response.body().byteStream());
  12.     Logger.w(TAG, "解压gzip文件, 解压前大小:");
  13.   } else {
  14.     imageStream = response.body().byteStream();
  15.     total = response.body().contentLength();
  16.   } catch (Exception e) {

代码示例来源：origin: org.echocat.marquardt/client

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public boolean signOut(final Certificate<SIGNABLE> certificate) throws IOException {
  6.   final Request request = sendRequestWithCertificateHeader(_baseUri + "/auth/signOut", POST_METHOD, certificate);
  7.   final Response response = _addSignedHeaderHttpClient.newCall(request).execute();
  8.   if (response.code() != NO_CONTENT_STATUS) {
  9.     throw ResponseStatusTranslation.from(response.code()).translateToException(response.message());
  10.   }
  11.   return true;
  12. }

代码示例来源：origin: io.macgyver/macgyver-core

  1. public List<X509Certificate> fetchCertificates(String httpUrl)
  2.     throws IOException {
  3.   OkHttpClient c = new OkHttpClient();
  4.   CertExtractor extractor = new CertExtractor();
  5.   c.setHostnameVerifier(extractor);
  6.   c.setSslSocketFactory(SslTrust.withoutCertificateValidation()
  7.       .getSocketFactory());
  8.   Request r = new Request.Builder().url(httpUrl).build();
  9.   Response response = c.newCall(r).execute();
  10.   response.body().close();
  11.   return extractor.certList;
  12. }

代码示例来源：origin: com.dropbox.core/dropbox-core-sdk

  1. @Override
  2. public Response doGet(String url, Iterable<Header> headers) throws IOException {
  3.   Request.Builder builder = new Request.Builder().get().url(url);
  4.   toOkHttpHeaders(headers, builder);
  5.   configureRequest(builder);
  6.   com.squareup.okhttp.Response response = client.newCall(builder.build()).execute();
  7.   response = interceptResponse(response);
  8.   Map<String, List<String>> responseHeaders = fromOkHttpHeaders(response.headers());
  9.   return new Response(response.code(), response.body().byteStream(), responseHeaders);
  10. }

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

  1. @Override
  2. public void onHandleWork(@NonNull Intent i) {
  3.  Request request=new Request.Builder()
  4.   .url(i.getData().toString())
  5.   .build();
  6.  try {
  7.   Response response=
  8.    BackupService.OKHTTP_CLIENT.newCall(request).execute();
  9.   File toRestore=new File(getCacheDir(), "backup.zip");
  10.   if (toRestore.exists()) {
  11.    toRestore.delete();
  12.   }
  13.   BufferedSink sink = Okio.buffer(Okio.sink(toRestore));
  14.   sink.writeAll(response.body().source());
  15.   sink.close();
  16.   ZipUtils.unzip(toRestore, getFilesDir(),
  17.    BackupService.ZIP_PREFIX_FILES);
  18.   ZipUtils.unzip(toRestore,
  19.    BackupService.getSharedPrefsDir(this),
  20.    BackupService.ZIP_PREFIX_PREFS);
  21.   ZipUtils.unzip(toRestore, getExternalFilesDir(null),
  22.    BackupService.ZIP_PREFIX_EXTERNAL);
  23.   EventBus.getDefault().post(new RestoreCompletedEvent());
  24.  }
  25.  catch (Exception e) {
  26.   Log.e(getClass().getSimpleName(),
  27.    "Exception restoring backup", e);
  28.   EventBus.getDefault().post(new RestoreFailedEvent());
  29.  }
  30. }

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

  1. .post(RequestBody.create(JSON, "{}"))
  2.  .build();
  3. Response response=OKHTTP_CLIENT.newCall(request).execute();
  4. if (response.code()==201) {
  5.  String backupURL=response.header("Location");
  6.   .put(RequestBody.create(ZIP, backup))
  7.   .build();
  8.  response=OKHTTP_CLIENT.newCall(request).execute();
  9.  if (response.code()==201) {
  10.   String datasetURL=response.header("Location");
  11.   SharedPreferences prefs=

代码示例来源：origin: survivingwithandroid/Surviving-with-android

  1. OkHttpClient client = new OkHttpClient();
  2. Request req = new Request.Builder().addHeader("X-Auth-Token", apiKey)
  3.     .url("http://things.ubidots.com/api/v1.6/variables/" + varId + "/values")
  4.     .build();
  5. client.newCall(req).enqueue(new Callback() {
  6.   @Override
  7.   public void onFailure(Request request, IOException e) {

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

  1. && client.getReadTimeout() != apolloRequest.ttl().get().toMillis()) {
  2.  finalClient = client.clone();
  3.  finalClient.setReadTimeout(apolloRequest.ttl().get().toMillis(), TimeUnit.MILLISECONDS);
  4. finalClient.newCall(request).enqueue(TransformingCallback.create(result));

代码示例来源：origin: licheedev/Custom-Glide-ModelLoader-Demo

  1. private InputStream fetchStream(String url) {
  2.   // 缓存请求，用来及时取消连接
  3.   mFetchStreamCall = syncGet(url);
  4.   try {
  5.     return mFetchStreamCall.execute().body().byteStream();
  6.   } catch (IOException e) {
  7.     //e.printStackTrace();
  8.   }
  9.   return null;
  10. }

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

Call

相关文章

    查看更多

    热门标签

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

    最新文章

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