org.eclipse.jetty.server.Request.getHttpFields()方法的使用及代码示例

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

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

Request.getHttpFields介绍

暂无

代码示例

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

  1. private String acceptHeaderValue(Request baseRequest) {
  2.   List<String> qualityCSV = baseRequest.getHttpFields().getQualityCSV(HttpHeader.ACCEPT);
  3.   return qualityCSV.isEmpty() ? MimeTypes.Type.TEXT_HTML.asString() : qualityCSV.get(0);
  4. }

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

  1. private MockResponse request(String target, String acceptHeaderValue) throws Exception {
  2.   Request baseRequest = mock(Request.class);
  3.   HttpFields httpFields = new HttpFields();
  4.   if (acceptHeaderValue != null) {
  5.     httpFields.add("Accept", acceptHeaderValue);
  6.   }
  7.   when(baseRequest.getHttpFields()).thenReturn(httpFields);
  8.   HttpServletRequest servletRequest = mock(HttpServletRequest.class);
  9.   HttpServletResponse servletResponse = mock(HttpServletResponse.class);
  10.   PrintWriter printWriter = mock(PrintWriter.class);
  11.   when(servletResponse.getWriter()).thenReturn(printWriter);
  12.   handler.getHandler().handle(target, baseRequest, servletRequest, servletResponse);
  13.   return new MockResponse(servletResponse, printWriter);
  14. }

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

  1. @Test
  2. public void shouldAddDefaultHeadersForRootContext() throws Exception {
  3.   jetty9Server.configure();
  4.   jetty9Server.startHandlers();
  5.   HttpServletResponse response = mock(HttpServletResponse.class);
  6.   when(response.getWriter()).thenReturn(mock(PrintWriter.class));
  7.   HttpServletRequest request = mock(HttpServletRequest.class);
  8.   Request baseRequest = mock(Request.class);
  9.   when(baseRequest.getDispatcherType()).thenReturn(DispatcherType.REQUEST);
  10.   when(baseRequest.getHttpFields()).thenReturn(mock(HttpFields.class));
  11.   ContextHandler rootPathHandler = getLoadedHandlers().get(GoServerLoadingIndicationHandler.class);
  12.   rootPathHandler.setServer(server);
  13.   rootPathHandler.start();
  14.   rootPathHandler.handle("/something", baseRequest, request, response);
  15.   verify(response).setHeader("X-XSS-Protection", "1; mode=block");
  16.   verify(response).setHeader("X-Content-Type-Options", "nosniff");
  17.   verify(response).setHeader("X-Frame-Options", "SAMEORIGIN");
  18.   verify(response).setHeader("X-UA-Compatible", "chrome=1");
  19. }

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

  1. @Override
  2. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
  3.   throws IOException, ServletException {
  4.   baseRequest.setHandled(true);
  5.   if(method.name().equals(request.getMethod())) {
  6.     if(this.expectedContentType.isEmpty()) {
  7.       Assert.assertNull(request.getHeader("Content-Type"));
  8.     } else {
  9.       assertEquals(this.expectedContentType,request.getHeader("Content-Type"));
  10.     }
  11.     final String body = request.getReader().readLine();
  12.     this.trackedHeaderValue = baseRequest.getHttpFields().get(headerToTrack);
  13.     if(this.expectedContentType.isEmpty()) {
  14.       Assert.assertNull(body);
  15.     } else {
  16.       assertEquals("Hello", body);
  17.     }
  18.   } else {
  19.     response.setStatus(404);
  20.     response.setContentType("text/plain");
  21.     response.setContentLength(0);
  22.   }
  23. }

代码示例来源：origin: jenkinsci/winstone

  1. private String getXForwardedFor(Request request)
  2. {
  3.   // Get the right most XForwarded-For for value.
  4.   // This is the value from the closest proxy and the only one that
  5.   // can be trusted.
  6.   String forwarded_for = null;
  7.   HttpFields httpFields = request.getHttpFields();
  8.   for (HttpField field : httpFields)
  9.     if (_forwardedHeader.equalsIgnoreCase(field.getName()))
  10.       forwarded_for = field.getValue();
  11.   
  12.   if (forwarded_for==null || forwarded_for.isEmpty())
  13.     return null;
  14.   
  15.   int comma = forwarded_for.lastIndexOf(',');
  16.   return (comma>=0)?forwarded_for.substring(comma+1).trim():forwarded_for;
  17. }

