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

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

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

Request.setScheme介绍

暂无

代码示例

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

  1. @Override
  2. public void customize( Connector connector, HttpConfiguration channelConfig, Request request )
  3. {
  4.   request.setScheme( HttpScheme.HTTPS.asString() );
  5.   addResponseFieldIfConfigured( request, hstsResponseField );
  6. }

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

  1. @Test
  2. public void shouldSetRequestSchemeToHttps()
  3. {
  4.   Customizer customizer = newCustomizer();
  5.   Request request = mock( Request.class );
  6.   customize( customizer, request );
  7.   verify( request ).setScheme( HTTPS.asString() );
  8. }

代码示例来源：origin: OAuth-Apis/apis

  1. @Override
  2. public void customize(EndPoint endpoint, Request request) throws IOException {
  3.   String forwardedProtocol = getHeaderCaseInsensitive(request, X_FORWARDED_PROTO);
  4.   if (forwardedProtocol != null) {
  5.     if (forwardedProtocol.indexOf("https") >= 0) {
  6.       request.setScheme("https");
  7.     }
  8.   }
  9.   super.customize(endpoint, request);
  10. }

代码示例来源：origin: org.eclipse.jetty.aggregate/jetty-all-server

  1. protected String apply(String target, String value, HttpServletRequest request, HttpServletResponse response) 
  2.   {
  3.     ((Request) request).setScheme(_scheme);
  4.     return target;
  5.   }    
  6. }

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

  1. @Override
  2.   protected String apply(String target, String value, HttpServletRequest request, HttpServletResponse response) 
  3.   {
  4.     ((Request) request).setScheme(_scheme);
  5.     return target;
  6.   }    
  7. }

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

  1. @Override
  2.   protected String apply(String target, String value, HttpServletRequest request, HttpServletResponse response) 
  3.   {
  4.     ((Request) request).setScheme(_scheme);
  5.     return target;
  6.   }    
  7. }

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

  1. @Override
  2.   protected String apply(String target, String value, HttpServletRequest request, HttpServletResponse response) 
  3.   {
  4.     ((Request) request).setScheme(_scheme);
  5.     return target;
  6.   }    
  7. }

代码示例来源：origin: org.simplericity.jettyconsole/jetty-console-core

  1. @Override
  2.   public void customize(Connector connector, HttpConfiguration channelConfig, Request request) {
  3.     request.setScheme(URIUtil.HTTPS);
  4.     request.setSecure(true);
  5.   }
  6. });

代码示例来源：origin: org.neo4j.app/neo4j-server

  1. @Override
  2. public void customize( Connector connector, HttpConfiguration channelConfig, Request request )
  3. {
  4.   request.setScheme( HttpScheme.HTTPS.asString() );
  5.   addResponseFieldIfConfigured( request, hstsResponseField );
  6. }

代码示例来源：origin: org.eclipse.jetty.aggregate/jetty-all-server

  1. @Override
  2. public void customize(EndPoint endpoint, Request request) throws IOException
  3. {
  4.   super.customize(endpoint,request);
  5.   if (request.isSecure())
  6.     request.setScheme(HttpSchemes.HTTPS);
  7. }

代码示例来源：origin: org.eclipse.jetty.spdy/spdy-jetty-http

  1. @Override
  2. public void customize(EndPoint endPoint, Request request) throws IOException
  3. {
  4.   super.customize(endPoint, request);
  5.   if (getSslContextFactory() != null)
  6.     request.setScheme(HttpSchemes.HTTPS);
  7. }

代码示例来源：origin: works.lmz.common/common-runnable-war

  1. public static void rewriteProxyRequest(Request request) {
  2.  String client = request.getHeader(CLIENT_HEADER);
  3.  if (client != null && client.length() > 0) {
  4.   InetSocketAddress realClient = new InetSocketAddress(client, 80);
  5.   request.setRemoteAddr(realClient);
  6.  }
  7.  String scheme = request.getHeader(SCHEME_HEADER);
  8.  if (scheme == null || scheme.equals("")) {
  9.   scheme = HTTP_SCHEME;
  10.  }
  11.  request.setScheme(scheme);
  12.  String hostAndPort = request.getHeader(HOST_HEADER);
  13.  if (hostAndPort != null) {
  14.   int ofs = hostAndPort.indexOf(':');
  15.   if (ofs >= 0) {
  16.    request.setServerName(hostAndPort.substring(0, ofs));
  17.    request.setServerPort(Integer.parseInt(hostAndPort.substring(ofs + 1)));
  18.   } else {
  19.    request.setServerName(hostAndPort);
  20.    request.setServerPort(HTTPS_SCHEME.equalsIgnoreCase(scheme) ? HTTPS_PORT : HTTP_PORT);
  21.   }
  22.  }
  23. }

