com.ning.http.client.RequestBuilder.addHeader()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(12.1k)|赞(0)|评价(0)|浏览(199)

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

RequestBuilder.addHeader介绍

暂无

代码示例

代码示例来源：origin: com.ning/async-http-client

public Builder addHeader(String name, String value) {
  requestBuilder.addHeader(name, value);
  return this;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

public Builder addHeader(String name, String value) {
  requestBuilder.addHeader(name, value);
  return this;
}

代码示例来源：origin: javaee/grizzly-ahc

public Builder addHeader(String name, String value) {
  requestBuilder.addHeader(name, value);
  return this;
}

代码示例来源：origin: io.gatling/async-http-client

public Builder addHeader(String name, String value) {
  requestBuilder.addHeader(name, value);
  return this;
}

代码示例来源：origin: org.sonatype.spice/jersey-ahc-client

private void configureHeaders(MultivaluedMap<String, Object> metadata, RequestBuilder requestBuilder) {
    for (Map.Entry<String, List<Object>> e : metadata.entrySet()) {
      List<Object> vs = e.getValue();
      for (Object o : vs) {
        if (String.class.isAssignableFrom( o.getClass() )) {
          requestBuilder.addHeader(e.getKey(), o.toString());
        } else {
          requestBuilder.addHeader(e.getKey(), headerValueToString(o));
        }
      }
    }
  }
}

代码示例来源：origin: sonia.net.ahc/jersey-ahc-client

private void configureHeaders(MultivaluedMap<String, Object> metadata, RequestBuilder requestBuilder) {
    for (Map.Entry<String, List<Object>> e : metadata.entrySet()) {
      List<Object> vs = e.getValue();
      for (Object o : vs) {
        if (String.class.isAssignableFrom( o.getClass() )) {
          requestBuilder.addHeader(e.getKey(), o.toString());
        } else {
          requestBuilder.addHeader(e.getKey(), ClientRequest.getHeaderValue(o));
        }
      }
    }
  }
}

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

/**
 * Add cookies to the final HTTP request.
 *
 * @param builder The pending HTTP request.
 * @see RequestBuilder#addCookie(com.ning.http.client.cookie.Cookie)
 */
private void handleCookies(RequestBuilder builder) {
  if (!cookies.isEmpty()) {
    builder.addHeader(HttpHeaders.COOKIE, Cookies.serialize(cookies));
  }
}

代码示例来源：origin: dhanji/sitebricks

private RequestBuilder addHeadersToRequestBuilder(RequestBuilder requestBuilder) {
 //
 // The user may wish to override the Content-Type header for whatever reason. If they do so we just honour that header and make
 // sure we don't trample that header with the default Content-Type header as provided by the Transport.
 //
 boolean contentTypeOverriddenInHeaders = false;
 if (null != headers) {
  for (Map.Entry<String, String> header : headers.entrySet()) {
   if (header.getKey().toLowerCase().equals("content-type")) {
    contentTypeOverriddenInHeaders = true;
   }
   requestBuilder.addHeader(header.getKey(), header.getValue());
  }
 }
 if (!contentTypeOverriddenInHeaders) {
  //
  // Set the Content-Type as specified by the Transport. For example if we're using the Json transport the Content-Type header
  // will be set to application/json.
  //
  requestBuilder.addHeader("Content-Type", transport.contentType());
 }
 return requestBuilder;
}

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

/**
   * Add request headers.
   *
   * @param builder The pending HTTP request.
   * @see RequestBuilder#addHeader(String, String)
   */
  private void handleHeaders(RequestBuilder builder) {
    for (HttpHeader header : headers.values()) {
      builder.addHeader(header.getName(), header.serializeValues());
    }
  }
}

代码示例来源：origin: br.com.objectos/sitebricks-client

private WebResponse simpleRequest(RequestBuilder requestBuilder) {
  //set request headers as necessary
  if (null != headers)
    for (Map.Entry<String, String> header : headers.entrySet())
      requestBuilder.addHeader(header.getKey(), header.getValue());
  try {
    Response r = httpClient.executeRequest(requestBuilder.build()).get();
    return new WebResponseImpl(injector, r);
  } catch (IOException e) {
    throw new TransportException(e);
  } catch (InterruptedException e) {
    throw new TransportException(e);
  } catch (ExecutionException e) {
    throw new TransportException(e);
  }
}

代码示例来源：origin: io.sphere.sdk.jvm/sdk-http-ahc-1_8

<T> Request asAhcRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach(value -> builder.addHeader(name, value)));
  Optional.ofNullable(request.getBody()).ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      final File file = ((FileHttpRequestBody) body).getFile();
      builder.setBody(out -> FileUtils.copyFile(file, out));
      final long length = file.length();
      builder.addHeader(HttpHeaders.CONTENT_LENGTH, "" + length);
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      final FormUrlEncodedHttpRequestBody formUrlEncodedHttpRequestBody = (FormUrlEncodedHttpRequestBody) body;
      formUrlEncodedHttpRequestBody.getParameters().forEach(pair -> builder.addParameter(pair.getName(), pair.getValue()));
    }
  });
  final Request ahcRequest = builder.build();
  return ahcRequest;
}

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

