org.apache.http.client.methods.RequestBuilder.addHeader()方法的使用及代码示例

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

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

RequestBuilder.addHeader介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-pinot

private static void addHeadersAndParameters(RequestBuilder requestBuilder, @Nullable List<Header> headers,
  @Nullable List<NameValuePair> parameters) {
 if (headers != null) {
  for (Header header : headers) {
   requestBuilder.addHeader(header);
  }
 }
 if (parameters != null) {
  for (NameValuePair parameter : parameters) {
   requestBuilder.addParameter(parameter);
  }
 }
}

代码示例来源：origin: apache/incubator-gobblin

private HttpUriRequest newRequest(RequestBuilder builder, JsonElement payload) {
 try {
  builder.addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())
      .addHeader(HttpHeaders.AUTHORIZATION, "OAuth " + accessToken)
      .setEntity(new StringEntity(payload.toString(), ContentType.APPLICATION_JSON));
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
 if (getLog().isDebugEnabled()) {
  getLog().debug("Request builder: " + ToStringBuilder.reflectionToString(builder, ToStringStyle.SHORT_PREFIX_STYLE));
 }
 return builder.build();
}

代码示例来源：origin: igniterealtime/Openfire

final HttpUriRequest getRequest = RequestBuilder.get(crowdServer.resolve(request.toString() + startIndex))
  .setConfig(requestConfig)
  .addHeader(HEADER_ACCEPT_APPLICATION_XML)
  .addHeader(HEADER_ACCEPT_CHARSET_UTF8)
  .build();

代码示例来源：origin: igniterealtime/Openfire

/**
 * Get the description of a group from crowd
 * @param groupName
 * @return a Group object
 * @throws RemoteException
 */
public Group getGroup(String groupName) throws RemoteException {
  LOG.debug("Get group:" + groupName + " from crowd");
  final HttpUriRequest getRequest = RequestBuilder.get(crowdServer.resolve("group?groupname=" + urlEncode(groupName)))
    .setConfig(requestConfig)
    .addHeader(HEADER_ACCEPT_APPLICATION_XML)
    .addHeader(HEADER_ACCEPT_CHARSET_UTF8)
    .build();
  Group group = null;
  try (final CloseableHttpResponse response = client.execute(getRequest, clientContext)) {
    if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
      handleHTTPError(response);
    }
    group = JAXB.unmarshal(response.getEntity().getContent(), Group.class);
    
  } catch (IOException ioe) {
    handleError(ioe);
  }
  return group;
}

代码示例来源：origin: igniterealtime/Openfire

final HttpUriRequest getRequest = RequestBuilder.get(crowdServer.resolve(request.toString() + startIndex))
  .setConfig(requestConfig)
  .addHeader(HEADER_ACCEPT_APPLICATION_XML)
  .addHeader(HEADER_ACCEPT_CHARSET_UTF8)
  .build();

代码示例来源：origin: apache/incubator-gobblin

