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

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

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

RequestBuilder.create介绍

暂无

代码示例

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

private static HttpUriRequest getUploadFileRequest(String method, URI uri, ContentBody contentBody,
  @Nullable List<Header> headers, @Nullable List<NameValuePair> parameters, int socketTimeoutMs) {
 // Build the Http entity
 HttpEntity entity = MultipartEntityBuilder.create().setMode(HttpMultipartMode.BROWSER_COMPATIBLE)
   .addPart(contentBody.getFilename(), contentBody).build();
 // Build the request
 RequestBuilder requestBuilder =
   RequestBuilder.create(method).setVersion(HttpVersion.HTTP_1_1).setUri(uri).setEntity(entity);
 addHeadersAndParameters(requestBuilder, headers, parameters);
 setTimeout(requestBuilder, socketTimeoutMs);
 return requestBuilder.build();
}

代码示例来源:origin: fabric8io/docker-maven-plugin

CloseableHttpResponse response = httpClient.execute(RequestBuilder.create(method.toUpperCase()).setUri(url).build());
try {
  int responseCode = response.getStatusLine().getStatusCode();

代码示例来源: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

RequestBuilder builder = RequestBuilder.create(verb.toUpperCase());
builder.setUri(uri);

代码示例来源:origin: jersey/jersey

private HttpUriRequest getUriHttpRequest(final ClientRequest clientRequest) {
  final RequestConfig.Builder requestConfigBuilder = RequestConfig.copy(requestConfig);
  final int connectTimeout = clientRequest.resolveProperty(ClientProperties.CONNECT_TIMEOUT, -1);
  final int socketTimeout = clientRequest.resolveProperty(ClientProperties.READ_TIMEOUT, -1);
  if (connectTimeout >= 0) {
    requestConfigBuilder.setConnectTimeout(connectTimeout);
  }
  if (socketTimeout >= 0) {
    requestConfigBuilder.setSocketTimeout(socketTimeout);
  }
  final Boolean redirectsEnabled =
      clientRequest.resolveProperty(ClientProperties.FOLLOW_REDIRECTS, requestConfig.isRedirectsEnabled());
  requestConfigBuilder.setRedirectsEnabled(redirectsEnabled);
  final Boolean bufferingEnabled = clientRequest.resolveProperty(ClientProperties.REQUEST_ENTITY_PROCESSING,
      RequestEntityProcessing.class) == RequestEntityProcessing.BUFFERED;
  final HttpEntity entity = getHttpEntity(clientRequest, bufferingEnabled);
  return RequestBuilder
      .create(clientRequest.getMethod())
      .setUri(clientRequest.getUri())
      .setConfig(requestConfigBuilder.build())
      .setEntity(entity)
      .build();
}

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

final RequestBuilder reqBuilder = RequestBuilder.create(
    request.getMethod().name());

代码示例来源: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: com.intuit.karate/karate-apache

private void build() {
  try {
    URI uri = uriBuilder.build();
    String method = request.getMethod();
    requestBuilder = RequestBuilder.create(method).setUri(uri);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源:origin: com.blackducksoftware.integration/integration-rest

public final RequestBuilder createRequestBuilder(HttpMethod method, Map<String, String> additionalHeaders) throws IntegrationException {
  if (method == null) {
    throw new IntegrationException("Missing field 'method'");
  }
  RequestBuilder requestBuilder = RequestBuilder.create(method.name());
  Map<String, String> requestHeaders = new HashMap<>(commonRequestHeaders);
  if (additionalHeaders != null && !additionalHeaders.isEmpty()) {
    requestHeaders.putAll(additionalHeaders);
  }
  for (Entry<String, String> header : requestHeaders.entrySet()) {
    requestBuilder.addHeader(header.getKey(), header.getValue());
  }
  return requestBuilder;
}

代码示例来源:origin: authorjapps/zerocode

public static RequestBuilder createUploadRequestBuilder(String httpUrl, String methodName, MultipartEntityBuilder multipartEntityBuilder) {
  RequestBuilder uploadRequestBuilder = RequestBuilder
      .create(methodName)
      .setUri(httpUrl);
  HttpEntity reqEntity = multipartEntityBuilder.build();
  uploadRequestBuilder.setEntity(reqEntity);
  return uploadRequestBuilder;
}

代码示例来源:origin: com.jsunsoft.http/http-request

/**
 * {@inheritDoc}
 */
@Override
public ResponseHandler<T> executeWithBody(String payload) {
  LOGGER.debug("Started executing with body. Uri: " + uri);
  ArgsCheck.notNull(payload, "payload");
  RequestBuilder requestBuilder = RequestBuilder.create(httpMethod)
      .setUri(uri)
      .setEntity(new StringEntity(payload, UTF_8));
  return execute(requestBuilder);
}

代码示例来源:origin: com.jsunsoft.http/http-request

/**
 * {@inheritDoc}
 */
@Override
public ResponseHandler<T> execute(NameValuePair... params) {
  LOGGER.debug("Started executing. Uri: " + uri);
  ArgsCheck.notNull(params, "params");
  RequestBuilder requestBuilder = RequestBuilder.create(httpMethod).setUri(uri).addParameters(params);
  return execute(requestBuilder);
}

代码示例来源:origin: horrorho/InflatableDonkey

@Override
  public HttpUriRequest apply(ChunkServer.HostInfo hostInfo) {
    String uri = hostInfo.getScheme() + "://" + hostInfo.getHostname() + "/" + hostInfo.getUri();
    HttpUriRequest request = RequestBuilder.create(hostInfo.getMethod())
        .setUri(uri)
        .build();
    hostInfo.getHeadersList()
        .stream()
        .map(u -> new BasicHeader(u.getName(), u.getValue()))
        .forEach(request::addHeader);
    return request;
  }
}

代码示例来源:origin: horrorho/LiquidDonkey

public HttpUriRequest get(ChunkServer.StorageHostChunkList chunks) {
  ChunkServer.HostInfo hostInfo = chunks.getHostInfo();
  String uri = hostInfo.getScheme() + "://" + hostInfo.getHostname() + "/" + hostInfo.getUri();
  HttpUriRequest request = RequestBuilder.create(hostInfo.getMethod()).setUri(uri).build();
  headers.headers(hostInfo.getHeadersList()).stream().forEach(request::addHeader);
  return request;
}

代码示例来源:origin: iterate-ch/cyberduck

private HttpUriRequest toUriHttpRequest(final ClientRequest request) {
  final HttpEntity entity = this.getHttpEntity(request);
  return RequestBuilder
      .create(request.getMethod())
      .setUri(request.getUri())
      .setEntity(entity)
      .build();
}

代码示例来源: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();
}

代码示例来源:origin: com.salesforce.argus/argus-core

private HttpUriRequest buildRequest(DefaultAlertService.NotificationContext context,
    CallbackService.Request request) {
  RequestBuilder builder = RequestBuilder
      .create(request.method().name())
      .setUri(request.uri())
      .setEntity(body(context, request));
  request.header().forEach((k, v) -> builder.addHeader(k, v));
  return builder.build();
}

代码示例来源:origin: com.github.tomakehurst/wiremock-jre8

private <B, R> R executeRequest(RequestSpec requestSpec, PathParams pathParams, B requestBody, Class<R> responseType) {
  String url = String.format(ADMIN_URL_PREFIX + requestSpec.path(pathParams), scheme, host, port, urlPathPrefix);
  RequestBuilder requestBuilder = RequestBuilder
      .create(requestSpec.method().getName())
      .setUri(url);
  if (requestBody != null) {
    requestBuilder.setEntity(jsonStringEntity(Json.write(requestBody)));
  }
  String responseBodyString = safelyExecuteRequest(url, requestBuilder.build());
  return responseType == Void.class ?
      null :
      Json.read(responseBodyString, responseType);
}

代码示例来源:origin: apache/asterixdb

private HttpUriRequest buildRequest(String method, URI uri, List<Parameter> params, Optional<String> body) {
  RequestBuilder builder = RequestBuilder.create(method);
  builder.setUri(uri);
  for (Parameter param : params) {
    builder.addParameter(param.getName(), param.getValue());
  }
  builder.setCharset(StandardCharsets.UTF_8);
  body.ifPresent(s -> builder.setEntity(new StringEntity(s, StandardCharsets.UTF_8)));
  return builder.build();
}

代码示例来源:origin: com.ca.apim.gateway/gateway-import-plugin

@TaskAction
  public void perform() {
    File bundleFile = importFile.getAsFile().get();
    gatewayClient.makeGatewayAPICall(
        create(METHOD_NAME)
            .setUri(getRestmanBundleEndpoint(gatewayConnectionProperties.getUrl().get()))
            .setEntity(new FileEntity(bundleFile))
            .setHeader(CONTENT_TYPE, "application/xml"),
        gatewayConnectionProperties.getUserName().get(),
        gatewayConnectionProperties.getUserPass().get()
    );
  }
}

相关文章