com.google.api.client.http.HttpResponse.download()方法的使用及代码示例

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

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

HttpResponse.download介绍

暂无

代码示例

代码示例来源:origin: googleapis/google-cloud-java

httpResponse.download(output);

代码示例来源:origin: googleapis/google-cloud-java

@Override
public byte[] load(StorageObject from, Map<Option, ?> options) {
 Span span = startSpan(HttpStorageRpcSpans.SPAN_NAME_LOAD);
 Scope scope = tracer.withSpan(span);
 try {
  Storage.Objects.Get getRequest =
    storage
      .objects()
      .get(from.getBucket(), from.getName())
      .setGeneration(from.getGeneration())
      .setIfMetagenerationMatch(Option.IF_METAGENERATION_MATCH.getLong(options))
      .setIfMetagenerationNotMatch(Option.IF_METAGENERATION_NOT_MATCH.getLong(options))
      .setIfGenerationMatch(Option.IF_GENERATION_MATCH.getLong(options))
      .setIfGenerationNotMatch(Option.IF_GENERATION_NOT_MATCH.getLong(options))
      .setUserProject(Option.USER_PROJECT.getString(options));
  setEncryptionHeaders(getRequest.getRequestHeaders(), ENCRYPTION_KEY_PREFIX, options);
  ByteArrayOutputStream out = new ByteArrayOutputStream();
  getRequest.executeMedia().download(out);
  return out.toByteArray();
 } catch (IOException ex) {
  span.setStatus(Status.UNKNOWN.withDescription(ex.getMessage()));
  throw translate(ex);
 } finally {
  scope.close();
  span.end();
 }
}

代码示例来源:origin: com.google.api-client/google-api-client

/**
 * Sends the metadata request to the server and writes the metadata content input stream of
 * {@link HttpResponse} into the given destination output stream.
 *
 * <p>
 * This method closes the content of the HTTP response from {@link HttpResponse#getContent()}.
 * </p>
 *
 * <p>
 * Subclasses may override by calling the super implementation.
 * </p>
 *
 * @param outputStream destination output stream
 */
public void executeAndDownloadTo(OutputStream outputStream) throws IOException {
 executeUnparsed().download(outputStream);
}

代码示例来源:origin: com.google.api-client/google-api-client

/**
 * Sends the media request to the server and writes the media content input stream of
 * {@link HttpResponse} into the given destination output stream.
 *
 * <p>
 * This method closes the content of the HTTP response from {@link HttpResponse#getContent()}.
 * </p>
 *
 * <p>
 * Subclasses may override by calling the super implementation.
 * </p>
 *
 * @param outputStream destination output stream
 */
protected void executeMediaAndDownloadTo(OutputStream outputStream) throws IOException {
 if (downloader == null) {
  executeMedia().download(outputStream);
 } else {
  downloader.download(buildHttpRequestUrl(), requestHeaders, outputStream);
 }
}

代码示例来源:origin: com.google.gcloud/gcloud-java-storage

@Override
public Tuple<String, byte[]> read(StorageObject from, Map<Option, ?> options, long position,
  int bytes) {
 try {
  Get req = storage.objects()
    .get(from.getBucket(), from.getName())
    .setGeneration(from.getGeneration())
    .setIfMetagenerationMatch(IF_METAGENERATION_MATCH.getLong(options))
    .setIfMetagenerationNotMatch(IF_METAGENERATION_NOT_MATCH.getLong(options))
    .setIfGenerationMatch(IF_GENERATION_MATCH.getLong(options))
    .setIfGenerationNotMatch(IF_GENERATION_NOT_MATCH.getLong(options));
  StringBuilder range = new StringBuilder();
  range.append("bytes=").append(position).append("-").append(position + bytes - 1);
  req.getRequestHeaders().setRange(range.toString());
  ByteArrayOutputStream output = new ByteArrayOutputStream();
  req.executeMedia().download(output);
  String etag = req.getLastResponseHeaders().getETag();
  return Tuple.of(etag, output.toByteArray());
 } catch (IOException ex) {
  StorageException serviceException = translate(ex);
  if (serviceException.code() == SC_REQUESTED_RANGE_NOT_SATISFIABLE) {
   return Tuple.of(null, new byte[0]);
  }
  throw serviceException;
 }
}

代码示例来源:origin: com.google.cloud/google-cloud-storage

httpResponse.download(output);

代码示例来源:origin: com.google.cloud/google-cloud-storage

@Override
public byte[] load(StorageObject from, Map<Option, ?> options) {
 Span span = startSpan(HttpStorageRpcSpans.SPAN_NAME_LOAD);
 Scope scope = tracer.withSpan(span);
 try {
  Storage.Objects.Get getRequest =
    storage
      .objects()
      .get(from.getBucket(), from.getName())
      .setGeneration(from.getGeneration())
      .setIfMetagenerationMatch(Option.IF_METAGENERATION_MATCH.getLong(options))
      .setIfMetagenerationNotMatch(Option.IF_METAGENERATION_NOT_MATCH.getLong(options))
      .setIfGenerationMatch(Option.IF_GENERATION_MATCH.getLong(options))
      .setIfGenerationNotMatch(Option.IF_GENERATION_NOT_MATCH.getLong(options))
      .setUserProject(Option.USER_PROJECT.getString(options));
  setEncryptionHeaders(getRequest.getRequestHeaders(), ENCRYPTION_KEY_PREFIX, options);
  ByteArrayOutputStream out = new ByteArrayOutputStream();
  getRequest.executeMedia().download(out);
  return out.toByteArray();
 } catch (IOException ex) {
  span.setStatus(Status.UNKNOWN.withDescription(ex.getMessage()));
  throw translate(ex);
 } finally {
  scope.close();
  span.end();
 }
}

相关文章