本文整理了Java中org.apache.http.client.methods.RequestBuilder.build
方法的一些代码示例,展示了RequestBuilder.build
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RequestBuilder.build
方法的具体详情如下:
包路径:org.apache.http.client.methods.RequestBuilder
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!