org.apache.coyote.Request类的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(13.8k)|赞(0)|评价(0)|浏览(354)

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

Request介绍

[英]This is a low-level, efficient representation of a server request. Most fields are GC-free, expensive operations are delayed until the user code needs the information. Processing is delegated to modules, using a hook mechanism. This class is not intended for user code - it is used internally by tomcat for processing the request in the most efficient way. Users ( servlets ) can access the information using a facade, which provides the high-level view of the request. Tomcat defines a number of attributes:

  • "org.apache.tomcat.request" - allows access to the low-level request object in trusted applications
    [中]这是服务器请求的低级别、高效表示。大多数字段都是无GC的，昂贵的操作会被延迟，直到用户代码需要这些信息。使用钩子机制将处理委托给模块。这个类不适用于用户代码——tomcat在内部使用它以最有效的方式处理请求。用户（servlet）可以使用facade访问信息，facade提供请求的高级视图。Tomcat定义了许多属性：
    *“org.apache.tomcat.request”-允许访问受信任应用程序中的低级请求对象

代码示例

代码示例来源：origin: line/armeria

  1. @Nullable
  2. private Request convertRequest(ServiceRequestContext ctx, AggregatedHttpMessage req) throws Throwable {
  3.   final String mappedPath = ctx.mappedPath();
  4.   final Request coyoteReq = new Request();
  5.   coyoteReq.scheme().setString(req.scheme());
  6.   coyoteReq.remoteAddr().setString(remoteAddr.getAddress().getHostAddress());
  7.   coyoteReq.remoteHost().setString(remoteAddr.getHostString());
  8.   coyoteReq.setRemotePort(remoteAddr.getPort());
  9.   coyoteReq.localAddr().setString(localAddr.getAddress().getHostAddress());
  10.   coyoteReq.localName().setString(hostName());
  11.   coyoteReq.setLocalPort(localAddr.getPort());
  12.     coyoteReq.serverName().setString(hostHeader);
  13.   } else {
  14.     coyoteReq.serverName().setString(hostHeader.substring(0, colonPos));
  15.     try {
  16.       final int port = Integer.parseInt(hostHeader.substring(colonPos + 1));
  17.       coyoteReq.setServerPort(port);
  18.     } catch (NumberFormatException e) {
  19.   coyoteReq.method().setString(method.name());
  20.   coyoteReq.requestURI().setBytes(uriBytes, 0, uriBytes.length);
  21.     coyoteReq.queryString().setString(ctx.query());
  22.   final MimeHeaders cHeaders = coyoteReq.getMimeHeaders();

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. @Override
  2. public void dispatch(ServletContext context, String path) {
  3.   synchronized (asyncContextLock) {
  4.     if (log.isDebugEnabled()) {
  5.       logDebug("dispatch   ");
  6.     if (dispatch != null) {
  7.       throw new IllegalStateException(
  8.           sm.getString("asyncContextImpl.dispatchingStarted"));
  9.     if (request.getAttribute(ASYNC_REQUEST_URI)==null) {
  10.       request.setAttribute(ASYNC_REQUEST_URI, request.getRequestURI());
  11.       request.setAttribute(ASYNC_CONTEXT_PATH, request.getContextPath());
  12.       request.setAttribute(ASYNC_SERVLET_PATH, request.getServletPath());
  13.     if (!(requestDispatcher instanceof AsyncDispatcher)) {
  14.       throw new UnsupportedOperationException(
  15.           sm.getString("asyncContextImpl.noAsyncDispatcher"));
  16.     this.dispatch = new AsyncRunnable(
  17.         request, applicationDispatcher, servletRequest, servletResponse);
  18.     this.request.getCoyoteRequest().action(ActionCode.ASYNC_DISPATCH, null);
  19.     clearServletRequestResponse();

代码示例来源：origin: tomcat/catalina

  1. ByteChunk uriBC = req.requestURI().getByteChunk();
  2. int semicolon = uriBC.indexOf(match, 0, match.length(), 0);
  3.   int start = uriBC.getStart();
  4.   int end = uriBC.getEnd();
  5.   int semicolon2 = uriBC.indexOf(';', sessionIdStart);
  6.   if (semicolon2 >= 0) {
  7.     request.setRequestedSessionId
  8.       (new String(uriBC.getBuffer(), start + sessionIdStart, 
  9.           semicolon2 - sessionIdStart));
  10.     uriBC.setBytes(buf, start, end - start - semicolon2 + semicolon);
  11.   } else {
  12.     request.setRequestedSessionId
  13.       (new String(uriBC.getBuffer(), start + sessionIdStart, 
  14.           (end - start) - sessionIdStart));
  15.     uriBC.setEnd(start + semicolon);
  16.   request.setRequestedSessionURL(true);

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. final synchronized boolean onDataAvailable() {
  2.   if (readInterest) {
  3.     if (log.isDebugEnabled()) {
  4.       log.debug(sm.getString("stream.inputBuffer.dispatch"));
  5.     }
  6.     readInterest = false;
  7.     coyoteRequest.action(ActionCode.DISPATCH_READ, null);
  8.     // Always need to dispatch since this thread is processing
  9.     // the incoming connection and streams are processed on their
  10.     // own.
  11.     coyoteRequest.action(ActionCode.DISPATCH_EXECUTE, null);
  12.     return true;
  13.   } else {
  14.     if (log.isDebugEnabled()) {
  15.       log.debug(sm.getString("stream.inputBuffer.signal"));
  16.     }
  17.     synchronized (inBuffer) {
  18.       inBuffer.notifyAll();
  19.     }
  20.     return false;
  21.   }
  22. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. @Override
  2. public void complete() {
  3.   if (log.isDebugEnabled()) {
  4.     logDebug("complete   ");
  5.   }
  6.   check();
  7.   request.getCoyoteRequest().action(ActionCode.COMMIT, null);
  8.   request.getCoyoteRequest().action(ActionCode.ASYNC_COMPLETE, null);
  9.   clearServletRequestResponse();
  10. }

代码示例来源：origin: com.tomitribe.tribestream/tribestream-container

  1. String password = null;
  2. final MessageBytes authorization = request.getCoyoteRequest().getMimeHeaders().getValue("authorization");
  3. if (authorization != null) {
  4.   authorization.toBytes();
  5.   final ByteChunk authorizationBC = authorization.getByteChunk();
  6.   if (authorizationBC.startsWithIgnoreCase("basic ", 0)) {
  7.     authorizationBC.setOffset(authorizationBC.getOffset() + 6);
  8.     final byte[] decoded = Base64.decodeBase64(authorizationBC.getBuffer(), authorizationBC.getOffset(), authorizationBC.getLength());
  9.   final Principal principal = context.getRealm().authenticate(username, password);
  10.   if (principal != null) {
  11.     register(request, response, principal, HttpServletRequest.BASIC_AUTH, username, password);

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. /**
  2.  * Reject the request that was denied by this valve.
  3.  * <p>If <code>invalidAuthenticationWhenDeny</code> is true
  4.  * and the context has <code>preemptiveAuthentication</code>
  5.  * set, set an invalid authorization header to trigger basic auth.
  6.  *
  7.  * @param request The servlet request to be processed
  8.  * @param response The servlet response to be processed
  9.  * @exception IOException if an input/output error occurs
  10.  * @exception ServletException if a servlet error occurs
  11.  */
  12. protected void denyRequest(Request request, Response response)
  13.     throws IOException, ServletException {
  14.   if (invalidAuthenticationWhenDeny) {
  15.     Context context = request.getContext();
  16.     if (context != null && context.getPreemptiveAuthentication()) {
  17.       if (request.getCoyoteRequest().getMimeHeaders().getValue("authorization") == null) {
  18.         request.getCoyoteRequest().getMimeHeaders().addValue("authorization").setString("invalid");
  19.       }
  20.       getNext().invoke(request, response);
  21.       return;
  22.     }
  23.   }
  24.   response.sendError(denyStatus);
  25. }

代码示例来源：origin: org.apache.geronimo.modules/geronimo-tomcat6

  1. request.getCoyoteRequest().getMimeHeaders()
  2. .getValue("authorization");
  3. authorization.toBytes();
  4. ByteChunk authorizationBC = authorization.getByteChunk();
  5. if (authorizationBC.startsWithIgnoreCase("basic ", 0)) {
  6.   authorizationBC.setOffset(authorizationBC.getOffset() + 6);
  7.   CharChunk authorizationCC = authorization.getCharChunk();
  8.   Base64.decode(authorizationBC, authorizationCC);
  9. try {
  10.   MessageBytes authenticate =
  11.       response.getCoyoteResponse().getMimeHeaders()
  12.       .addValue(AUTHENTICATE_BYTES, 0, AUTHENTICATE_BYTES.length);
  13.   CharChunk authenticateCC = authenticate.getCharChunk();
  14.   authenticateCC.append("Basic realm=\"");

代码示例来源：origin: line/armeria

  1. private static HttpHeaders convertResponse(Response coyoteRes) {
  2.   final HttpHeaders headers = HttpHeaders.of(HttpStatus.valueOf(coyoteRes.getStatus()));
  3.   final String contentType = coyoteRes.getContentType();
  4.   if (contentType != null && !contentType.isEmpty()) {
  5.     headers.set(HttpHeaderNames.CONTENT_TYPE, contentType);
  6.   }
  7.   final long contentLength = coyoteRes.getBytesWritten(true); // 'true' will trigger flush.
  8.   final String method = coyoteRes.getRequest().method().toString();
  9.   if (!"HEAD".equals(method)) {
  10.     headers.setLong(HttpHeaderNames.CONTENT_LENGTH, contentLength);
  11.   }
  12.   final MimeHeaders cHeaders = coyoteRes.getMimeHeaders();
  13.   final int numHeaders = cHeaders.size();
  14.   for (int i = 0; i < numHeaders; i++) {
  15.     final AsciiString name = toHeaderName(cHeaders.getName(i));
  16.     if (name == null) {
  17.       continue;
  18.     }
  19.     final String value = toHeaderValue(cHeaders.getValue(i));
  20.     if (value == null) {
  21.       continue;
  22.     }
  23.     headers.add(name.toLowerCase(), value);
  24.   }
  25.   return headers;
  26. }

代码示例来源：origin: org.osivia.portal.core/osivia-portal-jbossas-jbossweb-lib

  1. /*      */   public String getRemoteHost()
  2. /*      */   {
  3. /* 1181 */     if (this.remoteHost == null) {
  4. /* 1182 */       if (!this.connector.getEnableLookups()) {
  5. /* 1183 */         this.remoteHost = getRemoteAddr();
  6. /*      */       } else {
  7. /* 1185 */         this.coyoteRequest.action(ActionCode.ACTION_REQ_HOST_ATTRIBUTE, this.coyoteRequest);
  8. /*      */ 
  9. /* 1187 */         this.remoteHost = this.coyoteRequest.remoteHost().toString();
  10. /*      */       }
  11. /*      */     }
  12. /* 1190 */     return this.remoteHost;
  13. /*      */   }
  14. /*      */

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. final boolean receivedEndOfHeaders() throws ConnectionException {
  2.   if (coyoteRequest.method().isNull() || coyoteRequest.scheme().isNull() ||
  3.       coyoteRequest.requestURI().isNull()) {
  4.     throw new ConnectionException(sm.getString("stream.header.required",
  5.         getConnectionId(), getIdentifier()), Http2Error.PROTOCOL_ERROR);
  6.   }
  7.   // Cookie headers need to be concatenated into a single header
  8.   // See RFC 7540 8.1.2.5
  9.   // Can only do this once the headers are fully received
  10.   if (cookieHeader != null) {
  11.     coyoteRequest.getMimeHeaders().addValue("cookie").setString(cookieHeader.toString());
  12.   }
  13.   return headerState == HEADER_STATE_REGULAR || headerState == HEADER_STATE_PSEUDO;
  14. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. /**
  2.  * Check the configuration for aborted uploads and if configured to do so,
  3.  * disable the swallowing of any remaining input and close the connection
  4.  * once the response has been written.
  5.  */
  6. protected void checkSwallowInput() {
  7.   Context context = getContext();
  8.   if (context != null && !context.getSwallowAbortedUploads()) {
  9.     coyoteRequest.action(ActionCode.DISABLE_SWALLOW_INPUT, null);
  10.   }
  11. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. /** Called by the processor before recycling the request. It'll collect
  2.  * statistic information.
  3.  */
  4. void updateCounters() {
  5.   bytesReceived+=req.getBytesRead();
  6.   bytesSent+=req.getResponse().getContentWritten();
  7.   requestCount++;
  8.   if( req.getResponse().getStatus() >=400 )
  9.     errorCount++;
  10.   long t0=req.getStartTime();
  11.   long t1=System.currentTimeMillis();
  12.   long time=t1-t0;
  13.   this.lastRequestProcessingTime = time;
  14.   processingTime+=time;
  15.   if( maxTime < time ) {
  16.     maxTime=time;
  17.     maxRequestUri=req.requestURI().toString();
  18.   }
  19. }

代码示例来源：origin: org.glassfish.metro/webservices-extra

  1. /**
  2.  * Intercept the request and decide if we cache the static resource. If the
  3.  * static resource is already cached, return it.
  4.  */
  5. public int handle(Request req, int handlerCode) throws IOException{
  6.   if (fileCache == null) return Handler.CONTINUE;
  7.   
  8.   if (handlerCode == Handler.RESPONSE_PROCEEDED && fileCache.isEnabled()){
  9.     String docroot = SelectorThread.getWebAppRootPath();
  10.     MessageBytes mb = req.requestURI();
  11.     ByteChunk requestURI = mb.getByteChunk();
  12.     String uri = req.requestURI().toString();                
  13.     fileCache.add(FileCache.DEFAULT_SERVLET_NAME,docroot,uri,
  14.            req.getResponse().getMimeHeaders(),false);        
  15.   } else if (handlerCode == Handler.HEADERS_PARSED) {
  16.     ByteChunk requestURI = req.requestURI().getByteChunk(); 
  17.     if (fileCache.sendCache(requestURI.getBytes(), requestURI.getStart(),
  18.               requestURI.getLength(), socketChannel,
  19.               keepAlive(req))){
  20.       return Handler.BREAK;   
  21.     }
  22.   }     
  23.   return Handler.CONTINUE;
  24. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. public boolean timeout() {
  2.   AtomicBoolean result = new AtomicBoolean();
  3.   request.getCoyoteRequest().action(ActionCode.ASYNC_TIMEOUT, result);
  4.   // Avoids NPEs during shutdown. A call to recycle will null this field.
  5.   Context context = this.context;
  6.   if (result.get()) {
  7.     ClassLoader oldCL = context.bind(false, null);
  8.     try {
  9.       List<AsyncListenerWrapper> listenersCopy = new ArrayList<>();
  10.       listenersCopy.addAll(listeners);
  11.       for (AsyncListenerWrapper listener : listenersCopy) {
  12.         try {
  13.           listener.fireOnTimeout(event);
  14.         } catch (Throwable t) {
  15.           ExceptionUtils.handleThrowable(t);
  16.           log.warn(sm.getString("asyncContextImpl.onTimeoutError",
  17.               listener.getClass().getName()), t);
  18.         }
  19.       }
  20.       request.getCoyoteRequest().action(
  21.           ActionCode.ASYNC_IS_TIMINGOUT, result);
  22.     } finally {
  23.       context.unbind(false, oldCL);
  24.     }
  25.   }
  26.   return !result.get();
  27. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. /**
  2.  * @return the remote IP address making this Request.
  3.  */
  4. @Override
  5. public String getRemoteAddr() {
  6.   if (remoteAddr == null) {
  7.     coyoteRequest.action
  8.       (ActionCode.REQ_HOST_ADDR_ATTRIBUTE, coyoteRequest);
  9.     remoteAddr = coyoteRequest.remoteAddr().toString();
  10.   }
  11.   return remoteAddr;
  12. }

代码示例来源：origin: tomcat/catalina

  1. /**
  2.  * Returns the Internet Protocol (IP) address of the interface on
  3.  * which the request  was received.
  4.  */       
  5. public String getLocalAddr(){
  6.   if (localAddr == null) {
  7.     coyoteRequest.action
  8.       (ActionCode.ACTION_REQ_LOCAL_ADDR_ATTRIBUTE, coyoteRequest);
  9.     localAddr = coyoteRequest.localAddr().toString();
  10.   }
  11.   return localAddr;    
  12. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. public void setStarted(Context context, ServletRequest request,
  2.     ServletResponse response, boolean originalRequestResponse) {
  3.   synchronized (asyncContextLock) {
  4.     this.request.getCoyoteRequest().action(
  5.         ActionCode.ASYNC_START, this);
  6.     this.context = context;
  7.     this.servletRequest = request;
  8.     this.servletResponse = response;
  9.     this.hasOriginalRequestAndResponse = originalRequestResponse;
  10.     this.event = new AsyncEvent(this, request, response);
  11.     List<AsyncListenerWrapper> listenersCopy = new ArrayList<>();
  12.     listenersCopy.addAll(listeners);
  13.     listeners.clear();
  14.     for (AsyncListenerWrapper listener : listenersCopy) {
  15.       try {
  16.         listener.fireOnStartAsync(event);
  17.       } catch (Throwable t) {
  18.         ExceptionUtils.handleThrowable(t);
  19.         log.warn(sm.getString("asyncContextImpl.onStartAsyncError",
  20.             listener.getClass().getName()), t);
  21.       }
  22.     }
  23.   }
  24. }

代码示例来源：origin: org.jboss.web/jbossweb

  1. /** Called by the processor before recycling the request. It'll collect
  2.  * statistic information.
  3.  */
  4. void updateCounters() {
  5.   bytesReceived+=req.getBytesRead();
  6.   bytesSent+=req.getResponse().getBytesWritten();
  7.   requestCount++;
  8.   if( req.getResponse().getStatus() >=400 )
  9.     errorCount++;
  10.   long t0=req.getStartTime();
  11.   long t1=System.currentTimeMillis();
  12.   long time=t1-t0;
  13.   this.lastRequestProcessingTime = time;
  14.   processingTime+=time;
  15.   if( maxTime < time ) {
  16.     maxTime=time;
  17.     maxRequestUri=req.requestURI().toString();
  18.   }
  19. }

代码示例来源：origin: jboss.remoting/jboss-remoting

  1. private void populateRequestMetadata(RequestMap metadata, Request req)
  2. {
  3.  MimeHeaders headers = req.getMimeHeaders();
  4.  Enumeration nameEnum = headers.names();
  5.  while (nameEnum.hasMoreElements())
  6.  {
  7.    Object nameObj = nameEnum.nextElement();
  8.    if (nameObj instanceof String)
  9.    {
  10.     Object valueObj = headers.getHeader((String) nameObj);
  11.     metadata.put(nameObj, valueObj);
  12.    }
  13.  }
  14.  metadata.put(HTTPMetadataConstants.METHODTYPE, req.method().getString());
  15.  metadata.put(HTTPMetadataConstants.PATH, req.requestURI().getString());
  16.  metadata.put(HTTPMetadataConstants.HTTPVERSION, req.protocol().getString());
  17. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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