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

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

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

RequestBuilder.setUrl介绍

暂无

代码示例

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

public Builder setUrl(String url) {
  requestBuilder.setUrl(url);
  return this;
}

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

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

代码示例来源：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: org.sonatype.cert-support/ahc-cert-impl

private static RequestBuilder requestBuilder( String method, String url )
{
  return new RequestBuilder( method ).setUrl( url );
}

代码示例来源：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: dhanji/sitebricks

@Override
public ListenableFuture<WebResponse> get(Executor executor) {
 return simpleAsyncRequest(new RequestBuilder("GET").setUrl(url), executor);
}

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

final Request nextRequest = requestBuilder.setUrl(newUrl).build();

代码示例来源：origin: apache/predictionio-sdk-java

/**
 * Sends an asynchronous get event request to the API.
 *
 * @param eid ID of the event to get
 */
public FutureAPIResponse getEventAsFuture(String eid) throws IOException {
 Request request = (new RequestBuilder("GET"))
   .setUrl(apiUrl + "/events/" + eid + ".json?accessKey=" + accessKey)
   .build();
 return new FutureAPIResponse(client.executeRequest(request, getHandler()));
}

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

@Test(groups = {"standalone", "default_provider"})
public void testParsesQueryParams() throws IOException, ExecutionException, InterruptedException {
  Request request = new RequestBuilder("GET")
      .setUrl("http://foo.com/?param1=value1")
      .addQueryParam("param2", "value2")
      .build();
  assertEquals(request.getUrl(), "http://foo.com/?param1=value1&param2=value2");
  List<Param> params = request.getQueryParams();
  assertEquals(params.size(), 2);
  assertEquals(params.get(0), new Param("param1", "value1"));
  assertEquals(params.get(1), new Param("param2", "value2"));
}

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

@Test(dataProvider = "timeout")
public void testRequestTimeout(String timeout) {
  SLEEP_TIME = Long.valueOf(timeout) * 2;
  AsyncHttpClient client = getAsyncHttpClient(clientConfig);
  Request request = new RequestBuilder("GET").setRequestTimeout(Integer.valueOf(timeout)).setUrl(getTargetUrl().concat(REDIRECT_PATH)).build();
  ListenableFuture<Response> responseFuture = client.executeRequest(request);
  assertTimeout(responseFuture, timeout);
}

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

<T> Request asNingRequest(final Requestable requestable) {
  final HttpRequest request = requestable.httpRequest();
  final RequestBuilder builder = new RequestBuilder().
      setUrl(CharMatcher.is('/').trimTrailingFrom(coreUrl) + "/" + projectKey + request.getPath()).
      setMethod(request.getHttpMethod().toString()).
      setHeader("User-Agent", "SPHERE.IO JVM SDK version " + BuildInfo.version()).
      setHeader("Authorization", "Bearer " + clientCredentials.getAccessToken());
  return request.getBody().map(builder::setBody).orElse(builder).build();
}

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

@Test(groups = {"standalone", "default_provider"})
public void testChaining() throws IOException, ExecutionException, InterruptedException {
  Request request = new RequestBuilder("GET")
      .setUrl("http://foo.com")
      .addQueryParam("x", "value")
      .build();
  Request request2 = new RequestBuilder(request).build();
  assertEquals(request2.getUri(), request.getUri());
}

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

@Test(groups = "fast")
public void testSignatureBaseStringWithRawUri() {
  // note: @ is legal so don't decode it into %40 because it won't be encoded back
  // note: we don't know how to fix a = that should have been encoded as %3D but who would be stupid enough to do that?
  Request request = new RequestBuilder("POST")//
      .setUrl("http://example.com/request?b5=%3D%253D&a3=a&c%40=&a2=r b")//
      .addFormParam("c2", "")//
      .addFormParam("a3", "2 q")//
      .build();
  testSignatureBaseString(request);
  testSignatureBaseStringWithEncodableOAuthToken(request);
}

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

