javax.ws.rs.core.Response.getHeaders()方法的使用及代码示例

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

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

Response.getHeaders介绍

[英]Get view of the response headers and their object values. The underlying header data may be subsequently modified by the JAX-RS runtime on the server side. Changes in the underlying header data are reflected in this view.

On the server-side, when the message is sent, the non-string values will be serialized using a javax.ws.rs.ext.RuntimeDelegate.HeaderDelegate if one is available via javax.ws.rs.ext.RuntimeDelegate#createHeaderDelegate(java.lang.Class) for the class of the value or using the values toString method if a header delegate is not available.

On the client side, the returned map is identical to the one returned by #getStringHeaders().
[中]获取响应头及其对象值的视图。随后,服务器端的JAX-RS运行时可能会修改底层头数据。基础标题数据中的更改反映在该视图中。
在服务器端,当消息被发送时,非字符串值将使用javax进行序列化。ws。rs.ext.RuntimeDelegate。HeaderDelegate(如果可以通过javax获得)。ws。rs.ext.RuntimeDelegate#createHeaderDelegate(java.lang.Class)用于值的类,或者在头委托不可用时使用values-toString方法。
在客户端,返回的映射与#getStringHeaders()返回的映射相同。

代码示例

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

@Override
  public Response getListingJson(Application app, ServletConfig sc,
                  HttpHeaders headers, UriInfo uriInfo)  throws JsonProcessingException {
    Response response =  getListingJsonResponse(app, context, sc, headers, uriInfo);
    response.getHeaders().add("Access-Control-Allow-Origin", "*");
    response.getHeaders().add("Access-Control-Allow-Headers", "x-requested-with, ssi-token");
    response.getHeaders().add("Access-Control-Max-Age", "3600");
    response.getHeaders().add("Access-Control-Allow-Methods","GET,POST,PUT,DELETE,OPTIONS");
    return response;
  }
}

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

@Override
  public Response getListingJson(Application app, ServletConfig sc,
                  HttpHeaders headers, UriInfo uriInfo)  throws JsonProcessingException {
    Response response =  getListingJsonResponse(app, context, sc, headers, uriInfo);
    response.getHeaders().add("Access-Control-Allow-Origin", "*");
    response.getHeaders().add("Access-Control-Allow-Headers", "x-requested-with, ssi-token");
    response.getHeaders().add("Access-Control-Max-Age", "3600");
    response.getHeaders().add("Access-Control-Allow-Methods","GET,POST,PUT,DELETE,OPTIONS");
    return response;
  }
}

代码示例来源:origin: apache/nifi

for (final String key : response.getHeaders().keySet()) {
  final List<Object> values = response.getHeaders().get(key);
  for (final Object value : values) {
    if (key.equalsIgnoreCase("transfer-encoding") || key.equalsIgnoreCase("content-length")) {

代码示例来源:origin: apache/storm

private <T> void assertEqualsJsonResponse(Response expected, Response actual, Class<T> entityClass) throws IOException {
    ObjectMapper objectMapper = new ObjectMapper();
    T entityFromExpected = objectMapper.readValue((String) expected.getEntity(), entityClass);
    T actualFromExpected = objectMapper.readValue((String) expected.getEntity(), entityClass);
    assertEquals(entityFromExpected, actualFromExpected);

    assertEquals(expected.getStatus(), actual.getStatus());
    assertTrue(expected.getHeaders().equalsIgnoreValueOrder(actual.getHeaders()));
  }
}

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

@Override
  public void run() {
    try {
      requestScopeListener.resume(foreignScopeInstance, responder.runtime.injectionManager);
      final Response jaxrsResponse =
          (response instanceof Response) ? (Response) response : Response.ok(response).build();
      if (!responder.runtime.disableLocationHeaderRelativeUriResolution) {
        ServerRuntime.ensureAbsolute(jaxrsResponse.getLocation(), jaxrsResponse.getHeaders(),
            responder.processingContext.request(),
            responder.runtime.rfc7231LocationHeaderRelativeUriResolution);
      }
      responder.process(new ContainerResponse(responder.processingContext.request(), jaxrsResponse));
    } catch (final Throwable t) {
      responder.process(t);
    }
  }
});

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

