org.eclipse.jetty.client.api.Request.content()方法的使用及代码示例

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

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

Request.content介绍

暂无

代码示例

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

proxyRequest.content(new BytesContentProvider(avaticaQuery));
try {
 byte[] bytes = objectMapper.writeValueAsBytes(query);
 proxyRequest.content(new BytesContentProvider(bytes));
 proxyRequest.getHeaders().put(HttpHeader.CONTENT_LENGTH, String.valueOf(bytes.length));

代码示例来源：origin: spring-projects/spring-framework

protected ResponseEntity<String> executeRequest(URI url, HttpMethod method,
    HttpHeaders headers, @Nullable String body) {
  Request httpRequest = this.httpClient.newRequest(url).method(method);
  addHttpHeaders(httpRequest, headers);
  if (body != null) {
    httpRequest.content(new StringContentProvider(body));
  }
  ContentResponse response;
  try {
    response = httpRequest.send();
  }
  catch (Exception ex) {
    throw new SockJsTransportFailureException("Failed to execute request to " + url, ex);
  }
  HttpStatus status = HttpStatus.valueOf(response.getStatus());
  HttpHeaders responseHeaders = toHttpHeaders(response.getHeaders());
  return (response.getContent() != null ?
      new ResponseEntity<>(response.getContentAsString(), responseHeaders, status) :
      new ResponseEntity<>(responseHeaders, status));
}

代码示例来源：origin: konsoletyper/teavm

copyRequestHeaders(req, proxyReq::header);
proxyReq.content(new InputStreamContentProvider(req.getInputStream()));
HeaderSender headerSender = new HeaderSender(resp);

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

final ContentProvider entity = getStreamProvider(jerseyRequest);
if (entity != null) {
  jettyRequest.content(entity);

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

@Override
public ClientResponse apply(final ClientRequest jerseyRequest) throws ProcessingException {
  final Request jettyRequest = translateRequest(jerseyRequest);
  final Map<String, String> clientHeadersSnapshot = writeOutBoundHeaders(jerseyRequest.getHeaders(), jettyRequest);
  final ContentProvider entity = getBytesProvider(jerseyRequest);
  if (entity != null) {
    jettyRequest.content(entity);
  }
  try {
    final ContentResponse jettyResponse = jettyRequest.send();
    HeaderUtils.checkHeaderChanges(clientHeadersSnapshot, jerseyRequest.getHeaders(),
                    JettyConnector.this.getClass().getName());
    final javax.ws.rs.core.Response.StatusType status = jettyResponse.getReason() == null
        ? Statuses.from(jettyResponse.getStatus())
        : Statuses.from(jettyResponse.getStatus(), jettyResponse.getReason());
    final ClientResponse jerseyResponse = new ClientResponse(status, jerseyRequest);
    processResponseHeaders(jettyResponse.getHeaders(), jerseyResponse);
    try {
      jerseyResponse.setEntityStream(new HttpClientResponseInputStream(jettyResponse));
    } catch (final IOException e) {
      LOGGER.log(Level.SEVERE, null, e);
    }
    return jerseyResponse;
  } catch (final Exception e) {
    throw new ProcessingException(e);
  }
}

代码示例来源：origin: sixt/ja-micro

public Request newRequest(HttpClient httpClient) {
  Request request = httpClient.newRequest(uri);
  request.content(contentProvider).method(method);
  for (String key : headers.keySet()) {
    if (! "User-Agent".equals(key)) {
      request.header(key, headers.get(key));
    }
  }
  return request;
}

代码示例来源：origin: sixt/ja-micro

private boolean sendRegistration(JsonObject request) {
  try {
    ContentResponse httpResponse = httpClient.newRequest(getRegistrationUri()).
        content(new StringContentProvider(request.toString())).
        method(HttpMethod.PUT).header(HttpHeader.CONTENT_TYPE, "application/json").send();
    if (httpResponse.getStatus() == 200) {
      return true;
    }
  } catch (Exception ex) {
    logger.warn("Caught exception sending registration {}", request.toString(), ex);
  }
  return false;
}

代码示例来源：origin: sixt/ja-micro

@Override
public Request newRequest(String uri) {
  Request retval = mock(Request.class);
  try {
    if (requestsTimeout || (isFirstRequestTimeout && requests.isEmpty())) {
      when(retval.send()).thenThrow(new TimeoutException());
    } else {
      when(retval.send()).thenReturn(httpResponse);
    }
    if (requestsFail && featureFlag.equals("true")) {
      when(httpResponse.getStatus()).thenReturn(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
    } else if (responseException != null) {
      when(httpResponse.getStatus()).thenReturn(responseException.getCategory().getHttpStatus());
    } else {
      when(httpResponse.getStatus()).thenReturn(HttpServletResponse.SC_OK);
    }
  } catch (Exception e) {
    e.printStackTrace();
  }
  when(retval.method(anyString())).thenReturn(retval);
  when(retval.content(any(ContentProvider.class))).thenReturn(retval);
  when(retval.timeout(anyLong(), any(TimeUnit.class))).thenReturn(retval);
  requests.add(uri);
  return retval;
}

代码示例来源：origin: sixt/ja-micro

@Before
public void setup() throws InterruptedException, ExecutionException, TimeoutException {
  when(loadBalancer.getHealthyInstance()).thenReturn(createServiceEndpoint());
  when(loadBalancer.getHealthyInstanceExclude(anyListOf(ServiceEndpoint.class)))
    .thenReturn(createServiceEndpoint());
  when(rpcClient.getRetries()).thenReturn(NUMBER_OF_RETRIES);
  when(rpcClient.getTimeout()).thenReturn(0);
  httpClientWrapper.setLoadBalancer(loadBalancer);
  when(rpcClientMetrics.getMethodTimer(any(), any())).thenReturn(new GoTimer("timer"));
  when(tracer.buildSpan(any())).thenReturn(spanBuilder);
  when(spanBuilder.start()).thenReturn(span);
  when(httpClient.newRequest(any(URI.class))).thenReturn(request);
  when(httpClient.newRequest(any(String.class))).thenReturn(request);
  when(request.content(any(ContentProvider.class))).thenReturn(request);
  when(request.method(anyString())).thenReturn(request);
  when(request.timeout(anyLong(), any(TimeUnit.class))).thenReturn(request);
  when(request.send()).thenReturn(httpContentResponse);
  when(httpContentResponse.getStatus()).thenReturn(100);
  dependencyHealthCheck = mock(ServiceDependencyHealthCheck.class);
}

代码示例来源：origin: sixt/ja-micro

protected String sendRequest(String path, String data, HttpMethod method) throws Exception {
  String url = getServiceUrl(path);
  Request request = httpClient.newRequest(url).method(method).
      header(HttpHeader.CONTENT_TYPE, "application/json");
  if (data != null) {
    request.content(new StringContentProvider(data));
  }
  ContentResponse response = request.send();
  return response.getContentAsString();
}

代码示例来源：origin: resteasy/Resteasy

request.content(new BytesContentProvider(os.toByteArray()));

代码示例来源：origin: org.eclipse.jetty/jetty-reactive-httpclient

/**
 * <p>Provides the request content via a Publisher.</p>
 *
 * @param content the request content
 * @return this instance
 */
public Builder content(Content content) {
  request.content(new PublisherContentProvider(content));
  return this;
}

代码示例来源：origin: jetty-project/jetty-reactive-httpclient

/**
 * <p>Provides the request content via a Publisher.</p>
 *
 * @param content the request content
 * @return this instance
 */
public Builder content(Content content) {
  request.content(new PublisherContentProvider(content));
  return this;
}

代码示例来源：origin: seleniumkit/gridrouter

protected Request getRequestWithoutSessionId(HttpServletRequest clientRequest, Request proxyRequest) throws IOException {
  String content = IOUtils.toString(clientRequest.getInputStream(), UTF_8);
  if (!content.isEmpty()) {
    String remoteHost = getRemoteHost(clientRequest);
    content = removeSessionIdSafe(content, remoteHost);
  }
  return proxyRequest.content(
      new StringContentProvider(clientRequest.getContentType(), content, UTF_8));
}

代码示例来源：origin: isucon/isucon5-final

private Request createPostRequest(Session session, String path, ContentProvider content) {
  Request req = client.newRequest(config.uri(path))
    .method("POST")
    .timeout(Config.POST_TIMEOUT, TimeUnit.MILLISECONDS)
    .content(content)
    .header("Content-Length", String.valueOf(content.getLength()));
  session.writeCookie(req);
  return req;
}

代码示例来源：origin: isucon/isucon5-qualify

private Request createPostRequest(Session session, String path, ContentProvider content) {
 Request req = client.newRequest(config.uri(path))
  .method("POST")
  .timeout(Config.POST_TIMEOUT, TimeUnit.MILLISECONDS)
  .content(content)
  .header("Content-Length", String.valueOf(content.getLength()));
 session.writeCookie(req);
 return req;
}

代码示例来源：origin: org.infinispan/infinispan-server-rest

private ContentResponse writeJsonToCache(String key, String json, String cacheName) throws Exception {
 return client.newRequest(String.format("http://localhost:%d/rest/%s/%s", restServer().getPort(), cacheName, key))
    .content(new StringContentProvider(json))
    .header(HttpHeader.CONTENT_TYPE, APPLICATION_JSON_TYPE)
    .method(HttpMethod.PUT).send();
}

代码示例来源：origin: org.infinispan/infinispan-server-rest

protected void registerProtobuf(String protoFileName, String protoFileContents) throws Exception {
 String protobufMetadataUrl = getProtobufMetadataUrl(protoFileName);
 ContentResponse response = client
    .newRequest(protobufMetadataUrl)
    .content(new StringContentProvider(protoFileContents))
    .method(POST)
    .send();
 assertEquals(response.getStatus(), HttpStatus.OK_200);
 String errorKey = protoFileName.concat(".error");
 ContentResponse errorCheck = client.newRequest(getProtobufMetadataUrl(errorKey)).method(GET).send();
 assertEquals(errorCheck.getStatus(), HttpStatus.NOT_FOUND_404);
}

代码示例来源：origin: org.infinispan/infinispan-server-rest

void putBinaryValueInCache(String cacheName, String key, byte[] value, MediaType mediaType) throws InterruptedException, ExecutionException, TimeoutException {
 ContentResponse response = client
    .newRequest(String.format("http://localhost:%d/rest/%s/%s", restServer().getPort(), cacheName, key))
    .content(new BytesContentProvider(value))
    .header(HttpHeader.CONTENT_TYPE, mediaType.toString())
    .method(HttpMethod.PUT)
    .send();
 ResponseAssertion.assertThat(response).isOk();
}

代码示例来源：origin: org.infinispan/infinispan-server-rest

private void putInCache(String cacheName, Object key, String keyContentType, String value, String contentType) throws InterruptedException, ExecutionException, TimeoutException {
 Request request = client
    .newRequest(String.format("http://localhost:%d/rest/%s/%s", restServer().getPort(), cacheName, key))
    .content(new StringContentProvider(value))
    .header("Content-type", contentType)
    .method(HttpMethod.PUT);
 if (keyContentType != null) request.header("Key-Content-type", keyContentType);
 ContentResponse response = request.send();
 ResponseAssertion.assertThat(response).isOk();
}

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com