org.asynchttpclient.Response.getHeaders()方法的使用及代码示例

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

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

Response.getHeaders介绍

[英]Return a List of the response header value.
[中]返回响应头值的列表。

代码示例

代码示例来源：origin: AsyncHttpClient/async-http-client

public List<String> getHeaders(CharSequence name) {
 return response.getHeaders(name);
}

代码示例来源：origin: AsyncHttpClient/async-http-client

public HttpHeaders getHeaders() {
 return response.getHeaders();
}

代码示例来源：origin: AsyncHttpClient/async-http-client

private void waitForAndAssertResponse(ListenableFuture<Response> responseFuture) throws InterruptedException, java.util.concurrent.ExecutionException {
  Response response = responseFuture.get();
  if (500 == response.getStatusCode()) {
   logger.debug("==============\n" +
       "500 response from call\n" +
       "Headers:" + response.getHeaders() + "\n" +
       "==============\n");
   assertEquals(response.getStatusCode(), 500, "Should have 500 status code");
   assertTrue(response.getHeader("X-Exception").contains("invalid.chunk.length"), "Should have failed due to chunking");
   fail("HARD Failing the test due to provided InputStreamBodyGenerator, chunking incorrectly:" + response.getHeader("X-Exception"));
  } else {
   assertEquals(response.getResponseBodyAsBytes(), LARGE_IMAGE_BYTES);
  }
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test
public void testRetryNonBlockingAsyncConnect() throws IOException, InterruptedException, ExecutionException {
 AsyncHttpClientConfig config = config()
     .setKeepAlive(true)
     .setMaxConnections(100)
     .setConnectTimeout(60000)
     .setRequestTimeout(30000)
     .build();
 try (AsyncHttpClient client = asyncHttpClient(config)) {
  List<ListenableFuture<Response>> res = new ArrayList<>();
  for (int i = 0; i < 32; i++) {
   res.add(testMethodRequest(client, 3, "servlet", UUID.randomUUID().toString()));
  }
  StringBuilder b = new StringBuilder();
  for (ListenableFuture<Response> r : res) {
   Response theres = r.get();
   assertEquals(theres.getStatusCode(), 200);
   b.append("==============\r\n")
       .append("Response Headers\r\n");
   HttpHeaders heads = theres.getHeaders();
   b.append(heads).append("\r\n")
       .append("==============\r\n");
  }
  System.out.println(b.toString());
  System.out.flush();
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test
public void testRetryNonBlocking() throws IOException, InterruptedException, ExecutionException {
 AsyncHttpClientConfig config = config()
     .setKeepAlive(true)
     .setMaxConnections(100)
     .setConnectTimeout(60000)
     .setRequestTimeout(30000)
     .build();
 try (AsyncHttpClient client = asyncHttpClient(config)) {
  List<ListenableFuture<Response>> res = new ArrayList<>();
  for (int i = 0; i < 32; i++) {
   res.add(testMethodRequest(client, 3, "servlet", UUID.randomUUID().toString()));
  }
  StringBuilder b = new StringBuilder();
  for (ListenableFuture<Response> r : res) {
   Response theres = r.get();
   assertEquals(200, theres.getStatusCode());
   b.append("==============\r\n")
       .append("Response Headers\r\n");
   HttpHeaders heads = theres.getHeaders();
   b.append(heads).append("\r\n")
       .append("==============\r\n");
  }
  System.out.println(b.toString());
  System.out.flush();
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

/**
 * Converts async-http-client response to okhttp response.
 *
 * @param asyncHttpClientResponse async-http-client response
 * @return okhttp response.
 * @throws NullPointerException in case of null arguments
 */
private Response toOkhttpResponse(org.asynchttpclient.Response asyncHttpClientResponse) {
 // status code
 val rspBuilder = new Response.Builder()
     .request(request())
     .protocol(Protocol.HTTP_1_1)
     .code(asyncHttpClientResponse.getStatusCode())
     .message(asyncHttpClientResponse.getStatusText());
 // headers
 if (asyncHttpClientResponse.hasResponseHeaders()) {
  asyncHttpClientResponse.getHeaders().forEach(e -> rspBuilder.header(e.getKey(), e.getValue()));
 }
 // body
 if (asyncHttpClientResponse.hasResponseBody()) {
  val contentType = asyncHttpClientResponse.getContentType() == null
      ? null : MediaType.parse(asyncHttpClientResponse.getContentType());
  val okHttpBody = ResponseBody.create(contentType, asyncHttpClientResponse.getResponseBodyAsBytes());
  rspBuilder.body(okHttpBody);
 } else {
  rspBuilder.body(EMPTY_BODY);
 }
 return rspBuilder.build();
}

代码示例来源：origin: org.asynchttpclient/async-http-client-api

public List<String> getHeaders(String name) {
  return response.getHeaders(name);
}

代码示例来源：origin: org.asynchttpclient/async-http-client-api

public FluentCaseInsensitiveStringsMap getHeaders() {
  return response.getHeaders();
}

代码示例来源：origin: com.github.mjeanroy/rest-assert-core

@Override
public List<String> getHeader(String name) {
  List<String> headers = response.getHeaders(name);
  if (headers.isEmpty()) {
    return emptyList();
  }
  return unmodifiableList(headers);
}

代码示例来源：origin: com.github.mjeanroy/junit-servers-core

@Override
public HttpHeader getHeader(String name) {
  List<String> values = response.getHeaders(name);
  if (values == null || values.isEmpty()) {
    return null;
  }
  return HttpHeader.header(name, values);
}

代码示例来源：origin: com.typesafe.play/play-java-ws

/**
 * Get all the HTTP headers of the response as a case-insensitive map
 */
@Override
public Map<String, List<String>> getAllHeaders() {
  final Map<String, List<String>> headerMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
  final HttpHeaders headers = ahcResponse.getHeaders();
  for (String name : headers.names()) {
    final List<String> values = headers.getAll(name);
    headerMap.put(name, values);
  }
  return headerMap;
}

代码示例来源：origin: cloudbees/zendesk-java-client

private void logResponse(Response response) throws IOException {
  if (logger.isDebugEnabled()) {
    logger.debug("Response HTTP/{} {}\n{}", response.getStatusCode(), response.getStatusText(),
        response.getResponseBody());
  }
  if (logger.isTraceEnabled()) {
    logger.trace("Response headers {}", response.getHeaders());
  }
}

代码示例来源：origin: com.github.mjeanroy/junit-servers-core

@Override
public Collection<HttpHeader> getHeaders() {
  HttpHeaders headers = response.getHeaders();
  List<HttpHeader> results = new ArrayList<>(headers.size());
  for (Map.Entry<String, String> entry : headers) {
    String name = entry.getKey();
    List<String> values = headers.getAll(name);
    results.add(HttpHeader.header(name, values));
  }
  return results;
}

代码示例来源：origin: ribasco/async-gamequery-lib

/**
   * Converts the underlying processed content to a {@link com.google.gson.JsonObject} instance
   */
  @SuppressWarnings("unchecked")
  private <A> A postProcessConversion(Res response) {
    log.debug("ConvertToJson for Response = {}, {}", response.getMessage().getStatusCode(), response.getMessage().getHeaders());
    JsonElement processedElement = response.getProcessedContent();
    if (processedElement != null) {
      if (processedElement.isJsonObject())
        return (A) processedElement.getAsJsonObject();
      else if (processedElement.isJsonArray())
        return (A) processedElement.getAsJsonArray();
    }
    throw new AsyncGameLibUncheckedException("No parsed content found for response" + response);
  }
}

代码示例来源：origin: com.github.scribejava/scribejava-httpclient-ahc

@Override
public T onCompleted(org.asynchttpclient.Response ahcResponse) {
  try {
    final Map<String, String> headersMap = new HashMap<>();
    for (Map.Entry<String, String> header : ahcResponse.getHeaders()) {
      headersMap.put(header.getKey(), header.getValue());
    }
    final Response response = new Response(ahcResponse.getStatusCode(), ahcResponse.getStatusText(), headersMap,
        ahcResponse.getResponseBodyAsStream());
    @SuppressWarnings("unchecked")
    final T t = converter == null ? (T) response : converter.convert(response);
    if (callback != null) {
      callback.onCompleted(t);
    }
    return t;
  } catch (IOException | RuntimeException e) {
    onThrowable(e);
    return null;
  }
}

代码示例来源：origin: com.commercetools.sdk.jvm.core/sdk-http-ahc-2_0

private HttpResponse convert(final HttpRequest httpRequest, final Response response) {
  final byte[] responseBodyAsBytes = getResponseBodyAsBytes(response);
  final int statusCode = response.getStatusCode();
  final HttpHeaders headers = HttpHeaders.ofMapEntryList(response.getHeaders().entries());
  return HttpResponse.of(statusCode, responseBodyAsBytes, httpRequest, headers);
}

代码示例来源：origin: commercetools/commercetools-jvm-sdk

private HttpResponse convert(final HttpRequest httpRequest, final Response response) {
  final byte[] responseBodyAsBytes = getResponseBodyAsBytes(response);
  final int statusCode = response.getStatusCode();
  final HttpHeaders headers = HttpHeaders.ofMapEntryList(response.getHeaders().entries());
  return HttpResponse.of(statusCode, responseBodyAsBytes, httpRequest, headers);
}

代码示例来源：origin: commercetools/commercetools-jvm-sdk

private HttpResponse convert(final HttpRequest httpRequest, final Response response) {
  final byte[] responseBodyAsBytes = getResponseBodyAsBytes(response);
  final int statusCode = response.getStatusCode();
  final HttpHeaders headers = HttpHeaders.ofMapEntryList(response.getHeaders().entries());
  return HttpResponse.of(statusCode, responseBodyAsBytes, httpRequest, headers);
}

代码示例来源：origin: darren-fu/pampas

fullHttpResponse.headers().set(response.getHeaders());
DefaultPampasResponse<FullHttpResponse> defaultResponseInfo = new DefaultPampasResponse();
defaultResponseInfo.setResponseData(fullHttpResponse);

代码示例来源：origin: com.tomitribe.tribestream/tribestream-container

for (Map.Entry<String, String> entry : response.getHeaders().entries()) {
  if ("content-type".equalsIgnoreCase(entry.getKey())) {
    if (!entry.getValue().contains("application/json")) {

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

response

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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