@Override
  public void run() {
    try {
      requestScopeListener.resume(foreignScopeInstance, responder.runtime.injectionManager);
      final Response jaxrsResponse =
          (response instanceof Response) ? (Response) response : Response.ok(response).build();
      if (!responder.runtime.disableLocationHeaderRelativeUriResolution) {
        ServerRuntime.ensureAbsolute(jaxrsResponse.getLocation(), jaxrsResponse.getHeaders(),
            responder.processingContext.request(),
            responder.runtime.rfc7231LocationHeaderRelativeUriResolution);
      }
      responder.process(new ContainerResponse(responder.processingContext.request(), jaxrsResponse));
    } catch (final Throwable t) {
      responder.process(t);
    }
  }
});

代码示例来源:origin: aol/micro-server

@Test
public void runAppAndBasicTest() throws InterruptedException, ExecutionException{
  
  Client client = ClientBuilder.newClient();
  WebTarget resource = client.target("http://localhost:8080/simple-app/single/ping");
  Builder request = resource.request();
  request.accept(MediaType.TEXT_PLAIN);
  assertFalse(request.get().getHeaders().containsKey("Access-Control-Allow-Origin"));
  
  

}

代码示例来源:origin: aol/micro-server

@Test
public void runAppAndBasicTest() throws InterruptedException, ExecutionException{
  
  Client client = ClientBuilder.newClient();
  WebTarget resource = client.target("http://localhost:8080/simple-app/single/ping");
  Builder request = resource.request();
  request.accept(MediaType.TEXT_PLAIN);
  assertTrue(request.get().getHeaders().containsKey("Access-Control-Allow-Origin"));
  
  

}

代码示例来源:origin: stackoverflow.com

public class InterceptingOkClient extends OkClient
{
  public InterceptingOkClient()
  {
  }

  public InterceptingOkClient(OkHttpClient client)
  {
    super(client);
  }

  @Override
  public Response execute(Request request) throws IOException
  {
    Response response = super.execute(request);

    for (Header header : response.getHeaders())
    {
      // do something with header
    }

    return response;
  }
}

代码示例来源:origin: hugegraph/hugegraph

@Override
public Response toResponse(WebApplicationException exception) {
  Response response = exception.getResponse();
  if (response.hasEntity()) {
    return response;
  }
  MultivaluedMap<String, Object> headers = response.getHeaders();
  boolean trace = this.trace(response.getStatus());
  response = Response.status(response.getStatus())
            .type(MediaType.APPLICATION_JSON)
            .entity(formatException(exception, trace))
            .build();
  response.getHeaders().putAll(headers);
  return response;
}

代码示例来源:origin: apache/servicecomb-java-chassis

@Override
 public Response mapResponse(StatusType status, Object response) {
  javax.ws.rs.core.Response jaxrsResponse = (javax.ws.rs.core.Response) response;

  Response cseResponse = Response.status(jaxrsResponse.getStatusInfo()).entity(jaxrsResponse.getEntity());
  MultivaluedMap<String, Object> headers = jaxrsResponse.getHeaders();
  for (Entry<String, List<Object>> entry : headers.entrySet()) {
   if (entry.getValue() == null || entry.getValue().isEmpty()) {
    continue;
   }

   cseResponse.getHeaders().addHeader(entry.getKey(), entry.getValue());
  }
  return cseResponse;
 }
}

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

if (candiate.handles(response.getStatus(), response.getHeaders()))

代码示例来源:origin: hugegraph/hugegraph

private Response doGetRequest(String location, String auth, String query) {
  String url = String.format("%s?%s", location, query);
  Response r = this.client.target(url)
              .request()
              .header(HttpHeaders.AUTHORIZATION, auth)
              .accept(MediaType.APPLICATION_JSON)
              .acceptEncoding(CompressInterceptor.GZIP)
              .get();
  if (r.getMediaType() != null) {
    // Append charset
    assert MediaType.APPLICATION_JSON_TYPE.equals(r.getMediaType());
    r.getHeaders().putSingle(HttpHeaders.CONTENT_TYPE,
                 r.getMediaType().withCharset(CHARSET));
  }
  gremlinInputHistogram.update(query.length());
  gremlinOutputHistogram.update(r.getLength());
  return r;
}

