javax.ws.rs.container.ContainerRequestContext.hasEntity()方法的使用及代码示例

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

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

ContainerRequestContext.hasEntity介绍

[英]Check if there is a non-empty entity input stream available in the request message. The method returns true if the entity is present, returns false otherwise.
[中]检查请求消息中是否存在可用的非空实体输入流。如果实体存在，则该方法返回true，否则返回false。

代码示例

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

@Override
public void filter(ContainerRequestContext requestContext) throws IOException {
  if (requestContext.hasEntity()) {
    requestContext.setEntityStream(new SequenceInputStream(new ByteArrayInputStream("DYN_MATCH_IN".getBytes()),
        requestContext.getEntityStream()));
  }
}

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

@Override
public void filter(ContainerRequestContext requestContext) throws IOException {
  if (requestContext.hasEntity()) {
    requestContext.setEntityStream(new SequenceInputStream(new ByteArrayInputStream("NAM_MATCH_IN".getBytes()),
        requestContext.getEntityStream()));
  }
}

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

@Override
public void filter(ContainerRequestContext context) throws IOException {
  System.out.println("WebApplicationExceptionFilter.preFilter() enter");
  String path = ((ContainerRequest) context).getRequestUri().getPath();
  if (path.endsWith("request_exception") && context.hasEntity() && ((ContainerRequest) context)
      .readEntity(String.class).equals("Request Exception")) {
    throw new WebApplicationException(Response.Status.OK);
  }
  System.out.println("WebApplicationExceptionFilter.preFilter() exit");
}

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

@Override
public void filter(ContainerRequestContext requestContext) throws IOException {
  if (requestContext.hasEntity()) {
    requestContext.setEntityStream(new SequenceInputStream(new ByteArrayInputStream("PRE_MATCH_IN".getBytes()),
        requestContext.getEntityStream()));
  }
}

代码示例来源：origin: docker-java/docker-java

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = aid.incrementAndGet();
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo()
      .getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity()) {
    context.setEntityStream(logInboundEntity(b, context.getEntityStream()));
  }
  log(b);
}

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

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  if (!logger.isLoggable(level)) {
    return;
  }
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (context.hasEntity() && printEntity(verbosity, context.getMediaType())) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

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

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  if (!logger.isLoggable(level)) {
    return;
  }
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (context.hasEntity() && printEntity(verbosity, context.getMediaType())) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

代码示例来源：origin: yahoo/fili

@Override public boolean hasEntity() { return request.hasEntity(); }
@Override public InputStream getEntityStream() { return request.getEntityStream(); }

代码示例来源：origin: com.yahoo.fili/fili-core

@Override public boolean hasEntity() { return request.hasEntity(); }
@Override public InputStream getEntityStream() { return request.getEntityStream(); }

代码示例来源：origin: dsukhoroslov/bagri

private String getBody(ContainerRequestContext context) {
  if (context.hasEntity() && (POST.equals(context.getMethod()) || PUT.equals(context.getMethod()))) {
    java.util.Scanner s = new java.util.Scanner(context.getEntityStream()).useDelimiter("\\A");
    String result = s.next();
    s.close();
    return result;
  }
  return null;
}

代码示例来源：origin: HuygensING/timbuctoo

@Override
public void filter(final ContainerRequestContext context) throws IOException {
 final Stopwatch stopwatch = Stopwatch.createStarted();
 final UUID id = UUID.randomUUID();
 MDC.put(MDC_ID, id.toString());
 MDC.put(MDC_RELEASE_HASH, releaseHash);
 MDC.put(MDC_PRE_LOG, "true");
 //Log a very minimal message. Mostly to make sure that we notice requests that never log in the response filter
 LOG.info(">     " + context.getMethod() + " " + context.getUriInfo().getRequestUri().toASCIIString());
 MDC.remove(MDC_PRE_LOG);
 context.setProperty(STOPWATCH_PROPERTY, stopwatch);
 if (context.hasEntity()) {
  context.setEntityStream(
   addInboundEntityToMdc(context.getEntityStream(), MessageUtils.getCharset(context.getMediaType()))
  );
 }
}

代码示例来源：origin: com.github.docker-java/docker-java

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = aid.incrementAndGet();
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo()
      .getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity()) {
    context.setEntityStream(logInboundEntity(b, context.getEntityStream()));
  }
  log(b);
}

代码示例来源：origin: hstaudacher/osgi-jax-rs-connector

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity()) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

代码示例来源：origin: com.eclipsesource.jaxrs/jersey-all

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity()) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

代码示例来源：origin: hstaudacher/osgi-jax-rs-connector

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity()) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

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

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  if (!logger.isLoggable(level)) {
    return;
  }
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (context.hasEntity() && printEntity(verbosity, context.getMediaType())) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

代码示例来源：origin: org.glassfish.jersey.bundles/jaxrs-ri

@Override
public void filter(final ContainerRequestContext context) throws IOException {
  if (!logger.isLoggable(level)) {
    return;
  }
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (context.hasEntity() && printEntity(verbosity, context.getMediaType())) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

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

@Override
public void filter(ContainerRequestContext context) throws IOException {
  if (isMethodWithNoContent(context.getMethod())
    || isCheckEmptyStream() && !context.hasEntity()) {
    return;
  }
  JweDecryptionOutput out = decrypt(context.getEntityStream());
  byte[] bytes = out.getContent();
  context.setEntityStream(new ByteArrayInputStream(bytes));
  context.getHeaders().putSingle("Content-Length", Integer.toString(bytes.length));
  String ct = JoseUtils.checkContentType(out.getHeaders().getContentType(), getDefaultMediaType());
  if (ct != null) {
    context.getHeaders().putSingle("Content-Type", ct);
  }
  if (super.isValidateHttpHeaders()) {
    super.validateHttpHeadersIfNeeded(context.getHeaders(), out.getHeaders());
  }
}

代码示例来源：origin: icode/ameba

/**
 * {@inheritDoc}
 */
@Override
public void filter(final ContainerRequestContext context) throws IOException {
  final long id = _id.incrementAndGet();
  context.setProperty(LOGGING_ID_PROPERTY, id);
  final StringBuilder b = new StringBuilder();
  printRequestLine(b, "Server has received a request", id, context.getMethod(), context.getUriInfo().getRequestUri());
  printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getHeaders());
  if (printEntity && context.hasEntity() && isSupportPrintType(context.getMediaType())) {
    context.setEntityStream(
        logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
  }
  log(b);
}

代码示例来源：origin: org.kantega.respiro/respiro-message-collector-plugin

@Override
  public void filter(ContainerRequestContext context) throws IOException {

    JaxRsExchangeMessage msg = new JaxRsExchangeMessage(ExchangeMessage.Type.REQUEST);

    final StringBuilder b = new StringBuilder();

    msg.setMethod(context.getMethod());
    msg.setAddress(context.getUriInfo().getAbsolutePath().toString());
    msg.setHeaders(context.getHeaders());

    if (context.hasEntity()) {
      context.setEntityStream(
       logInboundEntity(b, context.getEntityStream(), MessageUtils.getCharset(context.getMediaType())));
    }

    msg.setPayload(b.toString());
    ExchangeInfo exchangeInfo = Collector.newCollectionContext(msg);
    context.setProperty("collector.msg", exchangeInfo);
  }
}

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

ContainerRequestContext

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    ContainerRequestContext类方法

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