代码示例来源：origin: org.eclipse.jetty.aggregate/jetty-all-server

  1. /**
  2.  * Allow the Listener a chance to customise the request. before the server does its stuff. <br>
  3.  * This allows the required attributes to be set for SSL requests. <br>
  4.  * The requirements of the Servlet specs are:
  5.  * <ul>
  6.  * <li> an attribute named "javax.servlet.request.ssl_id" of type String (since Spec 3.0).</li>
  7.  * <li> an attribute named "javax.servlet.request.cipher_suite" of type String.</li>
  8.  * <li> an attribute named "javax.servlet.request.key_size" of type Integer.</li>
  9.  * <li> an attribute named "javax.servlet.request.X509Certificate" of type
  10.  * java.security.cert.X509Certificate[]. This is an array of objects of type X509Certificate,
  11.  * the order of this array is defined as being in ascending order of trust. The first
  12.  * certificate in the chain is the one set by the client, the next is the one used to
  13.  * authenticate the first, and so on. </li>
  14.  * </ul>
  15.  *
  16.  * @param endpoint The Socket the request arrived on.
  17.  *        This should be a {@link SocketEndPoint} wrapping a {@link SSLSocket}.
  18.  * @param request HttpRequest to be customised.
  19.  */
  20. @Override
  21. public void customize(EndPoint endpoint, Request request)
  22.   throws IOException
  23. {
  24.   super.customize(endpoint, request);
  25.   request.setScheme(HttpSchemes.HTTPS);
  26.   SocketEndPoint socket_end_point = (SocketEndPoint)endpoint;
  27.   SSLSocket sslSocket = (SSLSocket)socket_end_point.getTransport();
  28.   SSLSession sslSession = sslSocket.getSession();
  29.   SslCertificates.customize(sslSession,endpoint,request);
  30. }

代码示例来源：origin: org.apache.activemq/activemq-optional

  1. @Override
  2. public void customize(EndPoint endpoint, Request request) throws IOException {
  3.   if (useKrb) { // Add Kerberos-specific info
  4.     SSLSocket sslSocket = (SSLSocket) endpoint.getTransport();
  5.     Principal remotePrincipal = sslSocket.getSession().getPeerPrincipal();
  6.     logIfDebug("Remote principal = " + remotePrincipal);
  7.     request.setScheme(HttpSchemes.HTTPS);
  8.     request.setAttribute(REMOTE_PRINCIPAL, remotePrincipal);
  9.     if (!useCerts) { // Add extra info that would have been added by
  10.              // super
  11.       String cipherSuite = sslSocket.getSession().getCipherSuite();
  12.       Integer keySize = Integer.valueOf(ServletSSL.deduceKeyLength(cipherSuite));
  13.       ;
  14.       request.setAttribute("javax.servlet.request.cipher_suite", cipherSuite);
  15.       request.setAttribute("javax.servlet.request.key_size", keySize);
  16.     }
  17.   }
  18.   if (useCerts)
  19.     super.customize(endpoint, request);
  20. }

代码示例来源：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: 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. @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. }

代码示例来源：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.     
  7.     if (request.getHttpURI().getScheme()==null)
  8.       request.setScheme(HttpScheme.HTTPS.asString());
  9.     
  10.     SslConnection.DecryptedEndPoint ssl_endp = (DecryptedEndPoint)request.getHttpChannel().getEndPoint();
  11.     SslConnection sslConnection = ssl_endp.getSslConnection();
  12.     SSLEngine sslEngine=sslConnection.getSSLEngine();
  13.     customize(sslEngine,request);
  14.   }
  15.   if (HttpScheme.HTTPS.is(request.getScheme()))
  16.     customizeSecure(request);
  17. }

代码示例来源：origin: org.eclipse.jetty.spdy/spdy-http-server

  1. private boolean performBeginRequest(Fields headers)
  2. {
  3.   short version = stream.getSession().getVersion();
  4.   Fields.Field methodHeader = headers.get(HTTPSPDYHeader.METHOD.name(version));
  5.   Fields.Field uriHeader = headers.get(HTTPSPDYHeader.URI.name(version));
  6.   Fields.Field versionHeader = headers.get(HTTPSPDYHeader.VERSION.name(version));
  7.   if (methodHeader == null || uriHeader == null || versionHeader == null)
  8.   {
  9.     badMessage(400, "Missing required request line elements");
  10.     return false;
  11.   }
  12.   HttpMethod httpMethod = HttpMethod.fromString(methodHeader.getValue());
  13.   HttpVersion httpVersion = HttpVersion.fromString(versionHeader.getValue());
  14.   // TODO should handle URI as byte buffer as some bad clients send WRONG encodings in query string
  15.   // that  we have to deal with
  16.   ByteBuffer uri = BufferUtil.toBuffer(uriHeader.getValue());
  17.   if (LOG.isDebugEnabled())
  18.     LOG.debug("HTTP > {} {} {}", httpMethod, uriHeader.getValue(), httpVersion);
  19.   startRequest(httpMethod, httpMethod.asString(), uri, httpVersion);
  20.   Fields.Field schemeHeader = headers.get(HTTPSPDYHeader.SCHEME.name(version));
  21.   if (schemeHeader != null)
  22.     getRequest().setScheme(schemeHeader.getValue());
  23.   return true;
  24. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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