org.asynchttpclient.RequestBuilder.addHeader()方法的使用及代码示例

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

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

RequestBuilder.addHeader介绍

暂无

代码示例

代码示例来源：origin: AsyncHttpClient/async-http-client

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

代码示例来源：origin: AsyncHttpClient/async-http-client

public <T> FilterContext<T> filter(FilterContext<T> ctx) {
  if (ctx.getResponseHeaders() != null && ctx.getResponseHeaders().get("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: AsyncHttpClient/async-http-client

private void doTestNegative(final int status, boolean strict) throws Exception {
 ResponseFilter responseFilter = new ResponseFilter() {
  @Override
  public <T> FilterContext<T> filter(FilterContext<T> ctx) {
   // pass on the x-expect-get and remove the x-redirect
   // headers if found in the response
   ctx.getResponseHeaders().get("x-expect-post");
   ctx.getRequest().getHeaders().add("x-expect-post", "true");
   ctx.getRequest().getHeaders().remove("x-redirect");
   return ctx;
  }
 };
 try (AsyncHttpClient p = asyncHttpClient(config().setFollowRedirect(true).setStrict302Handling(strict).addResponseFilter(responseFilter))) {
  Request request = post(getTargetUrl()).addFormParam("q", "a b").addHeader("x-redirect", +status + "@" + "http://localhost:" + port1 + "/foo/bar/baz").addHeader("x-negative", "true").build();
  Future<Integer> responseFuture = p.executeRequest(request, new AsyncCompletionHandler<Integer>() {
   @Override
   public Integer onCompleted(Response response) {
    return response.getStatusCode();
   }
   @Override
   public void onThrowable(Throwable t) {
    t.printStackTrace();
    fail("Unexpected exception: " + t.getMessage(), t);
   }
  });
  int statusCode = responseFuture.get();
  assertEquals(statusCode, 200);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

public <T> FilterContext<T> filter(FilterContext<T> ctx) {
  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: AsyncHttpClient/async-http-client

private void doTestPositive(final int status) throws Exception {
 ResponseFilter responseFilter = new ResponseFilter() {
  @Override
  public <T> FilterContext<T> filter(FilterContext<T> ctx) {
   // pass on the x-expect-get and remove the x-redirect
   // headers if found in the response
   ctx.getResponseHeaders().get("x-expect-get");
   ctx.getRequest().getHeaders().add("x-expect-get", "true");
   ctx.getRequest().getHeaders().remove("x-redirect");
   return ctx;
  }
 };
 try (AsyncHttpClient p = asyncHttpClient(config().setFollowRedirect(true).addResponseFilter(responseFilter))) {
  Request request = post(getTargetUrl()).addFormParam("q", "a b").addHeader("x-redirect", +status + "@" + "http://localhost:" + port1 + "/foo/bar/baz").build();
  Future<Integer> responseFuture = p.executeRequest(request, new AsyncCompletionHandler<Integer>() {
   @Override
   public Integer onCompleted(Response response) {
    return response.getStatusCode();
   }
   @Override
   public void onThrowable(Throwable t) {
    t.printStackTrace();
    fail("Unexpected exception: " + t.getMessage(), t);
   }
  });
  int statusCode = responseFuture.get();
  assertEquals(statusCode, 200);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

public <T> FilterContext<T> filter(FilterContext<T> ctx) {
  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;
 }
};

代码示例来源：origin: org.asynchttpclient/async-http-client-api

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

代码示例来源：origin: ribasco/async-gamequery-lib

@Override
  protected void applyAuthenticationScheme(RequestBuilder requestBuilder, String authToken) {
    requestBuilder.addHeader("authorization", String.format("Bearer %s", authToken));
  }
}

代码示例来源：origin: com.tradeshift.sdk/tradeshift-sdk-core

/**
 * {@inheritDoc}
 */
@Override
public RequestBuilder unauthenticated(RequestBuilder req) {
  req.addHeader(TradeshiftHeaders.TENANT_ID, DefaultUsers.ANONYMOUS_COMPANY_ACCOUNT_ID.toString());
  req.addHeader(TradeshiftHeaders.ACTOR_ID, DefaultUsers.ANONYMOUS_USER_ID.toString());
  return req;
}

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

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

代码示例来源：origin: com.tradeshift.sdk/tradeshift-sdk-core

@Override
public RequestBuilder unauthenticated(RequestBuilder req) {
  req.addHeader(TradeshiftHeaders.TENANT_ID, DefaultUsers.ANONYMOUS_COMPANY_ACCOUNT_ID.toString());
  req.addHeader(TradeshiftHeaders.ACTOR_ID, DefaultUsers.ANONYMOUS_USER_ID.toString());
  return req;
}

代码示例来源：origin: com.tradeshift.sdk/tradeshift-sdk-core

private static void withLocale(UserContext ctx, RequestBuilder req) {
  req.addHeader(ACCEPT_LANGUAGE, ctx.getLocale().toLanguageTag());
}

代码示例来源：origin: ribasco/async-gamequery-lib

protected void header(CharSequence header, String value) {
  request().addHeader(header, value);
}

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

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

代码示例来源：origin: com.tradeshift.sdk/tradeshift-sdk-core

/**
   * {@inheritDoc}
   */
  @Override
  public RequestBuilder authenticated(RequestBuilder req, UserContext ctx) {
    req.addHeader(TradeshiftHeaders.TENANT_ID, ctx.getCompanyAccountId().toString());
    req.addHeader(TradeshiftHeaders.ACTOR_ID, ctx.getUserId().toString());
    return req;
  }
}

代码示例来源：origin: cloudbees/zendesk-java-client

private Request req(String method, String url) {
  RequestBuilder builder = new RequestBuilder(method);
  if (realm != null) {
    builder.setRealm(realm);
  } else {
    builder.addHeader("Authorization", "Bearer " + oauthToken);
  }
  builder.setUrl(RESTRICTED_PATTERN.matcher(url).replaceAll("+")); // replace out %2B with + due to API restriction
  return builder.build();
}

代码示例来源：origin: cloudbees/zendesk-java-client

private Request req(String method, Uri template, String contentType, byte[] body) {
  RequestBuilder builder = new RequestBuilder(method);
  if (realm != null) {
    builder.setRealm(realm);
  } else {
    builder.addHeader("Authorization", "Bearer " + oauthToken);
  }
  builder.setUrl(RESTRICTED_PATTERN.matcher(template.toString()).replaceAll("+")); //replace out %2B with + due to API restriction
  builder.addHeader("Content-type", contentType);
  builder.setBody(body);
  return builder.build();
}

代码示例来源：origin: com.tradeshift.sdk/tradeshift-sdk-core

@Override
  public RequestBuilder authenticated(RequestBuilder req, UserContext ctx) {
    req.addHeader(TradeshiftHeaders.TENANT_ID, ctx.getCompanyAccountId().toString());
    req.setSignatureCalculator(new OAuthSignatureCalculator(consumerKeyLookup.apply(ctx), tokenLookup.apply(ctx)));
    return req;
  }
}

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

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.setBody(bodyAsString);
      if (!request.getHeaders().findFlatHeader(HttpHeaders.CONTENT_TYPE).isPresent()) {
        builder.addHeader(HttpHeaders.CONTENT_TYPE, "application/json; charset=utf-8");
      }
    } 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()));
    }
  });
  return builder.build();
}

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

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.setBody(bodyAsString);
      if (!request.getHeaders().findFlatHeader(HttpHeaders.CONTENT_TYPE).isPresent()) {
        builder.addHeader(HttpHeaders.CONTENT_TYPE, "application/json; charset=utf-8");
      }
    } 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()));
    }
  });
  return builder.build();
}

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

RequestBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    RequestBuilder类方法

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