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

RequestBuilder.<init>介绍

暂无

代码示例

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

private RequestBuilder rebuildRequest(Request rb) {
  return new RequestBuilder(rb);
}

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

public Builder() {
  requestBuilder = new RequestBuilder("GET", false);
}

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

final URI uri = requestContext.getUri();
RequestBuilder builder = new RequestBuilder(strMethod).setUrl(uri.toString());

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

private Builder(SimpleAsyncHttpClient client) {
  this.requestBuilder = new RequestBuilder(client.requestBuilder.build());
  this.defaultThrowableHandler = client.defaultThrowableHandler;
  this.errorDocumentBehaviour = client.errorDocumentBehaviour;
  this.enableResumableDownload = client.resumeEnabled;
  this.ahc = client.asyncHttpClient();
  this.listener = client.listener;
}

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

private void executeSignatureCalculator() {
  /* Let's first calculate and inject signature, before finalizing actual build
   * (order does not matter with current implementation but may in future)
   */
  if (signatureCalculator != null) {
    RequestBuilder rb = new RequestBuilder(request).setSignatureCalculator(null);
    rb.rbQueryParams = this.rbQueryParams;
    Request unsignedRequest = rb.build();
    signatureCalculator.calculateAndAddSignature(unsignedRequest, this);
  }
}

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

/**
 * Invoke this API if you want to set the Range header on your {@link Request} based on the last valid bytes
 * position.
 *
 * @param request {@link Request}
 * @return a {@link Request} with the Range header properly set.
 */
public Request adjustRequestRange(Request request) {
  Long ri = resumableIndex.get(request.getUrl());
  if (ri != null) {
    byteTransferred.set(ri);
  }
  // The Resumbale
  if (resumableListener != null && resumableListener.length() > 0 && byteTransferred.get() != resumableListener.length()) {
    byteTransferred.set(resumableListener.length());
  }
  RequestBuilder builder = new RequestBuilder(request);
  if (request.getHeaders().get("Range").isEmpty() && byteTransferred.get() != 0) {
    builder.setHeader("Range", "bytes=" + byteTransferred.get() + "-");
  }
  return builder.build();
}

代码示例来源：origin: HubSpot/Singularity

private void asyncHealthcheck(final SingularityTask task) {
 final SingularityHealthcheckAsyncHandler handler = new SingularityHealthcheckAsyncHandler(exceptionNotifier, configuration, this, newTaskChecker, taskManager, task);
 final Optional<String> uri = getHealthcheckUri(task);
 if (!uri.isPresent()) {
  saveFailure(handler, "Invalid healthcheck uri or ports not present");
  return;
 }
 final Integer timeoutSeconds = task.getTaskRequest().getDeploy().getHealthcheck().isPresent() ?
  task.getTaskRequest().getDeploy().getHealthcheck().get().getResponseTimeoutSeconds().or(configuration.getHealthcheckTimeoutSeconds()) : configuration.getHealthcheckTimeoutSeconds();
 try {
  PerRequestConfig prc = new PerRequestConfig();
  prc.setRequestTimeoutInMs((int) TimeUnit.SECONDS.toMillis(timeoutSeconds));
  RequestBuilder builder = new RequestBuilder("GET");
  builder.setFollowRedirects(true);
  builder.setUrl(uri.get());
  builder.setPerRequestConfig(prc);
  LOG.trace("Issuing a healthcheck ({}) for task {} with timeout {}s", uri.get(), task.getTaskId(), timeoutSeconds);
  http.prepareRequest(builder.build()).execute(handler);
 } catch (Throwable t) {
  LOG.debug("Exception while preparing healthcheck ({}) for task ({})", uri, task.getTaskId(), t);
  exceptionNotifier.notify(String.format("Error preparing healthcheck (%s)", t.getMessage()), t, ImmutableMap.of("taskId", task.getTaskId().toString()));
  saveFailure(handler, String.format("Healthcheck failed due to exception: %s", t.getMessage()));
 }
}

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

/**
 * Configure and execute the associated {@link RequestFilter}. This class may decorate the {@link Request} and {@link AsyncHandler}
 *
 * @param fc {@link FilterContext}
 * @return {@link FilterContext}
 */
private <T> FilterContext<T> preProcessRequest(FilterContext<T> fc) throws FilterException {
  for (RequestFilter asyncFilter : config.getRequestFilters()) {
    fc = asyncFilter.filter(fc);
    if (fc == null) {
      throw new NullPointerException("FilterContext is null");
    }
  }
  Request request = fc.getRequest();
  if (fc.getAsyncHandler() instanceof ResumableAsyncHandler) {
    request = ResumableAsyncHandler.class.cast(fc.getAsyncHandler()).adjustRequestRange(request);
  }
  if (request.getRangeOffset() != 0) {
    RequestBuilder builder = new RequestBuilder(request);
    builder.setHeader("Range", "bytes=" + request.getRangeOffset() + "-");
    request = builder.build();
  }
  fc = new FilterContext.FilterContextBuilder<T>(fc).request(request).build();
  return fc;
}

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

