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

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

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

Request.getInputStream介绍

暂无

代码示例

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

  1. @Signature
  2. public Stream bodyStream(Environment env) throws IOException {
  3.   return new MiscStream(env, request.getInputStream());
  4. }

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

  1. @Override
  2.  public void handle(String pathInContext, Request request, HttpServletRequest httpRequest, HttpServletResponse httpResponse) throws IOException {
  3.   String redirectHeader = httpRequest.getHeader("X-REDIRECT");
  4.   if (redirectHeader != null && !redirectAlreadyPerformed) {
  5.    redirectAlreadyPerformed = true;
  6.    httpResponse.setStatus(Integer.valueOf(redirectHeader));
  7.    httpResponse.setContentLength(0);
  8.    httpResponse.setHeader(LOCATION.toString(), getTargetUrl());
  9.   } else {
  10.    receivedContentType = request.getContentType();
  11.    httpResponse.setStatus(200);
  12.    int len = request.getContentLength();
  13.    httpResponse.setContentLength(len);
  14.    if (len > 0) {
  15.     byte[] buffer = new byte[len];
  16.     IOUtils.read(request.getInputStream(), buffer);
  17.     httpResponse.getOutputStream().write(buffer);
  18.    }
  19.   }
  20.   httpResponse.getOutputStream().flush();
  21.   httpResponse.getOutputStream().close();
  22.  }
  23. };

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

  1. getSecurityContext(request),
  2.     new MapPropertiesDelegate());
  3. requestContext.setEntityStream(request.getInputStream());
  4. final Enumeration<String> headerNames = request.getHeaderNames();
  5. while (headerNames.hasMoreElements()) {

代码示例来源：origin: org.keycloak/keycloak-jetty-adapter-spi

  1. @Override
  2. public InputStream getInputStream(boolean buffered) {
  3.   if (inputStream != null) {
  4.     return inputStream;
  5.   }
  6.   if (buffered) {
  7.     try {
  8.       return inputStream = new BufferedInputStream(request.getInputStream());
  9.     } catch (IOException e) {
  10.       throw new RuntimeException(e);
  11.     }
  12.   }
  13.   try {
  14.     return request.getInputStream();
  15.   } catch (IOException e) {
  16.     throw new RuntimeException(e);
  17.   }
  18. }

代码示例来源：origin: org.keycloak/spring-boot-container-bundle

  1. @Override
  2. public InputStream getInputStream(boolean buffered) {
  3.   if (inputStream != null) {
  4.     return inputStream;
  5.   }
  6.   if (buffered) {
  7.     try {
  8.       return inputStream = new BufferedInputStream(request.getInputStream());
  9.     } catch (IOException e) {
  10.       throw new RuntimeException(e);
  11.     }
  12.   }
  13.   try {
  14.     return request.getInputStream();
  15.   } catch (IOException e) {
  16.     throw new RuntimeException(e);
  17.   }
  18. }

代码示例来源：origin: springside/springtime

  1. @Override
  2.   public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
  3.       throws IOException, ServletException {
  4.     if (!target.startsWith(RPC_PREFIX)) {
  5.       return;
  6.     }
  7.     String path = target.toLowerCase();
  8.     Serializer serializerForRequest = serializer;
  10.     dispatcher.dispatch(path, serializerForRequest, baseRequest.getInputStream(), response.getOutputStream());
  12.     response.setContentType(Serializer.JSON_TYPE);
  13.     response.setStatus(HttpServletResponse.SC_OK);
  14.     response.getOutputStream().flush();
  15.     baseRequest.setHandled(true);
  16.   }
  17. }

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

  1. public BufferedReader getReader() throws IOException
  2. {
  3.   if (_inputState != __NONE && _inputState != __READER)
  4.     throw new IllegalStateException("STREAMED");
  5.   if (_inputState == __READER)
  6.     return _reader;
  7.   String encoding = getCharacterEncoding();
  8.   if (encoding == null)
  9.     encoding = StringUtil.__ISO_8859_1;
  10.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  11.   {
  12.     final ServletInputStream in = getInputStream();
  13.     _readerEncoding = encoding;
  14.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  15.     {
  16.       @Override
  17.       public void close() throws IOException
  18.       {
  19.         in.close();
  20.       }
  21.     };
  22.   }
  23.   _inputState = __READER;
  24.   return _reader;
  25. }

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

  1. public BufferedReader getReader() throws IOException
  2. {
  3.   if (_inputState != __NONE && _inputState != __READER)
  4.     throw new IllegalStateException("STREAMED");
  5.   if (_inputState == __READER)
  6.     return _reader;
  7.   String encoding = getCharacterEncoding();
  8.   if (encoding == null)
  9.     encoding = StringUtil.__ISO_8859_1;
  10.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  11.   {
  12.     final ServletInputStream in = getInputStream();
  13.     _readerEncoding = encoding;
  14.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  15.     {
  16.       @Override
  17.       public void close() throws IOException
  18.       {
  19.         in.close();
  20.       }
  21.     };
  22.   }
  23.   _inputState = __READER;
  24.   return _reader;
  25. }

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

  1. public BufferedReader getReader() throws IOException
  2. {
  3.   if (_inputState != __NONE && _inputState != __READER)
  4.     throw new IllegalStateException("STREAMED");
  5.   if (_inputState == __READER)
  6.     return _reader;
  7.   String encoding = getCharacterEncoding();
  8.   if (encoding == null)
  9.     encoding = StringUtil.__ISO_8859_1;
  10.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  11.   {
  12.     final ServletInputStream in = getInputStream();
  13.     _readerEncoding = encoding;
  14.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  15.     {
  16.       @Override
  17.       public void close() throws IOException
  18.       {
  19.         in.close();
  20.       }
  21.     };
  22.   }
  23.   _inputState = __READER;
  24.   return _reader;
  25. }

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

  1. @Override
  2. public BufferedReader getReader() throws IOException
  3. {
  4.   if (_inputState != __NONE && _inputState != __READER)
  5.     throw new IllegalStateException("STREAMED");
  6.   if (_inputState == __READER)
  7.     return _reader;
  8.   String encoding = getCharacterEncoding();
  9.   if (encoding == null)
  10.     encoding = StringUtil.__ISO_8859_1;
  11.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  12.   {
  13.     final ServletInputStream in = getInputStream();
  14.     _readerEncoding = encoding;
  15.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  16.     {
  17.       @Override
  18.       public void close() throws IOException
  19.       {
  20.         in.close();
  21.       }
  22.     };
  23.   }
  24.   _inputState = __READER;
  25.   return _reader;
  26. }

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

  1. public BufferedReader getReader() throws IOException
  2. {
  3.   if (_inputState != __NONE && _inputState != __READER)
  4.     throw new IllegalStateException("STREAMED");
  5.   if (_inputState == __READER)
  6.     return _reader;
  7.   String encoding = getCharacterEncoding();
  8.   if (encoding == null)
  9.     encoding = StringUtil.__ISO_8859_1;
  10.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  11.   {
  12.     final ServletInputStream in = getInputStream();
  13.     _readerEncoding = encoding;
  14.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  15.     {
  16.       @Override
  17.       public void close() throws IOException
  18.       {
  19.         in.close();
  20.       }
  21.     };
  22.   }
  23.   _inputState = __READER;
  24.   return _reader;
  25. }

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

  1. public BufferedReader getReader() throws IOException
  2. {
  3.   if (_inputState != __NONE && _inputState != __READER)
  4.     throw new IllegalStateException("STREAMED");
  5.   if (_inputState == __READER)
  6.     return _reader;
  7.   String encoding = getCharacterEncoding();
  8.   if (encoding == null)
  9.     encoding = StringUtil.__ISO_8859_1;
  10.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  11.   {
  12.     final ServletInputStream in = getInputStream();
  13.     _readerEncoding = encoding;
  14.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  15.     {
  16.       @Override
  17.       public void close() throws IOException
  18.       {
  19.         in.close();
  20.       }
  21.     };
  22.   }
  23.   _inputState = __READER;
  24.   return _reader;
  25. }

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

  1. @Override
  2. public BufferedReader getReader() throws IOException
  3. {
  4.   if (_inputState != __NONE && _inputState != __READER)
  5.     throw new IllegalStateException("STREAMED");
  6.   if (_inputState == __READER)
  7.     return _reader;
  8.   String encoding = getCharacterEncoding();
  9.   if (encoding == null)
  10.     encoding = StringUtil.__ISO_8859_1;
  11.   if (_reader == null || !encoding.equalsIgnoreCase(_readerEncoding))
  12.   {
  13.     final ServletInputStream in = getInputStream();
  14.     _readerEncoding = encoding;
  15.     _reader = new BufferedReader(new InputStreamReader(in,encoding))
  16.     {
  17.       @Override
  18.       public void close() throws IOException
  19.       {
  20.         in.close();
  21.       }
  22.     };
  23.   }
  24.   _inputState = __READER;
  25.   return _reader;
  26. }

