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

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

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

Request.setHandled介绍

暂无

代码示例

代码示例来源：origin: perwendel/spark

  1. @Override
  2. public void doHandle(
  3.     String target,
  4.     Request baseRequest,
  5.     HttpServletRequest request,
  6.     HttpServletResponse response) throws IOException, ServletException {
  7.   HttpRequestWrapper wrapper = new HttpRequestWrapper(request);
  8.   filter.doFilter(wrapper, response, null);
  9.   if (wrapper.notConsumed()) {
  10.     baseRequest.setHandled(false);
  11.   } else {
  12.     baseRequest.setHandled(true);
  13.   }
  14. }

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

  1. private void respondWith503(Request baseRequest, HttpServletResponse response, String contentType, String body) throws IOException {
  2.   addHeaders(response);
  3.   response.setStatus(org.eclipse.jetty.http.HttpStatus.SERVICE_UNAVAILABLE_503);
  4.   response.setContentType(contentType);
  5.   response.getWriter().println(body);
  6.   baseRequest.setHandled(true);
  7. }

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

  1. @Override
  2.  public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
  3.    throws IOException, ServletException {
  4.   if (request.getRequestURI().equals("/js/settings.js")) {
  5.    response.setContentType("application/javascript");
  6.    response.setStatus(HttpServletResponse.SC_OK);
  7.    response.getWriter().println(String.format(responseTemplate, AdminWebServer.this.restServerUri.toString(),
  8.      AdminWebServer.this.hideJobsWithoutTasksByDefault, AdminWebServer.this.refreshInterval));
  9.    baseRequest.setHandled(true);
  10.   }
  11.  }
  12. };

代码示例来源：origin: jphp-group/jphp

  1. @Signature
  2.   public void end() {
  3.     request.setHandled(true);
  4.   }
  5. }

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

  1. public void execute() throws Pausable, Exception {
  2.     try {
  3.       String result = handler.handle(target,br,req,resp);
  4.       if (result != null) resp.getOutputStream().print(result);
  5.     }
  6.     catch (Exception ex) { resp.sendError(500,"the server encountered an error"); }
  7.     br.setHandled(true);
  8.     async.complete();
  9.   }
  10. }.start();

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

  1. @Override
  2.   public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  3.     baseRequest.setHandled(true);
  4.     response.sendError(HttpServletResponse.SC_UNAUTHORIZED);
  5.   }
  6. });

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

  1. public void handle(String s, Request request, HttpServletRequest req, HttpServletResponse resp) throws IOException, ServletException {
  2.   if (!req.getMethod().equalsIgnoreCase("PUT")) {
  3.    resp.setStatus(HttpServletResponse.SC_OK);
  4.   } else {
  5.    resp.setStatus(204);
  6.   }
  7.   request.setHandled(true);
  8.  }
  9. }

代码示例来源：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 ("HEAD".equalsIgnoreCase(request.getMethod())) {
  3.    response.setStatus(HttpServletResponse.SC_FOUND); // 302
  4.    response.setHeader("Location", request.getPathInfo() + "_moved");
  5.   } else if ("GET".equalsIgnoreCase(request.getMethod())) {
  6.    response.setStatus(HttpServletResponse.SC_OK);
  7.   } else {
  8.    response.setStatus(HttpServletResponse.SC_FORBIDDEN);
  9.   }
  10.   r.setHandled(true);
  11.  }
  12. }

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

  1. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException {
  2.   InputStream is = baseRequest.getInputStream();
  3.   int read;
  4.   do {
  5.    // drain upload
  6.    read = is.read();
  7.   } while (read >= 0);
  8.   response.setStatus(200);
  9.   response.getOutputStream().flush();
  10.   response.getOutputStream().close();
  11.   baseRequest.setHandled(true);
  12.  }
  13. };

代码示例来源：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.     dateString = request.getHeader("Date");
  5.     response.setStatus(200);
  6.     response.setContentType("text/plain");
  7.     response.getWriter().println("Way to go!");
  8.   }
  9. }

代码示例来源：origin: SonarSource/sonarqube

  1. @Override
  2.  public void handle(String target, Request request, HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse) throws IOException {
  3.   if ("/ping".equals(target)) {
  4.    request.setHandled(true);
  5.    httpServletResponse.getWriter().print("ping");
  6.   } else if ("/restart".equals(target)) {
  7.    writeTimeToFile("restartAskedAt");
  8.    request.setHandled(true);
  9.    processCommands.askForRestart();
  10.    httpServletResponse.getWriter().print("ok");
  11.   } else if ("/kill".equals(target)) {
  12.    writeTimeToFile("killedAt");
  13.    System.exit(0);
  14.   }
  15.  }
  16. });