代码示例来源：origin: com.teradata.airlift/http-server

  1. @Override
  2.   public Deflater getDeflater(Request request, long content_length)
  3.   {
  4.     // GzipHandler incorrectly skips this check for HTTP/2
  5.     HttpField accept = request.getHttpFields().getField(HttpHeader.ACCEPT_ENCODING);
  6.     if ((accept == null) || !accept.contains("gzip")) {
  7.       return null;
  8.     }
  9.     return super.getDeflater(request, content_length);
  10.   }
  11. }

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server

  1. @Override
  2. public Deflater getDeflater(Request request, long content_length)
  3.   String ua = request.getHttpFields().get(HttpHeader.USER_AGENT);
  4.   if (ua!=null && !isAgentGzipable(ua))
  5.   HttpField accept = request.getHttpFields().getField(HttpHeader.ACCEPT_ENCODING);

代码示例来源：origin: jenkinsci/winstone

  1. private String getForwarded(Request request)
  2. {
  3.   // Get the right most Forwarded for value.
  4.   // This is the value from the closest proxy and the only one that
  5.   // can be trusted.
  6.   RFC7239 rfc7239 = new RFC7239();
  7.   HttpFields httpFields = request.getHttpFields();
  8.   for (HttpField field : httpFields)
  9.     if (_forwardedHeader.equalsIgnoreCase(field.getName()))
  10.       rfc7239.addValue(field.getValue());
  11.   
  12.   if (rfc7239.getFor()!=null)
  13.     return new HostPortHttpField(rfc7239.getFor()).getHost();
  14.   
  15.   return null;
  16. }

代码示例来源：origin: jenkinsci/winstone

  1. throws IOException
  2. List<String> acceptable=baseRequest.getHttpFields().getQualityCSV(HttpHeader.ACCEPT);
  3. if (acceptable.isEmpty() && !baseRequest.getHttpFields().contains(HttpHeader.ACCEPT))

代码示例来源：origin: com.teradata.airlift/http-client

  1. @Override
  2.   public Deflater getDeflater(org.eclipse.jetty.server.Request request, long content_length)
  3.   {
  4.     // GzipHandler incorrectly skips this check for HTTP/2
  5.     HttpField accept = request.getHttpFields().getField(HttpHeader.ACCEPT_ENCODING);
  6.     if ((accept == null) || !accept.contains("gzip")) {
  7.       return null;
  8.     }
  9.     return super.getDeflater(request, content_length);
  10.   }
  11. }

代码示例来源：origin: jenkinsci/winstone

  1. @Override
  2. public Deflater getDeflater(Request request, long content_length)
  3. {
  4.   String ua = request.getHttpFields().get(HttpHeader.USER_AGENT);
  5.   if (ua!=null && !isAgentGzipable(ua))
  6.   {
  7.     LOG.debug("{} excluded user agent {}",this,request);
  8.     return null;
  9.   }
  10.   
  11.   if (content_length>=0 && content_length<_minGzipSize)
  12.   {
  13.     LOG.debug("{} excluded minGzipSize {}",this,request);
  14.     return null;
  15.   }
  16.   // check the accept encoding header
  17.   HttpField accept = request.getHttpFields().getField(HttpHeader.ACCEPT_ENCODING);
  18.   if (accept==null)
  19.   {
  20.     LOG.debug("{} excluded !accept {}",this,request);
  21.     return null;
  22.   }
  23.   boolean gzip = accept.contains("gzip");
  24.   if (!gzip)
  25.   {
  26.     LOG.debug("{} excluded not gzip accept {}",this,request);
  27.     return null;
  28.   }
  29.   return _deflaterPool.acquire();
  30. }

