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

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

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

Request.getHttpURI介绍

暂无

代码示例

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

  1. @Override
  2. public String getUriPath() {
  3. return request.getHttpURI().getPath();
  4. }

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

  1. @Override
  2. public void setRequestURI(String uri) {
  3. request.getHttpURI().setPath(uri);
  4. }

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

  1. @Override
  2. public String getUriAsString() {
  3. return request.getHttpURI().getPathQuery();
  4. }

代码示例来源:origin: AsyncHttpClient/async-http-client

  1. public void handle(String s, org.eclipse.jetty.server.Request r, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  2. if ("GET".equalsIgnoreCase(request.getMethod())) {
  3. response.addHeader("target", r.getHttpURI().getPath());
  4. response.setStatus(HttpServletResponse.SC_OK);
  5. } else {
  6. // this handler is to handle POST request
  7. response.sendError(HttpServletResponse.SC_FORBIDDEN);
  8. }
  9. r.setHandled(true);
  10. }
  11. }

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

  1. @Before
  2. public void setUp() throws Exception {
  3. initMocks(this);
  4. jetty9Request = new Jetty9Request(request);
  5. when(request.getHttpURI()).thenReturn(new HttpURI("foo/bar/baz"));
  6. when(request.getRootURL()).thenReturn(new StringBuilder("http://junk/"));
  7. }

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

  1. @Override
  2. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  3. baseRequest.setHandled(true);
  4. if ("Get".equalsIgnoreCase(request.getMethod())) {
  5. response.setStatus(200);
  6. String proxyPath = baseRequest.getHttpURI().toString();
  7. response.setContentLength(proxyPath.length());
  8. response.setContentType("text/plain");
  9. try (PrintWriter writer = response.getWriter()) {
  10. writer.print(proxyPath);
  11. writer.flush();
  12. }
  13. } else {
  14. response.setStatus(404);
  15. response.setContentType("text/plain");
  16. response.setContentLength(0);
  17. }
  18. }
  19. }

代码示例来源:origin: apache/incubator-druid

  1. @Override
  2. public void log(Request request, Response response)
  3. {
  4. if (logger.isDebugEnabled()) {
  5. logger.debug(
  6. "%s %s %s %s",
  7. request.getRemoteAddr(),
  8. request.getMethod(),
  9. request.getHttpURI().toString(),
  10. request.getProtocol()
  11. );
  12. }
  13. }
  14. }

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

  1. @Test
  2. public void shouldSetRequestUri() {
  3. HttpURI requestUri = new HttpURI("foo/bar/baz");
  4. when(request.getHttpURI()).thenReturn(requestUri);
  5. jetty9Request.setRequestURI("foo/junk?a=b&c=d");
  6. assertThat(requestUri.getPath(), is("foo/junk?a=b&c=d"));
  7. }
  8. }

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

  1. @Override
  2. public String toString()
  3. {
  4. return String.format("%s@%x{r=%s,c=%b,a=%s,uri=%s}",
  5. getClass().getSimpleName(),
  6. hashCode(),
  7. _requests,
  8. _committed.get(),
  9. _state.getState(),
  10. _request.getHttpURI());
  11. }

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

  1. @Override
  2. public String toString()
  3. {
  4. return String.format("%s%s%s %s%s@%x",
  5. getClass().getSimpleName(),
  6. _handled ? "[" : "(",
  7. getMethod(),
  8. getHttpURI(),
  9. _handled ? "]" : ")",
  10. hashCode());
  11. }

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

  1. @Override
  2. public String toString()
  3. {
  4. return String.format("%s%s%s %s%s@%x",
  5. getClass().getSimpleName(),
  6. _handled ? "[" : "(",
  7. getMethod(),
  8. getHttpURI(),
  9. _handled ? "]" : ")",
  10. hashCode());
  11. }

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

  1. @Override
  2. public String toString()
  3. {
  4. long timeStamp = _request.getTimeStamp();
  5. return String.format("%s@%x{r=%s,c=%b,a=%s,uri=%s,age=%d}",
  6. getClass().getSimpleName(),
  7. hashCode(),
  8. _requests,
  9. _committed.get(),
  10. _state.getState(),
  11. _request.getHttpURI(),
  12. timeStamp == 0 ? 0 : System.currentTimeMillis() - timeStamp);
  13. }

