javax.ws.rs.container.ContainerResponseContext类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(13.4k)|赞(0)|评价(0)|浏览(203)

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

ContainerResponseContext介绍

[英]Container response filter context. A mutable class that provides response-specific information for the filter, such as message headers, message entity or request-scoped properties. The exposed setters allow modification of the exposed response-specific information.
[中]容器响应筛选器上下文。为筛选器提供响应特定信息的可变类，例如消息头、消息实体或请求范围属性。公开的setter允许修改公开的响应特定信息。

代码示例

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

@Override
public void filter(ContainerRequestContext request, ContainerResponseContext response) throws IOException {
  if (!response.hasEntity()) {
    return;
  List<String> varyHeader = response.getStringHeaders().get(HttpHeaders.VARY);
  if (varyHeader == null || !varyHeader.contains(HttpHeaders.ACCEPT_ENCODING)) {
    response.getHeaders().add(HttpHeaders.VARY, HttpHeaders.ACCEPT_ENCODING);
  if (response.getHeaders().getFirst(HttpHeaders.CONTENT_ENCODING) != null) {
    return;
  List<String> acceptEncoding = request.getHeaders().get(HttpHeaders.ACCEPT_ENCODING);
    response.getHeaders().putSingle(HttpHeaders.CONTENT_ENCODING, contentEncoding);

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
  // we have already added the necessary headers for OPTIONS requests below
  if ("options".equalsIgnoreCase(requestContext.getRequest().getMethod())) {
    if(Response.Status.Family.familyOf(responseContext.getStatus()) == Response.Status.Family.SUCCESSFUL) {
      return;
    }
    responseContext.setStatus(Response.Status.NO_CONTENT.getStatusCode());
    responseContext.setEntity("");
  }
  String origin = requestContext.getHeaders().getFirst("Origin");
  if (origin != null && !origin.isEmpty()) {
    responseContext.getHeaders().add("Access-Control-Allow-Origin", origin);
    responseContext.getHeaders().add("Access-Control-Allow-Credentials", true);
    responseContext.getHeaders().add("Access-Control-Allow-Headers", "Authorization, Content-Type, X-Graylog-No-Session-Extension, X-Requested-With, X-Requested-By");
    responseContext.getHeaders().add("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS");
    // In order to avoid redoing the preflight thingy for every request, see http://stackoverflow.com/a/12021982/1088469
    responseContext.getHeaders().add("Access-Control-Max-Age", "600"); // 10 minutes seems to be the maximum allowable value
  }
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    if (responseContext.hasEntity()) {
      Exception e = (Exception) responseContext.getEntity();
      if (exceptionClass.isAssignableFrom(e.getClass()) ||
          (e.getCause() != null && exceptionClass.isAssignableFrom(e.getCause().getClass()))) {
        meter.mark();
      }
      responseContext.setEntity(null);
      responseContext.getHeaders().add("X-Exceptions-Thrown", e.toString() + " : " + meter.getCount());
    }
  }
}

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

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    if (responseContext.hasEntity()) {
      responseContext.setEntity("" + responseContext.getEntity() + "PRE_MATCH_OUT", null, MediaType.TEXT_PLAIN_TYPE);
    }
  }
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    if (responseContext.getStatusInfo().equals(Response.Status.UNAUTHORIZED)) {
      final String requestedWith = requestContext.getHeaderString(HttpHeaders.X_REQUESTED_WITH);
      if ("XMLHttpRequest".equalsIgnoreCase(requestedWith)) {
        responseContext.getHeaders().remove(HttpHeaders.WWW_AUTHENTICATE);

      }
    }
  }
}

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

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    System.out.println("WebApplicationExceptionFilter.postFilter() enter");
    if (responseContext.hasEntity() && responseContext.getEntity().equals("Response Exception")) {
      throw new WebApplicationException(Response.Status.OK);
    }
    System.out.println("WebApplicationExceptionFilter.postFilter() exit");
  }
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    // Add no-cache to XMLHttpRequests, to avoid browsers caching results
    String requestedWith = requestContext.getHeaders().getFirst("X-Requested-With");
    if ("XMLHttpRequest".equals(requestedWith)) {
      responseContext.getHeaders().add("Cache-Control", "no-cache");
    }
  }
}

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

