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

x33g5p2x  于2022-01-20 转载在 其他  
字(3.4k)|赞(0)|评价(0)|浏览(172)

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

HttpUrl.get介绍

暂无

代码示例

代码示例来源:origin: greenaddress/GreenBits

@Override
public InetSocketAddress[] getPeers(long services, long timeoutValue, TimeUnit timeoutUnit) throws PeerDiscoveryException {
  try {
    HttpUrl.Builder url = HttpUrl.get(details.uri).newBuilder();
    if (services != 0)
      url.addQueryParameter("srvmask", Long.toString(services));
    Request.Builder request = new Request.Builder();
    request.url(url.build());
    request.addHeader("User-Agent", VersionMessage.LIBRARY_SUBVER); // TODO Add main version.
    log.info("Requesting seeds from {}", url);
    Response response = client.newCall(request.build()).execute();
    if (!response.isSuccessful())
      throw new PeerDiscoveryException("HTTP request failed: " + response.code() + " " + response.message());
    InputStream stream = response.body().byteStream();
    GZIPInputStream zip = new GZIPInputStream(stream);
    PeerSeedProtos.SignedPeerSeeds proto = PeerSeedProtos.SignedPeerSeeds.parseDelimitedFrom(zip);
    stream.close();
    return protoToAddrs(proto);
  } catch (PeerDiscoveryException e1) {
    throw e1;
  } catch (Exception e) {
    throw new PeerDiscoveryException(e);
  }
}

代码示例来源:origin: cash.bitcoinj/bitcoinj-core

@Override
public InetSocketAddress[] getPeers(long services, long timeoutValue, TimeUnit timeoutUnit) throws PeerDiscoveryException {
  try {
    HttpUrl.Builder url = HttpUrl.get(details.uri).newBuilder();
    if (services != 0)
      url.addQueryParameter("srvmask", Long.toString(services));
    Request.Builder request = new Request.Builder();
    request.url(url.build());
    request.addHeader("User-Agent", VersionMessage.LIBRARY_SUBVER); // TODO Add main version.
    log.info("Requesting seeds from {}", url);
    Response response = client.newCall(request.build()).execute();
    if (!response.isSuccessful())
      throw new PeerDiscoveryException("HTTP request failed: " + response.code() + " " + response.message());
    InputStream stream = response.body().byteStream();
    GZIPInputStream zip = new GZIPInputStream(stream);
    PeerSeedProtos.SignedPeerSeeds proto;
    try {
      proto = PeerSeedProtos.SignedPeerSeeds.parseDelimitedFrom(zip);
    } finally {
      zip.close(); // will close InputStream as well
    }
    return protoToAddrs(proto);
  } catch (PeerDiscoveryException e1) {
    throw e1;
  } catch (Exception e) {
    throw new PeerDiscoveryException(e);
  }
}

代码示例来源:origin: HashEngineering/dashj

@Override
public InetSocketAddress[] getPeers(long services, long timeoutValue, TimeUnit timeoutUnit) throws PeerDiscoveryException {
  try {
    HttpUrl.Builder url = HttpUrl.get(details.uri).newBuilder();
    if (services != 0)
      url.addQueryParameter("srvmask", Long.toString(services));
    Request.Builder request = new Request.Builder();
    request.url(url.build());
    request.addHeader("User-Agent", VersionMessage.LIBRARY_SUBVER); // TODO Add main version.
    log.info("Requesting seeds from {}", url);
    Response response = client.newCall(request.build()).execute();
    if (!response.isSuccessful())
      throw new PeerDiscoveryException("HTTP request failed: " + response.code() + " " + response.message());
    InputStream stream = response.body().byteStream();
    GZIPInputStream zip = new GZIPInputStream(stream);
    PeerSeedProtos.SignedPeerSeeds proto;
    try {
      proto = PeerSeedProtos.SignedPeerSeeds.parseDelimitedFrom(zip);
    } finally {
      zip.close(); // will close InputStream as well
    }
    return protoToAddrs(proto);
  } catch (PeerDiscoveryException e1) {
    throw e1;
  } catch (Exception e) {
    throw new PeerDiscoveryException(e);
  }
}

相关文章

微信公众号

最新文章

更多