代码示例来源：origin: org.apache.camel/camel-jetty9

  1. jettyRequest.getHttpFields().remove(Exchange.CONTENT_ENCODING);

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server

  1. public void handle(HttpChannel connection) throws IOException, ServletException
  2. {
  3.   final String target=connection.getRequest().getPathInfo();
  4.   final Request request=connection.getRequest();
  5.   final Response response=connection.getResponse();
  6.   if (LOG.isDebugEnabled())
  7.     LOG.debug("{} on {}{}{} {} {}{}{}", request.getDispatcherType(), connection, System.lineSeparator(),
  8.         request.getMethod(), target, request.getProtocol(), System.lineSeparator(), request.getHttpFields());
  9.   if (HttpMethod.OPTIONS.is(request.getMethod()) || "*".equals(target))
  10.   {
  11.     if (!HttpMethod.OPTIONS.is(request.getMethod()))
  12.       response.sendError(HttpStatus.BAD_REQUEST_400);
  13.     handleOptions(request,response);
  14.     if (!request.isHandled())
  15.       handle(target, request, request, response);
  16.   }
  17.   else
  18.     handle(target, request, request, response);
  19.   if (LOG.isDebugEnabled())
  20.     LOG.debug("RESPONSE for {} h={}{}{} {}{}{}", target, request.isHandled(), System.lineSeparator(),
  21.         response.getStatus(), response.getReason(), System.lineSeparator(), response.getHttpFields());
  22. }

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

  1. _fields.clear();
  2. String connection = _channel.getRequest().getHttpFields().getStringField(HttpHeader.CONNECTION);
  3. if (connection != null)

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

  1. _fields.clear();
  2. String connection = _channel.getRequest().getHttpFields().getStringField(HttpHeader.CONNECTION);
  3. if (connection != null)

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

  1. persistent = getRequest().getHttpFields().contains(HttpHeader.CONNECTION, HttpHeaderValue.KEEP_ALIVE.asString());
  2. if (!persistent)
  3.   persistent = HttpMethod.CONNECT.is(getRequest().getMethod());
  4. persistent = !getRequest().getHttpFields().contains(HttpHeader.CONNECTION, HttpHeaderValue.CLOSE.asString());
  5. if (!persistent)
  6.   persistent = HttpMethod.CONNECT.is(getRequest().getMethod());

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

  1. persistent = getRequest().getHttpFields().contains(HttpHeader.CONNECTION, HttpHeaderValue.KEEP_ALIVE.asString());
  2. if (!persistent)
  3.   persistent = HttpMethod.CONNECT.is(getRequest().getMethod());
  4. persistent = !getRequest().getHttpFields().contains(HttpHeader.CONNECTION, HttpHeaderValue.CLOSE.asString());
  5. if (!persistent)
  6.   persistent = HttpMethod.CONNECT.is(getRequest().getMethod());

代码示例来源：origin: Nextdoor/bender

  1. _fields.clear();
  2. String connection = _channel.getRequest().getHttpFields().getStringField(HttpHeader.CONNECTION);
  3. if (connection != null)

代码示例来源：origin: jenkinsci/winstone

  1. private void extractContentParameters()
  2.   if (_metaData!=null && getHttpFields().contains(HttpHeader.CONTENT_ENCODING))
  3.     throw new BadMessageException(HttpStatus.NOT_IMPLEMENTED_501,"Unsupported Content-Encoding");

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server

  1. /**
  2.  * <p>Pushes a secondary resource identified by this dispatcher.</p>
  3.  *
  4.  * @param request the primary request
  5.  * @deprecated Use {@link Request#getPushBuilder()} instead
  6.  */
  7. @Deprecated
  8. public void push(ServletRequest request)
  9. {
  10.   Request baseRequest = Request.getBaseRequest(request);
  11.   HttpFields fields = new HttpFields(baseRequest.getHttpFields());
  12.   String query=baseRequest.getQueryString();
  13.   if (_uri.hasQuery())
  14.   {
  15.     if (query==null)
  16.       query=_uri.getQuery();
  17.     else
  18.       query=query+"&"+_uri.getQuery(); // TODO is this correct semantic?
  19.   }
  20.   HttpURI uri = HttpURI.createHttpURI(request.getScheme(),request.getServerName(),request.getServerPort(),_uri.getPath(),baseRequest.getHttpURI().getParam(),query,null);
  21.   MetaData.Request push = new MetaData.Request(HttpMethod.GET.asString(),uri,baseRequest.getHttpVersion(),fields);
  22.   baseRequest.getHttpChannel().getHttpTransport().push(push);
  23. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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