代码示例来源：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: AsyncHttpClient/async-http-client

  1. public void handle(String target, Request baseRequest, HttpServletRequest req, HttpServletResponse resp) throws IOException {
  2.   ServletInputStream in = req.getInputStream();
  3.   byte[] b = new byte[8192];
  4.   int count;
  5.   int total = 0;
  6.   while ((count = in.read(b)) != -1) {
  7.    b = new byte[8192];
  8.    total += count;
  9.   }
  10.   resp.setStatus(200);
  11.   resp.addHeader("X-TRANSFERRED", String.valueOf(total));
  12.   resp.getOutputStream().flush();
  13.   resp.getOutputStream().close();
  14.   baseRequest.setHandled(true);
  15.  }
  16. };

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

  1. public void handle(String target, Request baseRequest, HttpServletRequest req, HttpServletResponse resp) throws IOException {
  2.   ServletInputStream in = req.getInputStream();
  3.   byte[] b = new byte[8192];
  4.   int count;
  5.   int total = 0;
  6.   while ((count = in.read(b)) != -1) {
  7.    b = new byte[8192];
  8.    total += count;
  9.   }
  10.   resp.setStatus(200);
  11.   resp.addHeader("X-TRANFERED", String.valueOf(total));
  12.   resp.getOutputStream().flush();
  13.   resp.getOutputStream().close();
  14.   baseRequest.setHandled(true);
  15.  }
  16. };

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

  1. @Override
  2.   public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  3.     baseRequest.setHandled(true);
  4.     assertEquals("Basic dXNlcjpwYXNz", request.getHeader("Authorization"));
  5.     assertThat(request.getQueryString()).isEqualTo("bar=baz");
  6.     handled[0] = true;
  7.   }
  8. });

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

  1. public void handle(String s, Request r, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  2.   if ("GET".equalsIgnoreCase(request.getMethod())) {
  3.    String qs = request.getQueryString();
  4.    if (isNonEmpty(qs)) {
  5.     for (String qnv : qs.split("&")) {
  6.      String nv[] = qnv.split("=");
  7.      response.addHeader(nv[0], nv[1]);
  8.     }
  9.     response.setStatus(HttpServletResponse.SC_OK);
  10.    } else {
  11.     response.sendError(HttpServletResponse.SC_NOT_ACCEPTABLE);
  12.    }
  13.   } else { // this handler is to handle POST request
  14.    response.sendError(HttpServletResponse.SC_FORBIDDEN);
  15.   }
  16.   r.setHandled(true);
  17.  }
  18. }

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

  1. public void handle(String target, Request baseRequest, HttpServletRequest request, final HttpServletResponse response)
  2.      throws IOException, ServletException {
  3.   response.setStatus(HttpServletResponse.SC_OK);
  4.   final AsyncContext asyncContext = request.startAsync();
  5.   new Thread(() -> {
  6.    try {
  7.     Thread.sleep(SLEEPTIME_MS);
  8.     response.getOutputStream().print(MSG);
  9.     response.getOutputStream().flush();
  10.     asyncContext.complete();
  11.    } catch (InterruptedException | IOException e) {
  12.     logger.error(e.getMessage(), e);
  13.    }
  14.   }).start();
  15.   baseRequest.setHandled(true);
  16.  }
  17. }

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

  1. @Override
  2. public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  3.   boolean handled = false;
  4.   if ("/graphql".equals(target)) {
  5.     handleStarWars(request, response);
  6.     handled = true;
  7.   } else if (target.startsWith("/executionresult")) {
  8.     new ExecutionResultJSONTesting(target, response);
  9.     handled = true;
  10.   }
  11.   if (handled) {
  12.     baseRequest.setHandled(true);
  13.   }
  14. }

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

  1. @Override
  2.   public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
  3.     IOUtils.copy(IOUtils.getResourceAsStream("wsdl.xml"), response.getOutputStream());
  4.     baseRequest.setHandled(true);
  5.   }
  6. });

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

  1. @Override
  2. public void handle(
  3.     String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response )
  4.     throws IOException
  5. {
  6.   response.setContentType( "text/plain; charset=utf-8" );
  7.   response.setStatus( HttpServletResponse.SC_OK );
  8.   PrintWriter out = response.getWriter();
  9.   writeBatch( out, firstBatchSize );
  10.   out.flush();
  11.   latch.start();
  12.   innerBarrier.reached();
  13.   latch.finish();
  14.   writeBatch( out, otherBatchSize );
  15.   baseRequest.setHandled(true);
  16. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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