代码示例来源：origin: org.restlet.jee/org.restlet.ext.jetty

  1. @Override
  2. public InputStream getRequestEntityStream(long size) {
  3.   try {
  4.     return getConnection().getRequest().getInputStream();
  5.   } catch (IOException e) {
  6.     getLogger().log(Level.WARNING,
  7.         "Unable to get request entity stream", e);
  8.     return null;
  9.   }
  10. }

代码示例来源：origin: org.opendaylight.iotdm/onem2msimpleadapter-impl

  1. @Override
  2.   public void handle(String target, Request baseRequest,
  3.             HttpServletRequest httpRequest,
  4.             HttpServletResponse httpResponse) throws IOException, ServletException {
  5.     response = null;
  6.     httpRSC = HttpServletResponse.SC_OK;
  7.     String method = baseRequest.getMethod().toLowerCase();
  8.     String uri = baseRequest.getRequestURI();
  9.     String payload = IOUtils.toString(baseRequest.getInputStream()).trim();
  10.     LOG.info("handle: received http message: start");
  11.     LOG.info("Method {}", method);
  12.     LOG.info("URI {}", uri);
  13.     LOG.info("RemoteAddr {}", baseRequest.getRemoteAddr());
  14.     for (Enumeration<String> e = baseRequest.getHeaderNames(); e.hasMoreElements(); ) {
  15.       String header = e.nextElement();
  16.       LOG.info("Header: {}, Value: {}", header, baseRequest.getHeader(header));
  17.     }
  18.     LOG.info("payload: {}", payload);
  19.     if (method.compareToIgnoreCase("POST") == 0 || method.compareToIgnoreCase("PUT") == 0) {
  20.       processHttpMessage(baseRequest, uri, payload);
  21.     }
  22.     sendHttpResponse(httpResponse);
  23.     baseRequest.setHandled(true);
  24.     LOG.info("handle: received http message: end");
  25.   }
  26. }