代码示例来源:origin: labsai/EDDI

  1. @Override
  2. public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
  3. HttpServletRequest httpservletRequest = (HttpServletRequest) servletRequest;
  4. URL requestURL = URI.create(httpservletRequest.getRequestURL().toString()).toURL();
  5. String currentResourceURI = ((Request) httpservletRequest).getHttpURI().getPathQuery();
  6. ThreadContext.put("currentResourceURI", currentResourceURI);
  7. ThreadContext.put("currentURLProtocol", requestURL.getProtocol());
  8. ThreadContext.put("currentURLHost", requestURL.getHost());
  9. ThreadContext.put("currentURLPort", requestURL.getPort());
  10. filterChain.doFilter(servletRequest, servletResponse);
  11. ThreadContext.remove();
  12. }

代码示例来源:origin: javaee/grizzly-ahc

  1. public void handle(String s, Request r, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  2. if ("GET".equalsIgnoreCase(request.getMethod())) {
  3. response.addHeader("target", r.getHttpURI().getPath());
  4. response.setStatus(HttpServletResponse.SC_OK);
  5. } else { // this handler is to handle POST request
  6. response.sendError(HttpServletResponse.SC_FORBIDDEN);
  7. }
  8. r.setHandled(true);
  9. }
  10. }

代码示例来源:origin: javaee/grizzly-ahc

  1. @Override
  2. public void handle(String pathInContext, org.eclipse.jetty.server.Request request, HttpServletRequest httpRequest,
  3. HttpServletResponse httpResponse) throws IOException, ServletException {
  4. String authorization = httpRequest.getHeader("Authorization");
  5. String proxyAuthorization = httpRequest.getHeader("Proxy-Authorization");
  6. if (proxyAuthorization == null) {
  7. httpResponse.setStatus(HttpServletResponse.SC_PROXY_AUTHENTICATION_REQUIRED);
  8. httpResponse.setHeader("Proxy-Authenticate", "Basic realm=\"Fake Realm\"");
  9. } else if (proxyAuthorization
  10. .equals("Basic am9obmRvZTpwYXNz") && authorization != null && authorization.equals("Basic dXNlcjpwYXNzd2Q=")) {
  11. httpResponse.addHeader("target", request.getHttpURI().getPath());
  12. httpResponse.setStatus(HttpServletResponse.SC_OK);
  13. } else {
  14. httpResponse.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
  15. httpResponse.setHeader("www-authenticate", "Basic realm=\"Fake Realm\"");
  16. }
  17. httpResponse.getOutputStream().flush();
  18. httpResponse.getOutputStream().close();
  19. request.setHandled(true);
  20. }
  21. }

代码示例来源:origin: javaee/grizzly-ahc

  1. @Override
  2. public void handle(String pathInContext, org.eclipse.jetty.server.Request request, HttpServletRequest httpRequest,
  3. HttpServletResponse httpResponse) throws IOException, ServletException {
  4. String authorization = httpRequest.getHeader("Authorization");
  5. if (authorization != null && authorization.equals("Basic dXNlcjpwYXNzd2Q="))
  6. {
  7. httpResponse.addHeader("target", request.getHttpURI().getPath());
  8. target.handle(pathInContext, request, httpRequest, httpResponse);
  9. }
  10. else
  11. {
  12. httpResponse.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
  13. httpResponse.setHeader("www-authenticate", "Basic realm=\"Fake Realm\"");
  14. httpResponse.getOutputStream().flush();
  15. httpResponse.getOutputStream().close();
  16. request.setHandled(true);
  17. }
  18. }
  19. }

代码示例来源:origin: org.apache.druid/druid-server

  1. @Override
  2. public void log(Request request, Response response)
  3. {
  4. if (logger.isDebugEnabled()) {
  5. logger.debug(
  6. "%s %s %s %s",
  7. request.getRemoteAddr(),
  8. request.getMethod(),
  9. request.getHttpURI().toString(),
  10. request.getProtocol()
  11. );
  12. }
  13. }
  14. }

代码示例来源:origin: io.druid/druid-server

  1. @Override
  2. public void log(Request request, Response response)
  3. {
  4. if (logger.isDebugEnabled()) {
  5. logger.debug(
  6. "%s %s %s %s",
  7. request.getRemoteAddr(),
  8. request.getMethod(),
  9. request.getHttpURI().toString(),
  10. request.getProtocol()
  11. );
  12. }
  13. }
  14. }

代码示例来源: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: 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类方法