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

x33g5p2x  于2022-02-01 转载在 其他  
字(11.7k)|赞(0)|评价(0)|浏览(229)

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

Util介绍

暂无

代码示例

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

  1. public static FilterInputStream getFromCache(Context context, String url) throws Exception {
  2.   //  File cacheDirectory = new File("/storage/emulated/0/Android/data/com.name.demo .dev/cache/HttpCache");
  3.   File cacheDirectory = context.getExternalCacheDir();
  4.   DiskLruCache cache = DiskLruCache.create(FileSystem.SYSTEM, cacheDirectory, 201105, 2, 1024 * 1024 * 30);
  5.   cache.flush();
  6.   String key = Util.md5Hex(url);
  7.   final DiskLruCache.Snapshot snapshot;
  8.   try {
  9.     snapshot = cache.get(key);
  10.     if (snapshot == null) {
  11.       return null;
  12.     }
  13.   } catch (IOException e) {
  14.     return null;
  15.   }
  16.   okio.Source source = snapshot.getSource(1);
  17.   BufferedSource metadata = Okio.buffer(source);
  18.   FilterInputStream bodyIn = new FilterInputStream(metadata.inputStream()) {
  19.     @Override
  20.     public void close() throws IOException {
  21.       snapshot.close();
  22.       super.close();
  23.     }
  24.   };
  25.   return bodyIn;
  26. }

