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

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

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

Request.getHttpChannel介绍

暂无

代码示例

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

  1. @Override
  2. public void handle(String target,
  3. Request baseRequest,
  4. HttpServletRequest request,
  5. HttpServletResponse response) throws IOException, ServletException {
  6. final Connector connector = baseRequest.getHttpChannel().getConnector();
  7. for (Entry entry : entries) {
  8. // reference equality works fine — none of the connectors implement #equals(Object)
  9. if (entry.connector == connector) {
  10. entry.handler.handle(target, baseRequest, request, response);
  11. return;
  12. }
  13. }
  14. }
  15. }

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

  1. @Override
  2. public void handle( String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response ) throws IOException, ServletException
  3. {
  4. HttpChannel httpChannel = baseRequest.getHttpChannel();
  5. if ( httpChannel != null ) // if the channel is not null, all good, you handle yourself.
  6. {
  7. super.handle( target, baseRequest, request, response );
  8. }
  9. else // if we do not have a real channel, then we just log ourselves
  10. {
  11. try
  12. {
  13. if ( _handler != null )
  14. {
  15. _handler.handle( target, baseRequest, request, response );
  16. }
  17. }
  18. finally
  19. {
  20. RequestLog requestLog = getRequestLog();
  21. if ( requestLog != null && baseRequest.getDispatcherType() == DispatcherType.REQUEST )
  22. {
  23. requestLog.log( baseRequest, (Response) response );
  24. }
  25. }
  26. }
  27. }
  28. }

代码示例来源:origin: org.eclipse.jetty/jetty-security

  1. return true;
  2. HttpConfiguration httpConfig = Request.getBaseRequest(request).getHttpChannel().getHttpConfiguration();

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

  1. public boolean isPushSupported()
  2. {
  3. return getHttpChannel().getHttpTransport().isPushSupported();
  4. }

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

  1. protected String getRemoteIP(Request baseRequest)
  2. {
  3. // Do we have a forwarded header set?
  4. if (_forwardedHeader!=null && !_forwardedHeader.isEmpty())
  5. {
  6. // Yes, then try to get the remote IP from the header
  7. String remote = _rfc7239?getForwarded(baseRequest):getXForwardedFor(baseRequest);
  8. if (remote!=null && !remote.isEmpty())
  9. return remote;
  10. }
  11. // If no remote IP from a header, determine it directly from the channel
  12. // Do not use the request methods, as they may have been lied to by the
  13. // RequestCustomizer!
  14. InetSocketAddress inet_addr = baseRequest.getHttpChannel().getRemoteAddress();
  15. if (inet_addr!=null && inet_addr.getAddress()!=null)
  16. return inet_addr.getAddress().getHostAddress();
  17. return null;
  18. }

