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

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

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

RequestBuilder.build介绍

暂无

代码示例

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

/**
  * Add this method for argument capture in test
  */
 @VisibleForTesting
 public HttpUriRequest build(RequestBuilder builder) {
  return builder.build();
 }
}

代码示例来源:origin: zhegexiaohuozi/SeimiCrawler

@Override
public Response metaRefresh(String nextUrl) throws Exception {
  if (!nextUrl.startsWith("http")){
    String prefix = getRealUrl(httpContext);
    nextUrl = prefix + nextUrl;
  }
  logger.info("Seimi refresh url to={} from={}",nextUrl,currentReqBuilder.getUri());
  currentReqBuilder.setUri(nextUrl);
  httpResponse = hc.execute(currentReqBuilder.build(),httpContext);
  return renderResponse(httpResponse,currentRequest,httpContext);
}

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

private static HttpUriRequest getSegmentCompletionProtocolRequest(URI uri, int socketTimeoutMs) {
 RequestBuilder requestBuilder = RequestBuilder.get(uri).setVersion(HttpVersion.HTTP_1_1);
 setTimeout(requestBuilder, socketTimeoutMs);
 return requestBuilder.build();
}

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

private static HttpUriRequest getDownloadFileRequest(URI uri, int socketTimeoutMs) {
 RequestBuilder requestBuilder = RequestBuilder.get(uri).setVersion(HttpVersion.HTTP_1_1);
 setTimeout(requestBuilder, socketTimeoutMs);
 return requestBuilder.build();
}

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

private static HttpUriRequest constructGetRequest(URI uri) {
 RequestBuilder requestBuilder = RequestBuilder.get(uri).setVersion(HttpVersion.HTTP_1_1);
 setTimeout(requestBuilder, GET_REQUEST_SOCKET_TIMEOUT_MS);
 return requestBuilder.build();
}

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

private static HttpUriRequest getSendSegmentJsonRequest(URI uri, String jsonString, @Nullable List<Header> headers,
  @Nullable List<NameValuePair> parameters, int socketTimeoutMs) {
 RequestBuilder requestBuilder = RequestBuilder.post(uri).setVersion(HttpVersion.HTTP_1_1)
   .setHeader(CustomHeaders.UPLOAD_TYPE, FileUploadType.JSON.toString())
   .setEntity(new StringEntity(jsonString, ContentType.APPLICATION_JSON));
 addHeadersAndParameters(requestBuilder, headers, parameters);
 setTimeout(requestBuilder, socketTimeoutMs);
 return requestBuilder.build();
}

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

@Override
public Response process(Request request) throws Exception {
  currentReqBuilder = HcRequestGenerator.getHttpRequestBuilder(request,crawlerModel);
  currentRequest = request;
  addCookies(request.getUrl(),request.getSeimiCookies());
  httpResponse = hc.execute(currentReqBuilder.build(),httpContext);
  return renderResponse(httpResponse,request,httpContext);
}

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

private static HttpUriRequest getSendSegmentUriRequest(URI uri, String downloadUri, @Nullable List<Header> headers,
  @Nullable List<NameValuePair> parameters, int socketTimeoutMs) {
 RequestBuilder requestBuilder = RequestBuilder.post(uri).setVersion(HttpVersion.HTTP_1_1)
   .setHeader(CustomHeaders.UPLOAD_TYPE, FileUploadType.URI.toString())
   .setHeader(CustomHeaders.DOWNLOAD_URI, downloadUri).setHeader(HttpHeaders.CONTENT_TYPE, "application/json");
 addHeadersAndParameters(requestBuilder, headers, parameters);
 setTimeout(requestBuilder, socketTimeoutMs);
 return requestBuilder.build();
}

代码示例来源:origin: liyiorg/weixin-popular

/**
 * 查询所有分组
 * @param access_token access_token
 * @return Group
 */
public static Group groupsGet(String access_token){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
      .setUri(BASE_URI+"/cgi-bin/groups/get")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,Group.class);
}

代码示例来源:origin: liyiorg/weixin-popular

/**
 * 删除菜单
 * @param access_token access_token
 * @return BaseResult
 */
public static BaseResult menuDelete(String access_token){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
      .setUri(BASE_URI+"/cgi-bin/menu/delete")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

代码示例来源:origin: liyiorg/weixin-popular

/**
 * 获取素材总数
 * @param access_token access_token
 * @return MaterialcountResult
 */
public static MaterialcountResult get_materialcount(String access_token){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setUri(BASE_URI+"/cgi-bin/material/get_materialcount")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,MaterialcountResult.class);
}

代码示例来源:origin: liyiorg/weixin-popular

/**
 * 获取菜单
 * @param access_token access_token
 * @return Menu
 */
public static Menu menuGet(String access_token){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
        .setUri(BASE_URI+"/cgi-bin/menu/get")
        .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
        .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,Menu.class);
}

代码示例来源: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: liyiorg/weixin-popular

/**
   * 获取门店类目表
   * @param accessToken accessToken
   * @return result
   */
  public static CategoryListResult getWxCategory(String accessToken) {
    HttpUriRequest httpUriRequest = RequestBuilder.post()
        .setUri(BASE_URI + "/cgi-bin/poi/getwxcategory")
        .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(accessToken)).build();
    return LocalHttpClient.executeJsonResult(httpUriRequest,
        CategoryListResult.class);
  }
}

代码示例来源:origin: liyiorg/weixin-popular

/**
   * 获取微信服务器IP地址
   * @param access_token access_token
   * @return Callbackip
   */
  public static Callbackip getcallbackip(String access_token){
    HttpUriRequest httpUriRequest = RequestBuilder.get()
        .setUri(BASE_URI + "/cgi-bin/getcallbackip")
        .addParameter(PARAM_ACCESS_TOKEN,API.accessToken(access_token))
        .build();
    return LocalHttpClient.executeJsonResult(httpUriRequest,Callbackip.class);
  }
}

代码示例来源: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: liyiorg/weixin-popular

/**
 * 获取在线客服接待信息
 * @param access_token access_token
 * @return KFOnline
 */
public static KFOnline getOnlinekflist(String access_token) {
  HttpUriRequest httpUriRequest = RequestBuilder.get()
      .setHeader(jsonHeader)
      .setUri(BASE_URI + "/cgi-bin/customservice/getonlinekflist")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest, KFOnline.class);
}

代码示例来源:origin: liyiorg/weixin-popular

/**
 * 获取客服基本信息
 * @param access_token access_token
 * @return KFAccount
 */
public static KFAccount getkflist(String access_token) {
  HttpUriRequest httpUriRequest = RequestBuilder.get()
      .setHeader(jsonHeader)
      .setUri(BASE_URI + "/cgi-bin/customservice/getkflist")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest, KFAccount.class);
}

相关文章