代码示例来源:origin: hugegraph/hugegraph

private Response doPostRequest(String location, String auth, String req) {
  Entity<?> body = Entity.entity(req, MediaType.APPLICATION_JSON);
  Response r = this.client.target(location)
              .request()
              .header(HttpHeaders.AUTHORIZATION, auth)
              .accept(MediaType.APPLICATION_JSON)
              .acceptEncoding(CompressInterceptor.GZIP)
              .post(body);
  if (r.getMediaType() != null) {
    // Append charset
    assert MediaType.APPLICATION_JSON_TYPE.equals(r.getMediaType());
    r.getHeaders().putSingle(HttpHeaders.CONTENT_TYPE,
                 r.getMediaType().withCharset(CHARSET));
  }
  gremlinInputHistogram.update(req.length());
  gremlinOutputHistogram.update(r.getLength());
  return r;
}

代码示例来源:origin: org.glassfish.jersey.core/jersey-server

@Override
  public void run() {
    try {
      requestScopeListener.resume(foreignScopeInstance, responder.runtime.injectionManager);
      final Response jaxrsResponse =
          (response instanceof Response) ? (Response) response : Response.ok(response).build();
      if (!responder.runtime.disableLocationHeaderRelativeUriResolution) {
        ServerRuntime.ensureAbsolute(jaxrsResponse.getLocation(), jaxrsResponse.getHeaders(),
            responder.processingContext.request(),
            responder.runtime.rfc7231LocationHeaderRelativeUriResolution);
      }
      responder.process(new ContainerResponse(responder.processingContext.request(), jaxrsResponse));
    } catch (final Throwable t) {
      responder.process(t);
    }
  }
});

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

String s = String.class.cast(response.getHeaders().getFirst("resteasy.buffer.exception.entity"));
if (s == null || Boolean.parseBoolean(s))

代码示例来源:origin: javax/javaee-web-api

/**
 * Check if the underlying response contains the information on when is it
 * possible to {@link HttpHeaders#RETRY_AFTER retry the request}.
 *
 * @return {@code true} in case the retry time is specified in the underlying
 *         response, {@code false} otherwise.
 */
public boolean hasRetryAfter() {
  return getResponse().getHeaders().containsKey(RETRY_AFTER);
}

代码示例来源:origin: apache/cxf

private void assertThatTraceIsPresent(final Response r, final SpanId spanId) {
  assertThat((String)r.getHeaders().getFirst(SPAN_ID_NAME),
    equalTo(Long.toString(spanId.spanId())));
  assertThat((String)r.getHeaders().getFirst(TRACE_ID_NAME),
    equalTo(Long.toString(spanId.traceId())));
  assertThat((String)r.getHeaders().getFirst(SAMPLED_NAME),
    equalTo(Boolean.toString(spanId.sampled())));
  assertThat((String)r.getHeaders().getFirst(PARENT_SPAN_ID_NAME),
    equalTo(Long.toString(spanId.parentId())));
}

代码示例来源:origin: apache/cxf

@Test
public void testThatNewSpanIsCreatedWhenNotProvided() {
  final Response r = createWebClient("/bookstore/books").get();
  assertEquals(Status.OK.getStatusCode(), r.getStatus());
  assertThat(TestSpanReporter.getAllSpans().size(), equalTo(2));
  assertThat(TestSpanReporter.getAllSpans().get(0).name(), equalTo("get books"));
  assertThat(TestSpanReporter.getAllSpans().get(1).name(), equalTo("get /bookstore/books"));
  assertFalse(r.getHeaders().containsKey(SPAN_ID_NAME));
  assertFalse(r.getHeaders().containsKey(TRACE_ID_NAME));
  assertFalse(r.getHeaders().containsKey(SAMPLED_NAME));
  assertFalse(r.getHeaders().containsKey(PARENT_SPAN_ID_NAME));
}

代码示例来源:origin: apache/cxf

@Test
public void testOnewayWebClient2() throws Exception {
  WebClient client = WebClient.create("http://localhost:" + PORT + "/bookstore/oneway");
  Response r = client.post(null);
  assertEquals(202, r.getStatus());
  assertFalse(r.getHeaders().isEmpty());
}

相关文章