@Override
public void filter(final ContainerRequestContext request,
    final ContainerResponseContext response) throws IOException {
  String id = request.getHeaderString(REQUEST_ID);
  if (Strings.isNullOrEmpty(id)) {
    id = generateRandomUuid().toString();
  }
  logger.trace("method={} path={} request_id={} status={} length={}",
      request.getMethod(), request.getUriInfo().getPath(), id,
      response.getStatus(), response.getLength());
  response.getHeaders().putSingle(REQUEST_ID, id);
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    final Response.StatusType responseStatus = responseContext.getStatusInfo();
    final String requestPath = requestContext.getUriInfo().getAbsolutePath().getPath();
    final List<MediaType> acceptableMediaTypes = requestContext.getAcceptableMediaTypes();
    final boolean acceptsHtml = acceptableMediaTypes.stream()
        .anyMatch(mediaType -> mediaType.isCompatible(MediaType.TEXT_HTML_TYPE) || mediaType.isCompatible(MediaType.APPLICATION_XHTML_XML_TYPE));
    final boolean isGetRequest = "get".equalsIgnoreCase(requestContext.getMethod());

    if (isGetRequest
        && responseStatus == Response.Status.NOT_FOUND
        && acceptsHtml
        && !requestPath.startsWith("/" + HttpConfiguration.PATH_API)) {
      final String entity = indexHtmlGenerator.get(requestContext.getHeaders());
      responseContext.setStatusInfo(Response.Status.OK);
      responseContext.setEntity(entity, new Annotation[0], MediaType.TEXT_HTML_TYPE);

      responseContext.getHeaders().putSingle("X-UA-Compatible", "IE=edge");
    }
  }
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    final Timer.Context context = (Timer.Context) requestContext.getProperty("metricsTimerContext");
    if (context == null) return;
    final long elapsedNanos = context.stop();
    responseContext.getHeaders().add("X-Runtime-Microseconds", TimeUnit.NANOSECONDS.toMicros(elapsedNanos));
  }
}

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

@Override
public void filter(ContainerRequestContext requestContext,
          ContainerResponseContext responseContext) throws IOException {
  if (!cacheResponseHeader.isEmpty()) {
    responseContext.getHeaders().add(HttpHeaders.CACHE_CONTROL, cacheResponseHeader);
  }
}

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

@Override
  public void filter(final ContainerRequestContext requestContext, final ContainerResponseContext responseContext)
      throws IOException {
    if (!logger.isLoggable(level)) {
      return;
    }
    final Object requestId = requestContext.getProperty(LOGGING_ID_PROPERTY);
    final long id = requestId != null ? (Long) requestId : _id.incrementAndGet();

    final StringBuilder b = new StringBuilder();

    printResponseLine(b, "Server responded with a response", id, responseContext.getStatus());
    printPrefixedHeaders(b, id, RESPONSE_PREFIX, responseContext.getStringHeaders());

    if (responseContext.hasEntity() && printEntity(verbosity, responseContext.getMediaType())) {
      final OutputStream stream = new LoggingStream(b, responseContext.getEntityStream());
      responseContext.setEntityStream(stream);
      requestContext.setProperty(ENTITY_LOGGER_PROPERTY, stream);
      // not calling log(b) here - it will be called by the interceptor
    } else {
      log(b);
    }
  }
}

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

@Override
public void filter(ContainerRequestContext request, ContainerResponseContext response) throws IOException {
  if (!response.getHeaders().containsKey(HttpHeaderNames.ACCESS_CONTROL_ALLOW_HEADERS.toString())) {
    response.getHeaders().add(HttpHeaderNames.ACCESS_CONTROL_ALLOW_HEADERS.toString(), HEADERS_ALL);
  }
  if (!response.getHeaders().containsKey(HttpHeaderNames.ACCESS_CONTROL_ALLOW_CREDENTIALS.toString())) {
    response.getHeaders().add(HttpHeaderNames.ACCESS_CONTROL_ALLOW_CREDENTIALS.toString(), true);
  }
  if (!response.getHeaders().containsKey(HttpHeaderNames.ACCESS_CONTROL_ALLOW_METHODS.toString())) {
    response.getHeaders().add(HttpHeaderNames.ACCESS_CONTROL_ALLOW_METHODS.toString(), METHODS_ALL);
  }
  if (!response.getHeaders().containsKey(HttpHeaderNames.ACCESS_CONTROL_ALLOW_ORIGIN.toString())) {
    String origin = request.getHeaderString(HttpHeaderNames.ORIGIN.toString());
    String allowed = Context.getConfig().getString("web.origin");
    if (origin == null) {
      response.getHeaders().add(HttpHeaderNames.ACCESS_CONTROL_ALLOW_ORIGIN.toString(), ORIGIN_ALL);
    } else if (allowed == null || allowed.equals(ORIGIN_ALL) || allowed.contains(origin)) {
      response.getHeaders().add(HttpHeaderNames.ACCESS_CONTROL_ALLOW_ORIGIN.toString(), origin);
    }
  }
}

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