@Override
public Optional<HttpUriRequest> onNewRecord(D record) {
 try {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.TEXT_PLAIN.getMimeType())
    .setUri(getCurServerHost())
    .setEntity(new StringEntity(record.toString(), ContentType.TEXT_PLAIN.toString()))
    .build();
  return Optional.of(uriRequest);
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: igniterealtime/Openfire

final HttpUriRequest getRequest = RequestBuilder.get(crowdServer.resolve(request.toString() + startIndex))
  .setConfig(requestConfig)
  .addHeader(HEADER_ACCEPT_APPLICATION_XML)
  .addHeader(HEADER_ACCEPT_CHARSET_UTF8)
  .build();

代码示例来源：origin: igniterealtime/Openfire

final HttpUriRequest getRequest = RequestBuilder.get(crowdServer.resolve(request.toString() + startIndex))
  .setConfig(requestConfig)
  .addHeader(HEADER_ACCEPT_APPLICATION_XML)
  .addHeader(HEADER_ACCEPT_CHARSET_UTF8)
  .build();

代码示例来源：origin: code4craft/webmagic

private HttpUriRequest convertHttpUriRequest(Request request, Site site, Proxy proxy) {
  RequestBuilder requestBuilder = selectRequestMethod(request).setUri(UrlUtils.fixIllegalCharacterInUrl(request.getUrl()));
  if (site.getHeaders() != null) {
    for (Map.Entry<String, String> headerEntry : site.getHeaders().entrySet()) {
      requestBuilder.addHeader(headerEntry.getKey(), headerEntry.getValue());
    }
  }
  RequestConfig.Builder requestConfigBuilder = RequestConfig.custom();
  if (site != null) {
    requestConfigBuilder.setConnectionRequestTimeout(site.getTimeOut())
        .setSocketTimeout(site.getTimeOut())
        .setConnectTimeout(site.getTimeOut())
        .setCookieSpec(CookieSpecs.STANDARD);
  }
  if (proxy != null) {
    requestConfigBuilder.setProxy(new HttpHost(proxy.getHost(), proxy.getPort()));
  }
  requestBuilder.setConfig(requestConfigBuilder.build());
  HttpUriRequest httpUriRequest = requestBuilder.build();
  if (request.getHeaders() != null && !request.getHeaders().isEmpty()) {
    for (Map.Entry<String, String> header : request.getHeaders().entrySet()) {
      httpUriRequest.addHeader(header.getKey(), header.getValue());
    }
  }
  return httpUriRequest;
}

代码示例来源：origin: apache/incubator-gobblin

@Override
 public Optional<HttpUriRequest> onNewRecord(RestEntry<JsonObject> record) {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())
    .setUri(combineUrl(getCurServerHost(), record.getResourcePath()))
    .setEntity(new StringEntity(record.getRestEntryVal().toString(), ContentType.APPLICATION_JSON))
    .build();
  return Optional.of(uriRequest);
 }
}

代码示例来源：origin: apache/incubator-gobblin

@Override
 public Optional<HttpUriRequest> onNewRecord(RestEntry<String> record) {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.TEXT_PLAIN.getMimeType())
    .setUri(combineUrl(getCurServerHost(), record.getResourcePath()))
    .setEntity(new StringEntity(record.getRestEntryVal(), ContentType.TEXT_PLAIN))
    .build();
  return Optional.of(uriRequest);
 }
}

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

/**
 * Build a new Apache's {@link org.apache.http.client.methods.HttpUriRequest}
 * from Jersey's {@link org.glassfish.jersey.client.ClientRequest}
 * <p>
 * Convert a method, URI, body, headers and override a user-agent if necessary
 * </p>
 *
 * @param jerseyRequest representation of an HTTP request in Jersey
 * @return a new {@link org.apache.http.client.methods.HttpUriRequest}
 */
private HttpUriRequest buildApacheRequest(ClientRequest jerseyRequest) {
  final RequestBuilder builder = RequestBuilder
      .create(jerseyRequest.getMethod())
      .setUri(jerseyRequest.getUri())
      .setEntity(getHttpEntity(jerseyRequest));
  for (String headerName : jerseyRequest.getHeaders().keySet()) {
    builder.addHeader(headerName, jerseyRequest.getHeaderString(headerName));
  }
  final Optional<RequestConfig> requestConfig = addJerseyRequestConfig(jerseyRequest);
  requestConfig.ifPresent(builder::setConfig);
  return builder.build();
}

代码示例来源：origin: apache/incubator-gobblin

/**
  * Build a {@link HttpUriRequest} from a {@link GenericRecord}
  */
 public void testBuildWriteRequest()
   throws IOException {
  String urlTemplate = "http://www.test.com/a/part1:${part1}/a/part2:${part2}";
  String verb = "post";
  ApacheHttpRequestBuilder builder = spy(new ApacheHttpRequestBuilder(urlTemplate, verb, "application/json"));
  ArgumentCaptor<RequestBuilder> requestBuilderArgument = ArgumentCaptor.forClass(RequestBuilder.class);

  Queue<BufferedRecord<GenericRecord>> queue = HttpTestUtils.createQueue(1, false);
  AsyncRequest<GenericRecord, HttpUriRequest> request = builder.buildRequest(queue);
  verify(builder).build(requestBuilderArgument.capture());

  RequestBuilder expected = RequestBuilder.post();
  expected.setUri("http://www.test.com/a/part1:01/a/part2:02?param1=01");
  String payloadStr = "{\"id\":\"id0\"}";
  expected.addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())
    .setEntity(new StringEntity(payloadStr, ContentType.APPLICATION_JSON));

  // Compare HttpUriRequest
  HttpTestUtils.assertEqual(requestBuilderArgument.getValue(), expected);
  Assert.assertEquals(request.getRecordCount(), 1);
  Assert.assertEquals(queue.size(), 0);
 }
}

