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

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

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

RequestBuilder.setEntity介绍

暂无

代码示例

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

/**
 * Add payload to request. By default, payload is sent as application/json
 */
protected int addPayload(RequestBuilder builder, String payload) {
 if (payload == null || payload.length() == 0) {
  return 0;
 }
 builder.setHeader(HttpHeaders.CONTENT_TYPE, contentType.getMimeType());
 builder.setEntity(new StringEntity(payload, contentType));
 return payload.length();
}

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

private HttpUriRequest newRequest(RequestBuilder builder, JsonElement payload) {
 try {
  builder.addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType())
      .addHeader(HttpHeaders.AUTHORIZATION, "OAuth " + accessToken)
      .setEntity(new StringEntity(payload.toString(), ContentType.APPLICATION_JSON));
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
 if (getLog().isDebugEnabled()) {
  getLog().debug("Request builder: " + ToStringBuilder.reflectionToString(builder, ToStringStyle.SHORT_PREFIX_STYLE));
 }
 return builder.build();
}

代码示例来源：origin: code4craft/webmagic

private RequestBuilder addFormParams(RequestBuilder requestBuilder, Request request) {
  if (request.getRequestBody() != null) {
    ByteArrayEntity entity = new ByteArrayEntity(request.getRequestBody().getBody());
    entity.setContentType(request.getRequestBody().getContentType());
    requestBuilder.setEntity(entity);
  }
  return requestBuilder;
}

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

@Override
public Optional<HttpUriRequest> onNewRecord(D record) {
 try {
  HttpUriRequest uriRequest = RequestBuilder.post()
    .addHeader(HttpHeaders.CONTENT_TYPE, ContentType.TEXT_PLAIN.getMimeType())
    .setUri(getCurServerHost())
    .setEntity(new StringEntity(record.toString(), ContentType.TEXT_PLAIN.toString()))
    .build();
  return Optional.of(uriRequest);
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
}

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

/**
 * 高级群发 构成 MassMPnewsMessage 对象的前置请求接口
 * @param access_token access_token
 * @param messageJson messageJson
 * @return result
 */
public static Media mediaUploadnews(String access_token,String messageJson){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/media/uploadnews")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(messageJson,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,Media.class);
}

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

/**
 * 创建二维码
 * @param access_token access_token
 * @param qrcodeJson json 数据
 * @return QrcodeTicket
 */
private static QrcodeTicket qrcodeCreate(String access_token,String qrcodeJson){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/qrcode/create")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(qrcodeJson,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,QrcodeTicket.class);
}

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

/**
 * 创建菜单
 * @param access_token access_token
 * @param menuJson 菜单json 数据 例如{\"button\":[{\"type\":\"click\",\"name\":\"今日歌曲\",\"key\":\"V1001_TODAY_MUSIC\"},{\"type\":\"click\",\"name\":\"歌手简介\",\"key\":\"V1001_TODAY_SINGER\"},{\"name\":\"菜单\",\"sub_button\":[{\"type\":\"view\",\"name\":\"搜索\",\"url\":\"http://www.soso.com/\"},{\"type\":\"view\",\"name\":\"视频\",\"url\":\"http://v.qq.com/\"},{\"type\":\"click\",\"name\":\"赞一下我们\",\"key\":\"V1001_GOOD\"}]}]}
 * @return BaseResult
 */
public static BaseResult menuCreate(String access_token,String menuJson){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/menu/create")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(menuJson,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

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

/**
 * 测试个性化菜单匹配结果
 * @param access_token access_token
 * @param user_id 可以是粉丝的OpenID，也可以是粉丝的微信号。
 * @return TrymatchResult
 */
public static TrymatchResult menuTrymatch(String access_token,String user_id){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
      .setHeader(jsonHeader)
      .setUri(BASE_URI+"/cgi-bin/menu/trymatch")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .setEntity(new StringEntity("{\"user_id\":\""+user_id+"\"}",Charset.forName("utf-8")))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,TrymatchResult.class);
}

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

/**
 * 删除个性化菜单
 * @param access_token access_token
 * @param menuid menuid
 * @return BaseResult
 */
public static BaseResult menuDelconditional(String access_token,String menuid){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
      .setHeader(jsonHeader)
      .setUri(BASE_URI+"/cgi-bin/menu/delconditional")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .setEntity(new StringEntity("{\"menuid\":\""+menuid+"\"}",Charset.forName("utf-8")))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

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

/**
 * 删除永久素材
 * @param access_token access_token
 * @param media_id media_id
 * @return BaseResult
 */
public static BaseResult del_material(String access_token,String media_id){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
        .setHeader(jsonHeader)
        .setUri(BASE_URI+"/cgi-bin/material/del_material")
        .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
        .setEntity(new StringEntity("{\"media_id\":\""+media_id+"\"}",Charset.forName("utf-8")))
        .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

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

/**
 * 高级群发接口 根据OpenID列表群发
 *
 * @param access_token access_token
 * @param messageJson  messageJson
 * @return MessageSendResult
 */
public static MessageSendResult messageMassSend(String access_token, String messageJson) {
  HttpUriRequest httpUriRequest = RequestBuilder.post()
      .setHeader(jsonHeader)
      .setUri(BASE_URI + "/cgi-bin/message/mass/send")
      .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
      .setEntity(new StringEntity(messageJson, Charset.forName("utf-8")))
      .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest, MessageSendResult.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 access_token access_token
 * @param media_id media_id
 * @return MaterialGetResult
 */
public static MaterialGetResult get_material(String access_token,String media_id){
  HttpUriRequest httpUriRequest = RequestBuilder.post()
        .setHeader(jsonHeader)
        .setUri(BASE_URI+"/cgi-bin/material/get_material")
        .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
        .setEntity(new StringEntity("{\"media_id\":\""+media_id+"\"}",Charset.forName("utf-8")))
        .build();
  return LocalHttpClient.execute(httpUriRequest,BytesOrJsonResponseHandler.createResponseHandler(MaterialGetResult.class));
}

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

/**
 * 将评论标记精选
 * @param access_token access_token
 * @param markelect markelect
 * @return BaseResult BaseResult
 */
public static BaseResult markelect(String access_token,Params markelect){
  String json = JsonUtil.toJSONString(markelect);
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/comment/markelect")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(json,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

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

/**
 * 删除回复
 * @param access_token access_token
 * @param delete delete
 * @return BaseResult BaseResult
 */
public static BaseResult replyDelete(String access_token,Params delete){
  String json = JsonUtil.toJSONString(delete);
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/comment/reply/delete")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(json,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.class);
}

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

/**
 * 将评论取消精选
 * @param access_token access_token
 * @param unmarkelect unmarkelect
 * @return BaseResult BaseResult
 */
public static BaseResult unmarkelect(String access_token,Params unmarkelect){
  String json = JsonUtil.toJSONString(unmarkelect);
  HttpUriRequest httpUriRequest = RequestBuilder.post()
                  .setHeader(jsonHeader)
                  .setUri(BASE_URI+"/cgi-bin/comment/unmarkelect")
                  .addParameter(PARAM_ACCESS_TOKEN, API.accessToken(access_token))
                  .setEntity(new StringEntity(json,Charset.forName("utf-8")))
                  .build();
  return LocalHttpClient.executeJsonResult(httpUriRequest,BaseResult.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();
}

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

RequestBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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