@Test(groups = "fast")
public void testSignatureBaseStringWithProperlyEncodedUri() {
  Request request = new RequestBuilder("POST")//
      .setUrl("http://example.com/request?b5=%3D%253D&a3=a&c%40=&a2=r%20b")//
      .addFormParam("c2", "")//
      .addFormParam("a3", "2 q")//
      .build();
  testSignatureBaseString(request);
  testSignatureBaseStringWithEncodableOAuthToken(request);
}

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

@Test
public void handlesCloseResponse() throws IOException, InterruptedException, ExecutionException {
  AsyncHttpClientConfig config = new Builder().setSSLContext(createSSLContext(new AtomicBoolean(true))).build();
  try (AsyncHttpClient client = getAsyncHttpClient(config)) {
    Request request = new RequestBuilder("GET").setHeader("Connection", "keep-alive").setUrl(getTargetUrl()).build();
    Future<Response> responseFuture = client.executeRequest(request);
    int status = responseFuture.get().getStatusCode();
    Assert.assertEquals(status, 200);
  }
}

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

private ListenableFuture<Response> testMethodRequest(AsyncHttpClient
    fetcher, int requests, String action, String id) throws IOException {
  RequestBuilder builder = new RequestBuilder("GET");
  builder.addQueryParam(action, "1");
  builder.addQueryParam("maxRequests", "" + requests);
  builder.addQueryParam("id", id);
  builder.setUrl(servletEndpointUri.toString());
  com.ning.http.client.Request r = builder.build();
  return fetcher.executeRequest(r);
}

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

@Test
public void ntlmProxyTest() throws IOException, InterruptedException, ExecutionException {
  AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder().build();
  try (AsyncHttpClient client = getAsyncHttpClient(config)) {
    Request request = new RequestBuilder("GET").setProxyServer(ntlmProxy()).setUrl(getTargetUrl()).build();
    Future<Response> responseFuture = client.executeRequest(request);
    int status = responseFuture.get().getStatusCode();
    Assert.assertEquals(status, 200);
  }
}

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

private void ntlmAuthTest(RealmBuilder realmBuilder) throws IOException, InterruptedException, ExecutionException {
  AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder().setRealm(realmBuilder.build()).build();
  try (AsyncHttpClient client = getAsyncHttpClient(config)) {
    Request request = new RequestBuilder("GET").setUrl(getTargetUrl()).build();
    Future<Response> responseFuture = client.executeRequest(request);
    int status = responseFuture.get().getStatusCode();
    Assert.assertEquals(status, 200);
  }
}

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

private void doTest(boolean usePreemptiveAuth) throws UnknownHostException, InterruptedException, ExecutionException
{
  try (AsyncHttpClient client = getAsyncHttpClient(new AsyncHttpClientConfig.Builder().build())) {
    Request request = new RequestBuilder("GET").setProxyServer(basicProxy()).setUrl(getTargetUrl()).setRealm(
      new Realm.RealmBuilder().setPrincipal("user").setPassword("passwd").setScheme(BASIC).setUsePreemptiveAuth(usePreemptiveAuth).build()).build();
    Future<Response> responseFuture = client.executeRequest(request);
    Response response = responseFuture.get();
    Assert.assertEquals(response.getStatusCode(), HttpServletResponse.SC_OK);
    Assert.assertTrue(getTargetUrl().endsWith(response.getHeader("target")));
  }
}

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

private void doTestWithInputStreamBodyGenerator(InputStream is) throws Throwable {
  AsyncHttpClientConfig.Builder bc = httpClientBuilder();
  try (AsyncHttpClient c = getAsyncHttpClient(bc.build())) {
    RequestBuilder builder = new RequestBuilder("POST");
    builder.setUrl(getTargetUrl());
    builder.setBody(new InputStreamBodyGenerator(is));
    Request r = builder.build();
    final ListenableFuture<Response> responseFuture = c.executeRequest(r);
    waitForAndAssertResponse(responseFuture);
  }
}

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

RequestBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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