代码示例来源：origin: evernote/evernote-sdk-android

  1. @Override
  2.   public void close() {
  3.     Util.closeQuietly(mResponseBody);
  4.     mResponseBody = null;
  5.   }
  6. }

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

  1. private void handleWebSocketUpgrade(Socket socket, BufferedSource source, BufferedSink sink,
  2.   RecordedRequest request, MockResponse response) throws IOException {
  3.  String key = request.getHeader("Sec-WebSocket-Key");
  4.  String acceptKey = Util.shaBase64(key + WebSocketProtocol.ACCEPT_MAGIC);
  5.  response.setHeader("Sec-WebSocket-Accept", acceptKey);
  6.      Util.threadFactory(String.format("MockWebServer %s WebSocket", request.getPath()),
  7.        true));
  8.  replyExecutor.allowCoreThreadTimeOut(true);
  9.  Util.closeQuietly(sink);
  10.  Util.closeQuietly(source);

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

  1. /**
  2.  * Indicates the protocols supported by ALPN on incoming HTTPS
  3.  * connections. This list is ignored when
  4.  * {@link #setProtocolNegotiationEnabled negotiation is disabled}.
  5.  *
  6.  * @param protocols the protocols to use, in order of preference. The list
  7.  *     must contain {@linkplain Protocol#HTTP_1_1}. It must not contain null.
  8.  */
  9. public void setProtocols(List<Protocol> protocols) {
  10.  protocols = Util.immutableList(protocols);
  11.  if (!protocols.contains(Protocol.HTTP_1_1)) {
  12.   throw new IllegalArgumentException("protocols doesn't contain http/1.1: " + protocols);
  13.  }
  14.  if (protocols.contains(null)) {
  15.   throw new IllegalArgumentException("protocols must not contain null");
  16.  }
  17.  this.protocols = protocols;
  18. }

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

  1. private void createWebSocket(Response response, WebSocketListener listener) throws IOException {
  2.  if (response.code() != 101) {
  3.   Util.closeQuietly(response.body());
  4.   throw new ProtocolException("Expected HTTP 101 response but was '"
  5.     + response.code()
  6.  String acceptExpected = Util.shaBase64(key + WebSocketProtocol.ACCEPT_MAGIC);
  7.  if (!acceptExpected.equals(headerAccept)) {
  8.   throw new ProtocolException("Expected 'Sec-WebSocket-Accept' header value '"

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

  1. static RealWebSocket create(StreamAllocation streamAllocation, Response response,
  2.   Random random, WebSocketListener listener) {
  3.  String url = response.request().urlString();
  4.  ThreadPoolExecutor replyExecutor =
  5.    new ThreadPoolExecutor(1, 1, 1, SECONDS, new LinkedBlockingDeque<Runnable>(),
  6.      Util.threadFactory(String.format("OkHttp %s WebSocket", url), true));
  7.  replyExecutor.allowCoreThreadTimeOut(true);
  8.  return new StreamWebSocket(streamAllocation, random, replyExecutor, listener, url);
  9. }

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

  1. @Override public final Permission getPermission() throws IOException {
  2.  String hostName = getURL().getHost();
  3.  int hostPort = Util.getEffectivePort(getURL());
  4.  if (usingProxy()) {
  5.   InetSocketAddress proxyAddress = (InetSocketAddress) client.getProxy().address();
  6.   hostName = proxyAddress.getHostName();
  7.   hostPort = proxyAddress.getPort();
  8.  }
  9.  return new SocketPermission(hostName + ":" + hostPort, "connect, resolve");
  10. }

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

  1. private String defaultUserAgent() {
  2.  String agent = System.getProperty("http.agent");
  3.  return agent != null ? Util.toHumanReadableAscii(agent) : Version.userAgent();
  4. }

代码示例来源：origin: evernote/evernote-sdk-android

  1. private static void readFile(File file, byte[] buffer, int length) throws IOException {
  2.   InputStream inputStream = null;
  3.   try {
  4.     inputStream = new FileInputStream(file);
  5.     int read = 0;
  6.     int offset = 0;
  7.     while (length > 0 && read >= 0) {
  8.       read = inputStream.read(buffer, offset, length);
  9.       offset += read;
  10.       length -= read;
  11.     }
  12.   } finally {
  13.     Util.closeQuietly(inputStream);
  14.   }
  15. }

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

  1. /**
  2.  * Constructor.
  3.  * @param metricsServer
  4.  */
  5. public HawkularMetricsClient(URL metricsServer) {
  6.   this.serverUrl = metricsServer;
  7.   httpClient = new OkHttpClient();
  8.   httpClient.setReadTimeout(DEFAULT_READ_TIMEOUT, TimeUnit.SECONDS);
  9.   httpClient.setWriteTimeout(DEFAULT_WRITE_TIMEOUT, TimeUnit.SECONDS);
  10.   httpClient.setConnectTimeout(DEFAULT_CONNECT_TIMEOUT, TimeUnit.SECONDS);
  11.   httpClient.setFollowRedirects(true);
  12.   httpClient.setFollowSslRedirects(true);
  13.   httpClient.setProxySelector(ProxySelector.getDefault());
  14.   httpClient.setCookieHandler(CookieHandler.getDefault());
  15.   httpClient.setCertificatePinner(CertificatePinner.DEFAULT);
  16.   httpClient.setAuthenticator(AuthenticatorAdapter.INSTANCE);
  17.   httpClient.setConnectionPool(ConnectionPool.getDefault());
  18.   httpClient.setProtocols(Util.immutableList(Protocol.HTTP_1_1));
  19.   httpClient.setConnectionSpecs(DEFAULT_CONNECTION_SPECS);
  20.   httpClient.setSocketFactory(SocketFactory.getDefault());
  21.   Internal.instance.setNetwork(httpClient, Network.DEFAULT);
  22. }

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

  1. started = true;
  2. executor = Executors.newCachedThreadPool(Util.threadFactory("MockWebServer", false));
  3. this.inetSocketAddress = inetSocketAddress;
  4. serverSocket = serverSocketFactory.createServerSocket();

代码示例来源：origin: io.apiman/apiman-gateway-platforms-servlet

  1. @Override public final Permission getPermission() throws IOException {
  2.  String hostName = getURL().getHost();
  3.  int hostPort = Util.getEffectivePort(getURL());
  4.  if (usingProxy()) {
  5.   InetSocketAddress proxyAddress = (InetSocketAddress) client.getProxy().address();
  6.   hostName = proxyAddress.getHostName();
  7.   hostPort = proxyAddress.getPort();
  8.  }
  9.  return new SocketPermission(hostName + ":" + hostPort, "connect, resolve");
  10. }

代码示例来源：origin: evernote/evernote-sdk-android

  1. @Override
  2. public void close() throws IOException {
  3.   if (!mClosed) {
  4.     Util.closeQuietly(mFileOutputStream);
  5.     mByteArrayOutputStream.reset();
  6.     mClosed = true;
  7.   }
  8. }

代码示例来源：origin: io.apiman/apiman-common-net

  1. /**
  2.  * Constructor.
  3.  * @param metricsServer
  4.  */
  5. public HawkularMetricsClient(URL metricsServer) {
  6.   this.serverUrl = metricsServer;
  7.   httpClient = new OkHttpClient();
  8.   httpClient.setReadTimeout(DEFAULT_READ_TIMEOUT, TimeUnit.SECONDS);
  9.   httpClient.setWriteTimeout(DEFAULT_WRITE_TIMEOUT, TimeUnit.SECONDS);
  10.   httpClient.setConnectTimeout(DEFAULT_CONNECT_TIMEOUT, TimeUnit.SECONDS);
  11.   httpClient.setFollowRedirects(true);
  12.   httpClient.setFollowSslRedirects(true);
  13.   httpClient.setProxySelector(ProxySelector.getDefault());
  14.   httpClient.setCookieHandler(CookieHandler.getDefault());
  15.   httpClient.setCertificatePinner(CertificatePinner.DEFAULT);
  16.   httpClient.setAuthenticator(AuthenticatorAdapter.INSTANCE);
  17.   httpClient.setConnectionPool(ConnectionPool.getDefault());
  18.   httpClient.setProtocols(Util.immutableList(Protocol.HTTP_1_1));
  19.   httpClient.setConnectionSpecs(DEFAULT_CONNECTION_SPECS);
  20.   httpClient.setSocketFactory(SocketFactory.getDefault());
  21.   Internal.instance.setNetwork(httpClient, Network.DEFAULT);
  22. }

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

  1. @Override protected void execute() {
  2.  try {
  3.   logger.info(MockWebServer.this + " starting to accept connections");
  4.   acceptConnections();
  5.  } catch (Throwable e) {
  6.   logger.log(Level.WARNING, MockWebServer.this + " failed unexpectedly", e);
  7.  }
  8.  // Release all sockets and all threads, even if any close fails.
  9.  Util.closeQuietly(serverSocket);
  10.  for (Iterator<Socket> s = openClientSockets.iterator(); s.hasNext(); ) {
  11.   Util.closeQuietly(s.next());
  12.   s.remove();
  13.  }
  14.  for (Iterator<FramedConnection> s = openFramedConnections.iterator(); s.hasNext(); ) {
  15.   Util.closeQuietly(s.next());
  16.   s.remove();
  17.  }
  18.  executor.shutdown();
  19. }

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

  1. /**
  2.  * @return a new http client
  3.  */
  4. private OkHttpClient createHttpClient() {
  5.   OkHttpClient client = new OkHttpClient();
  6.   client.setReadTimeout(connectorOptions.getReadTimeout(), TimeUnit.SECONDS);
  7.   client.setWriteTimeout(connectorOptions.getWriteTimeout(), TimeUnit.SECONDS);
  8.   client.setConnectTimeout(connectorOptions.getConnectTimeout(), TimeUnit.SECONDS);
  9.   client.setFollowRedirects(connectorOptions.isFollowRedirects());
  10.   client.setFollowSslRedirects(connectorOptions.isFollowRedirects());
  11.   client.setProxySelector(ProxySelector.getDefault());
  12.   client.setCookieHandler(CookieHandler.getDefault());
  13.   client.setCertificatePinner(CertificatePinner.DEFAULT);
  14.   client.setAuthenticator(AuthenticatorAdapter.INSTANCE);
  15.   client.setConnectionPool(ConnectionPool.getDefault());
  16.   client.setProtocols(Util.immutableList(Protocol.HTTP_1_1));
  17.   client.setConnectionSpecs(DEFAULT_CONNECTION_SPECS);
  18.   client.setSocketFactory(SocketFactory.getDefault());
  19.   Internal.instance.setNetwork(client, Network.DEFAULT);
  20.   return client;
  21. }

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

  1. private void run() throws Exception {
  2.  ServerSocket serverSocket = new ServerSocket(8888);
  3.  serverSocket.setReuseAddress(true);
  4.  while (true) {
  5.   Socket socket = null;
  6.   try {
  7.    socket = serverSocket.accept();
  8.    SSLSocket sslSocket = doSsl(socket);
  9.    String protocolString = Platform.get().getSelectedProtocol(sslSocket);
  10.    Protocol protocol = protocolString != null ? Protocol.get(protocolString) : null;
  11.    if (protocol == null || !framedProtocols.contains(protocol)) {
  12.     throw new ProtocolException("Protocol " + protocol + " unsupported");
  13.    }
  14.    FramedConnection framedConnection = new FramedConnection.Builder(false)
  15.      .socket(sslSocket)
  16.      .protocol(protocol)
  17.      .listener(this)
  18.      .build();
  19.    framedConnection.sendConnectionPreface();
  20.   } catch (IOException e) {
  21.    logger.log(Level.INFO, "FramedServer connection failure: " + e);
  22.    Util.closeQuietly(socket);
  23.   } catch (Exception e) {
  24.    logger.log(Level.WARNING, "FramedServer unexpected failure", e);
  25.    Util.closeQuietly(socket);
  26.   }
  27.  }
  28. }

代码示例来源：origin: io.apiman/apiman-gateway-platforms-servlet

  1. /**
  2.  * @return a new http client
  3.  */
  4. private OkHttpClient createHttpClient() {
  5.   OkHttpClient client = new OkHttpClient();
  6.   client.setReadTimeout(connectorOptions.getReadTimeout(), TimeUnit.SECONDS);
  7.   client.setWriteTimeout(connectorOptions.getWriteTimeout(), TimeUnit.SECONDS);
  8.   client.setConnectTimeout(connectorOptions.getConnectTimeout(), TimeUnit.SECONDS);
  9.   client.setFollowRedirects(connectorOptions.isFollowRedirects());
  10.   client.setFollowSslRedirects(connectorOptions.isFollowRedirects());
  11.   client.setProxySelector(ProxySelector.getDefault());
  12.   client.setCookieHandler(CookieHandler.getDefault());
  13.   client.setCertificatePinner(CertificatePinner.DEFAULT);
  14.   client.setAuthenticator(AuthenticatorAdapter.INSTANCE);
  15.   client.setConnectionPool(ConnectionPool.getDefault());
  16.   client.setProtocols(Util.immutableList(Protocol.HTTP_1_1));
  17.   client.setConnectionSpecs(DEFAULT_CONNECTION_SPECS);
  18.   client.setSocketFactory(SocketFactory.getDefault());
  19.   Internal.instance.setNetwork(client, Network.DEFAULT);
  20.   return client;
  21. }

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

  1. private void serveFile(FramedStream stream, File file) throws IOException {
  2.  List<Header> responseHeaders = Arrays.asList(
  3.    new Header(":status", "200"),
  4.    new Header(":version", "HTTP/1.1"),
  5.    new Header("content-type", contentType(file))
  6.  );
  7.  stream.reply(responseHeaders, true);
  8.  Source source = Okio.source(file);
  9.  try {
  10.   BufferedSink out = Okio.buffer(stream.getSink());
  11.   out.writeAll(source);
  12.   out.close();
  13.  } finally {
  14.   Util.closeQuietly(source);
  15.  }
  16. }

代码示例来源：origin: liferay/liferay-mobile-sdk

  1. public static void transfer(
  2.     InputStream is, FileProgressCallback callback, Object tag,
  3.     BufferedSink sink)
  4.   throws IOException {
  5.   Source source = null;
  6.   try {
  7.     source = Okio.source(is);
  8.     Buffer os = new Buffer();
  9.     while ((source.read(os, 2048) != -1) && !isCancelled(callback)) {
  10.       byte[] bytes = os.readByteArray();
  11.       if (sink != null) {
  12.         sink.write(bytes);
  13.       }
  14.       if (callback != null) {
  15.         callback.onBytes(bytes);
  16.         callback.increment(bytes.length);
  17.       }
  18.     }
  19.     if (isCancelled(callback)) {
  20.       HttpUtil.cancel(tag);
  21.     }
  22.   }
  23.   finally {
  24.     Util.closeQuietly(source);
  25.   }
  26. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

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