Request asAhcRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach(value -> builder.addHeader(name, value)));
  Optional.ofNullable(request.getBody()).ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      final File file = ((FileHttpRequestBody) body).getFile();
      builder.setBody(out -> FileUtils.copyFile(file, out));
      final long length = file.length();
      builder.addHeader(HttpHeaders.CONTENT_LENGTH, "" + length);
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      final FormUrlEncodedHttpRequestBody formUrlEncodedHttpRequestBody = (FormUrlEncodedHttpRequestBody) body;
      formUrlEncodedHttpRequestBody.getParameters().forEach(pair -> builder.addParameter(pair.getName(), pair.getValue()));
    }
  });
  final Request ahcRequest = builder.build();
  return ahcRequest;
}

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

<T> Request asAhcRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach(value -> builder.addHeader(name, value)));
  Optional.ofNullable(request.getBody()).ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      builder.setBody(((FileHttpRequestBody) body).getFile());
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      final FormUrlEncodedHttpRequestBody formUrlEncodedHttpRequestBody = (FormUrlEncodedHttpRequestBody) body;
      formUrlEncodedHttpRequestBody.getParameters().forEach(pair -> builder.addFormParam(pair.getName(), pair.getValue()));
    }
  });
  final Request build = builder.build();
  return build;
}

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

<T> Request asAhcRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach(value -> builder.addHeader(name, value)));
  Optional.ofNullable(request.getBody()).ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      builder.setBody(((FileHttpRequestBody) body).getFile());
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      final FormUrlEncodedHttpRequestBody formUrlEncodedHttpRequestBody = (FormUrlEncodedHttpRequestBody) body;
      formUrlEncodedHttpRequestBody.getParameters().forEach(pair -> builder.addFormParam(pair.getName(), pair.getValue()));
    }
  });
  final Request build = builder.build();
  return build;
}

代码示例来源：origin: io.sphere.sdk.jvm/java-client

<T> Request asNingRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach( value -> builder.addHeader(name, value)));
  request.getBody().ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      builder.setBody(((FileHttpRequestBody) body).getFile());
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      ((FormUrlEncodedHttpRequestBody) body).getData().forEach((name, value) -> builder.addQueryParameter(name, value));
    }
  });
  final Request build = builder.build();
  return build;
}

代码示例来源：origin: io.sphere.sdk.jvm/sdk-http-ning-1_8

<T> Request asNingRequest(final HttpRequest request) {
  final RequestBuilder builder = new RequestBuilder()
      .setUrl(request.getUrl())
      .setMethod(request.getHttpMethod().toString());
  request.getHeaders().getHeadersAsMap().forEach((name, values) -> values.forEach( value -> builder.addHeader(name, value)));
  request.getBody().ifPresent(body -> {
    if (body instanceof StringHttpRequestBody) {
      final String bodyAsString = ((StringHttpRequestBody) body).getString();
      builder.setBodyEncoding(StandardCharsets.UTF_8.name()).setBody(bodyAsString);
    } else if (body instanceof FileHttpRequestBody) {
      builder.setBody(((FileHttpRequestBody) body).getFile());
    } else if (body instanceof FormUrlEncodedHttpRequestBody) {
      ((FormUrlEncodedHttpRequestBody) body).getData().forEach((name, value) -> builder.addQueryParameter(name, value));
    }
  });
  final Request build = builder.build();
  return build;
}

代码示例来源：origin: javaee/grizzly-ahc

@Test(groups = { "online", "default_provider" })
public void evilCoookieTest() throws Throwable {
  try (AsyncHttpClient client = getAsyncHttpClient(null)) {
    RequestBuilder builder2 = new RequestBuilder("GET");
    builder2.setFollowRedirects(true);
    builder2.setUrl("http://www.google.com/");
    builder2.addHeader("Content-Type", "text/plain");
    builder2.addCookie(new Cookie("evilcookie", "test", false, ".google.com", "/", 10L, false, false));
    com.ning.http.client.Request request2 = builder2.build();
    Response response = client.executeRequest(request2).get();
    assertNotNull(response);
    assertEquals(response.getStatusCode(), 200);
  }
}

代码示例来源：origin: javaee/grizzly-ahc

public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {
  if (replay.getAndSet(false)) {
    Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
}

代码示例来源：origin: javaee/grizzly-ahc

public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {
  if (ctx.getResponseHeaders() != null && ctx.getResponseHeaders().getHeaders().getFirstValue("Ping").equals("Pong") && replay.getAndSet(false)) {
    Request request = new RequestBuilder(ctx.getRequest()).addHeader("Ping", "Pong").build();
    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
}

代码示例来源：origin: javaee/grizzly-ahc

public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {
  if (ctx.getResponseStatus() != null && ctx.getResponseStatus().getStatusCode() == 200 && replay.getAndSet(false)) {
    Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
}

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

RequestBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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