代码示例来源:origin: io.dropwizard/dropwizard-jetty

  1. @Override
  2. public void handle(String target,
  3. Request baseRequest,
  4. HttpServletRequest request,
  5. HttpServletResponse response) throws IOException, ServletException {
  6. final Connector connector = baseRequest.getHttpChannel().getConnector();
  7. for (Entry entry : entries) {
  8. // reference equality works fine — none of the connectors implement #equals(Object)
  9. if (entry.connector == connector) {
  10. entry.handler.handle(target, baseRequest, request, response);
  11. return;
  12. }
  13. }
  14. }
  15. }

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

  1. @Override
  2. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
  3. throws IOException, ServletException
  4. {
  5. if (baseRequest.getDispatcherType()==DispatcherType.REQUEST)
  6. baseRequest.getHttpChannel().addRequestLog(_requestLog);
  7. if (_handler!=null)
  8. _handler.handle(target,baseRequest, request, response);
  9. }

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

  1. @Override
  2. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
  3. throws IOException, ServletException
  4. {
  5. if (baseRequest.getDispatcherType()==DispatcherType.REQUEST)
  6. baseRequest.getHttpChannel().addRequestLog(_requestLog);
  7. if (_handler!=null)
  8. _handler.handle(target,baseRequest, request, response);
  9. }

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

  1. public boolean isPushSupported()
  2. {
  3. return !isPush() && getHttpChannel().getHttpTransport().isPushSupported();
  4. }

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

  1. protected void writeErrorPageBody(HttpServletRequest request, Writer writer, int code, String message, boolean showStacks)
  2. throws IOException
  3. {
  4. String uri= request.getRequestURI();
  5. writeErrorPageMessage(request,writer,code,message,uri);
  6. if (showStacks)
  7. writeErrorPageStacks(request,writer);
  8. Request.getBaseRequest(request).getHttpChannel().getHttpConfiguration()
  9. .writePoweredBy(writer,"<hr>","<hr/>\n");
  10. }

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

  1. protected void writeErrorPageBody(HttpServletRequest request, Writer writer, int code, String message, boolean showStacks)
  2. throws IOException
  3. {
  4. String uri= request.getRequestURI();
  5. writeErrorPageMessage(request,writer,code,message,uri);
  6. if (showStacks)
  7. writeErrorPageStacks(request,writer);
  8. Request.getBaseRequest(request).getHttpChannel().getHttpConfiguration()
  9. .writePoweredBy(writer,"<hr>","<hr/>\n");
  10. }

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

  1. @Override
  2. protected void closeConnection(HttpServletRequest request, HttpServletResponse response, Thread thread)
  3. {
  4. Request base_request=(request instanceof Request)?(Request)request:HttpChannel.getCurrentHttpChannel().getRequest();
  5. base_request.getHttpChannel().getEndPoint().close();
  6. }
  7. }

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

  1. @Override
  2. protected void closeConnection(HttpServletRequest request, HttpServletResponse response, Thread thread)
  3. {
  4. Request base_request=(request instanceof Request)?(Request)request:HttpChannel.getCurrentHttpChannel().getRequest();
  5. base_request.getHttpChannel().getEndPoint().close();
  6. }
  7. }

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

  1. @Override
  2. public void customize(Connector connector, HttpConfiguration channelConfig, Request request)
  3. {
  4. if (request.getHttpChannel().getEndPoint() instanceof DecryptedEndPoint)
  5. {
  6. request.setScheme(HttpScheme.HTTPS.asString());
  7. request.setSecure(true);
  8. SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)request.getHttpChannel().getEndPoint();
  9. SslConnection sslConnection = ssl_endp.getSslConnection();
  10. SSLEngine sslEngine=sslConnection.getSSLEngine();
  11. customize(sslEngine,request);
  12. }
  13. }

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

  1. /**
  2. * @param cookies
  3. * The cookies to set.
  4. */
  5. public void setCookies(Cookie[] cookies)
  6. {
  7. if (_cookies == null)
  8. _cookies = new CookieCutter(getHttpChannel().getHttpConfiguration().getCookieCompliance());
  9. _cookies.setCookies(cookies);
  10. }

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

  1. @Override
  2. public void customize(Connector connector, HttpConfiguration channelConfig, Request request)
  3. {
  4. if (request.getHttpChannel().getEndPoint() instanceof DecryptedEndPoint)
  5. {
  6. request.setScheme(HttpScheme.HTTPS.asString());
  7. request.setSecure(true);
  8. SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)request.getHttpChannel().getEndPoint();
  9. SslConnection sslConnection = ssl_endp.getSslConnection();
  10. SSLEngine sslEngine=sslConnection.getSSLEngine();
  11. customize(sslEngine,request);
  12. }
  13. }

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

  1. @Override
  2. public void customize(Connector connector, HttpConfiguration channelConfig, Request request)
  3. {
  4. if (request.getHttpChannel().getEndPoint() instanceof DecryptedEndPoint)
  5. {
  6. request.setScheme(HttpScheme.HTTPS.asString());
  7. request.setSecure(true);
  8. SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)request.getHttpChannel().getEndPoint();
  9. SslConnection sslConnection = ssl_endp.getSslConnection();
  10. SSLEngine sslEngine=sslConnection.getSSLEngine();
  11. customize(sslEngine,request);
  12. }
  13. }

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

  1. @Override
  2. public void customize(Connector connector, HttpConfiguration channelConfig, Request request)
  3. {
  4. if (request.getHttpChannel().getEndPoint() instanceof DecryptedEndPoint)
  5. {
  6. if (request.getHttpURI().getScheme()==null)
  7. request.setScheme(HttpScheme.HTTPS.asString());
  8. SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)request.getHttpChannel().getEndPoint();
  9. SslConnection sslConnection = ssl_endp.getSslConnection();
  10. SSLEngine sslEngine=sslConnection.getSSLEngine();
  11. customize(sslEngine,request);
  12. }
  13. if (HttpScheme.HTTPS.is(request.getScheme()))
  14. customizeSecure(request);
  15. }

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

  1. private MultiParts newMultiParts(ServletInputStream inputStream, String contentType, MultipartConfigElement config, Object object) throws IOException
  2. {
  3. MultiPartFormDataCompliance compliance = getHttpChannel().getHttpConfiguration().getMultipartFormDataCompliance();
  4. if(LOG.isDebugEnabled())
  5. LOG.debug("newMultiParts {} {}",compliance, this);
  6. switch(compliance)
  7. {
  8. case RFC7578:
  9. return new MultiParts.MultiPartsHttpParser(getInputStream(), getContentType(), config,
  10. (_context != null?(File)_context.getAttribute("javax.servlet.context.tempdir"):null), this);
  11. case LEGACY:
  12. default:
  13. return new MultiParts.MultiPartsUtilParser(getInputStream(), getContentType(), config,
  14. (_context != null?(File)_context.getAttribute("javax.servlet.context.tempdir"):null), this);
  15. }
  16. }

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

  1. @Override
  2. public void customize(Connector connector, HttpConfiguration channelConfig, Request request)
  3. {
  4. EndPoint endp = request.getHttpChannel().getEndPoint();
  5. if (endp instanceof DecryptedEndPoint)
  6. {
  7. SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)endp;
  8. SslConnection sslConnection = ssl_endp.getSslConnection();
  9. SSLEngine sslEngine=sslConnection.getSSLEngine();
  10. customize(sslEngine,request);
  11. if (request.getHttpURI().getScheme()==null)
  12. request.setScheme(HttpScheme.HTTPS.asString());
  13. }
  14. else if (endp instanceof ProxyConnectionFactory.ProxyEndPoint)
  15. {
  16. ProxyConnectionFactory.ProxyEndPoint proxy = (ProxyConnectionFactory.ProxyEndPoint)endp;
  17. if (request.getHttpURI().getScheme()==null && proxy.getAttribute(ProxyConnectionFactory.TLS_VERSION)!=null)
  18. request.setScheme(HttpScheme.HTTPS.asString());
  19. }
  20. if (HttpScheme.HTTPS.is(request.getScheme()))
  21. customizeSecure(request);
  22. }

相关文章

Request类方法