代码示例来源：origin: wiztools/rest-client

if(StringUtil.isNotEmpty(authHeader)) {
  Header header = new BasicHeader("Authorization", authHeader);
  reqBuilder.addHeader(header);
Header header = new BasicHeader(key, value);
reqBuilder.addHeader(header);

代码示例来源：origin: apache/cloudstack

public HttpUriRequest build() {
  validate();
  final RequestBuilder builder = RequestBuilder.create(method.toString()).setUri(buildUri());
  if (!methodParameters.isEmpty()) {
    for (final Entry<String, String> entry : methodParameters.entrySet()) {
      builder.addParameter(entry.getKey(), entry.getValue());
    }
  }
  if (jsonPayload.isPresent()) {
    builder.addHeader(new BasicHeader(CONTENT_TYPE, JSON_CONTENT_TYPE))
      .setEntity(new StringEntity(jsonPayload.get(), ContentType.create(JSON_CONTENT_TYPE, Consts.UTF_8)));
  }
  return builder.build();
}

代码示例来源：origin: org.apache.gobblin/gobblin-core

@Override
 public Optional<HttpUriRequest> onNewRecord(RestEntry<JsonObject> record) {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())
    .setUri(combineUrl(getCurServerHost(), record.getResourcePath()))
    .setEntity(new StringEntity(record.getRestEntryVal().toString(), ContentType.APPLICATION_JSON))
    .build();
  return Optional.of(uriRequest);
 }
}

代码示例来源：origin: com.yahoo.vespa/vespa-athenz

@Override
public void deleteTenancy(AthenzDomain tenantDomain, AthenzService providerService, OktaAccessToken token) {
  URI uri = zmsUrl.resolve(String.format("domain/%s/tenancy/%s", tenantDomain.getName(), providerService.getFullName()));
  HttpUriRequest request = RequestBuilder.delete()
      .setUri(uri)
      .addHeader(creatOktaAccessTokenHeader(token))
      .build();
  execute(request, response -> readEntity(response, Void.class));
}

代码示例来源：origin: org.apache.gobblin/gobblin-core

@Override
 public Optional<HttpUriRequest> onNewRecord(RestEntry<String> record) {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.TEXT_PLAIN.getMimeType())
    .setUri(combineUrl(getCurServerHost(), record.getResourcePath()))
    .setEntity(new StringEntity(record.getRestEntryVal(), ContentType.TEXT_PLAIN))
    .build();
  return Optional.of(uriRequest);
 }
}

代码示例来源：origin: com.yahoo.vespa/vespa-athenz

@Override
public void createTenancy(AthenzDomain tenantDomain, AthenzService providerService, OktaAccessToken token) {
  URI uri = zmsUrl.resolve(String.format("domain/%s/tenancy/%s", tenantDomain.getName(), providerService.getFullName()));
  HttpUriRequest request = RequestBuilder.put()
      .setUri(uri)
      .addHeader(creatOktaAccessTokenHeader(token))
      .setEntity(toJsonStringEntity(new TenancyRequestEntity(tenantDomain, providerService, Collections.emptyList())))
      .build();
  execute(request, response -> readEntity(response, Void.class));
}

代码示例来源：origin: salesforce/Argus

private HttpUriRequest buildRequest(DefaultAlertService.NotificationContext context,
    CallbackService.Request request) {
  RequestBuilder builder = RequestBuilder
      .create(request.getMethod().name())
      .setUri(request.getUri())
      .setEntity(getBody(context, request));
  request.getHeader().forEach((k, v) -> builder.addHeader(k, v));
  return builder.build();
}

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

RequestBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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