RequestBuilder builder = new RequestBuilder(request);
    .setUsePreemptiveAuth(true)
    .build();
RequestBuilder builder = new RequestBuilder(request);
request = builder.setRealm(nr).build();
urlConnection = createUrlConnection(request);

代码示例来源：origin: SeanDragon/protools

RequestBuilder builder = new RequestBuilder(method.name());

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

final Request nextRequest = new RequestBuilder(future.getRequest()).setHeaders(request.getHeaders()).setRealm(newRealm).build();

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

private boolean exitAfterHandlingConnect(//
    final Channel channel,//
    final NettyResponseFuture<?> future,//
    final Request request,//
    ProxyServer proxyServer,//
    int statusCode,//
    HttpRequest httpRequest) throws IOException {
  if (statusCode == OK.getCode() && httpRequest.getMethod() == HttpMethod.CONNECT) {
    if (future.isKeepAlive())
      future.attachChannel(channel, true);
    try {
      Uri requestUri = request.getUri();
      String scheme = requestUri.getScheme();
      String host = requestUri.getHost();
      int port = getDefaultPort(requestUri);
      logger.debug("Connecting to proxy {} for scheme {}", proxyServer, scheme);
      channelManager.upgradeProtocol(channel.getPipeline(), scheme, host, port);
    } catch (Throwable ex) {
      requestSender.abort(channel, future, ex);
    }
    future.setReuseChannel(true);
    future.setConnectAllowed(false);
    requestSender.sendNextRequest(new RequestBuilder(future.getRequest()).build(), future);
    return true;
  }
  return false;
}

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

final Request nextRequest = new RequestBuilder(future.getRequest()).setHeaders(request.getHeaders()).setRealm(newRealm).build();

代码示例来源：origin: org.mule.modules/mule-module-http

protected RequestBuilder createRequestBuilder(HttpRequest request, RequestConfigurer requestConfigurer) throws IOException
{
  final RequestBuilder requestBuilder = new RequestBuilder();
  requestConfigurer.configure(requestBuilder);
  return requestBuilder;
}

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

private Builder(SimpleAsyncHttpClient client) {
  this.requestBuilder = new RequestBuilder(client.requestBuilder.build());
  this.defaultThrowableHandler = client.defaultThrowableHandler;
  this.errorDocumentBehaviour = client.errorDocumentBehaviour;
  this.enableResumableDownload = client.resumeEnabled;
  this.ahc = client.asyncHttpClient();
  this.listener = client.listener;
}

代码示例来源：origin: org.mule.services/mule-service-http

protected RequestBuilder createRequestBuilder(HttpRequest request, RequestConfigurer requestConfigurer) throws IOException {
 final RequestBuilder requestBuilder = new RequestBuilder();
 requestConfigurer.configure(requestBuilder);
 return requestBuilder;
}

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

private static Request newRequest(final HttpTransactionContext ctx,
    final Uri newUri, final HttpResponsePacket response,
    final Realm realm, boolean asGet) {
  final Request prototype = ctx.getAhcRequest();
  final FluentCaseInsensitiveStringsMap prototypeHeaders =
      prototype.getHeaders();
  
  prototypeHeaders.remove(Header.Host.toString());
  prototypeHeaders.remove(Header.ContentLength.toString());
  
  if (asGet)
    prototypeHeaders.remove(Header.ContentType.toString());
  if (realm != null && realm.getScheme() == AuthScheme.NTLM) {
    prototypeHeaders.remove(Header.Authorization.toString());
    prototypeHeaders.remove(Header.ProxyAuthorization.toString());
  }
  
  final RequestBuilder builder = new RequestBuilder(prototype);
  if (asGet) {
    builder.setMethod("GET");
  }
  builder.setUrl(newUri.toString());
  for (String cookieStr : response.getHeaders().values(Header.SetCookie)) {
    builder.addOrReplaceCookie(CookieDecoder.decode(cookieStr));
  }
      
  return builder.build();
}

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

final Request nextRequest = new RequestBuilder(req)
    .setRealm(newRealm)
    .build();

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

final Request nextRequest = new RequestBuilder(req)
    .setRealm(newRealm)
    .build();

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

boolean keepBody = statusCode == 307 || (statusCode == 302 && config.isStrict302Handling());
final RequestBuilder requestBuilder = new RequestBuilder(switchToGet ? "GET" : originalMethod)//