@Override
  public void filter(final ContainerRequestContext requestContext, final ContainerResponseContext responseContext)
      throws IOException {

    if (HttpMethod.OPTIONS.equals(requestContext.getMethod())) {
      final MultivaluedMap<String, Object> headers = responseContext.getHeaders();
      if (!headers.containsKey(ACCEPT_PATCH_HEADER)) {
        headers.putSingle(ACCEPT_PATCH_HEADER, MediaType.APPLICATION_JSON_PATCH_JSON);
      }
    }
  }
}

代码示例来源：origin: opentripplanner/OpenTripPlanner

/**
 * CORS response filter. Allow requests from anywhere.
 * Just echo back the contents of the Origin header.
 * Allow credentials if the transport layer is secure.
 */
@Override
public void filter(ContainerRequestContext request, ContainerResponseContext response) throws IOException {
  String origin = request.getHeaderString("Origin"); // case insensitive
  MultivaluedMap<String, Object> headers = response.getHeaders();
  headers.add("Access-Control-Allow-Origin", origin);
  boolean secureTransport = request.getSecurityContext().isSecure();
  headers.add("Access-Control-Allow-Credentials", secureTransport);
}

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

@Override
public void filter(ContainerRequestContext requestContext,
          ContainerResponseContext responseContext) throws IOException {
 ResteasyDeployment deployment = ResteasyContext.getContextData(ResteasyDeployment.class);
 if (deployment != null)
 {
   Boolean disable = (Boolean) deployment.getProperty(ResteasyContextParameters.RESTEASY_DISABLE_HTML_SANITIZER);
   if (disable != null && disable)
   {
    return;
   }
 }
 if (HttpResponseCodes.SC_BAD_REQUEST == responseContext.getStatus()) {
   Object entity = responseContext.getEntity();
   if (entity != null && entity instanceof String) {
    ArrayList<Object> contentTypes = (ArrayList<Object>)responseContext.getHeaders().get("Content-Type");
    if (contentTypes != null  && containsHtmlText(contentTypes)) {
      String escapedMsg = escapeXml((String) entity);
      responseContext.setEntity(escapedMsg);
    }
   }
 }
}

代码示例来源：origin: org.apache.rave/rave-core-api

@Override
  public void filter(ContainerRequestContext containerRequestContext, ContainerResponseContext containerResponseContext) throws IOException {
    String method = containerRequestContext.getRequest().getMethod();

    if (method.equals("POST") && containerResponseContext.getStatus() == Response.Status.OK.getStatusCode()) {
      containerResponseContext.setStatus(Response.Status.CREATED.getStatusCode());
      RestEntity entity = (RestEntity) containerResponseContext.getEntity();
      String id = entity.getId();
      containerResponseContext.getHeaders().add("Location",
          containerRequestContext.getUriInfo().getAbsolutePathBuilder().path(id).build().toString());
    }

    //containerResponseContext.getHeaders().put("Location")
  }
}

代码示例来源：origin: grro/stability

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    String clientId = requestContext.getHeaderString("X-Client");
    if (flowController.isTooManyRequests(clientId)) {
      responseContext.getHeaders().add("X-FlowControl", "slowdown");
    }
        Transaction.close(requestContext.getProperty(TRANSACTION), responseContext.getStatus() >= 500);
  }
}

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

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException
  {
   if (responseContext.getStatus() == 200)
   {
     responseContext.getHeaders().putSingle(HttpHeaders.CACHE_CONTROL, cacheControl);
   }
  }
}

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

@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException
{
 String origin = requestContext.getHeaderString(CorsHeaders.ORIGIN);
 if (origin == null || requestContext.getMethod().equalsIgnoreCase("OPTIONS") || requestContext.getProperty("cors.failure") != null)
 {
   // don't do anything if origin is null, its an OPTIONS request, or cors.failure is set
   return;
 }
 responseContext.getHeaders().putSingle(CorsHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, origin);
 responseContext.getHeaders().putSingle(CorsHeaders.VARY, CorsHeaders.ORIGIN);
 if (allowCredentials) responseContext.getHeaders().putSingle(CorsHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");
 if (exposedHeaders != null) {
   responseContext.getHeaders().putSingle(CorsHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, exposedHeaders);
 }
}

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

ContainerResponseContext

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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