代码示例来源：origin: com.yahoo.vespa/jdisc_http_service

  1. ContentChannel handleRequestFilterResponse(Response response) {
  2.   try {
  3.     jettyRequest.getInputStream().close();
  4.     ContentChannel responseContentChannel = servletResponseController.responseHandler.handleResponse(response);
  5.     servletResponseController.finishedFuture().whenComplete(completeRequestCallback);
  6.     return responseContentChannel;
  7.   } catch (IOException e) {
  8.     throw throwUnchecked(e);
  9.   }
  10. }

代码示例来源：origin: kiegroup/droolsjbpm-integration

  1. /**
  2.  * Read content
  3.  *
  4.  * @return content
  5.  */
  6. protected byte[] read() {
  7.  ByteArrayOutputStream content = new ByteArrayOutputStream();
  8.  final byte[] buffer = new byte[8196];
  9.  int read;
  10.  try {
  11.   InputStream input = request.getInputStream();
  12.   while ((read = input.read(buffer)) != -1)
  13.    content.write(buffer, 0, read);
  14.  } catch (IOException e) {
  15.   throw new RuntimeException(e);
  16.  }
  17.  return content.toByteArray();
  18. }

代码示例来源：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.   
  7.   switch(compliance)
  8.   {
  9.     case RFC7578:
  10.       return new MultiParts.MultiPartsHttpParser(getInputStream(), getContentType(), config,
  11.           (_context != null?(File)_context.getAttribute("javax.servlet.context.tempdir"):null), this);
  12.       
  13.     case LEGACY: 
  14.     default:
  15.       return new MultiParts.MultiPartsUtilParser(getInputStream(), getContentType(), config,
  16.         (_context != null?(File)_context.getAttribute("javax.servlet.context.tempdir"):null), this);
  17.           
  18.   }
  19. }

代码示例来源：origin: com.yahoo.vespa/jdisc_http_service

  1. @SuppressWarnings("try")
  2. private ServletRequestReader handleRequest() throws IOException {
  3.   HttpRequest jdiscRequest = HttpRequestFactory.newJDiscRequest(jDiscContext.container, jettyRequest);
  4.   ContentChannel requestContentChannel;
  5.   try (ResourceReference ref = References.fromResource(jdiscRequest)) {
  6.     HttpRequestFactory.copyHeaders(jettyRequest, jdiscRequest);
  7.     requestContentChannel = requestHandler.handleRequest(jdiscRequest, servletResponseController.responseHandler);
  8.   }
  9.   ServletInputStream servletInputStream = jettyRequest.getInputStream();
  10.   ServletRequestReader servletRequestReader =
  11.       new ServletRequestReader(
  12.           servletInputStream,
  13.           requestContentChannel,
  14.           jDiscContext.janitor,
  15.           metricReporter);
  16.   servletInputStream.setReadListener(servletRequestReader);
  17.   return servletRequestReader;
  18. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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