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

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

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

Request.getTimeStamp介绍

[英]Get Request TimeStamp
[中]获取请求时间戳

代码示例

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

  1. @Override
  2. public void log( Request request, Response response )
  3. {
  4.   // Trying to replicate this logback pattern:
  5.   // %h %l %user [%t{dd/MMM/yyyy:HH:mm:ss Z}] "%r" %s %b "%i{Referer}" "%i{User-Agent}" %D
  6.   String remoteHost = swallowExceptions( request, HttpServletRequest::getRemoteHost );
  7.   String user = swallowExceptions( request, HttpServletRequest::getRemoteUser );
  8.   String requestURL = swallowExceptions( request, HttpServletRequest::getRequestURI ) + "?" +
  9.       swallowExceptions( request, HttpServletRequest::getQueryString );
  10.   int statusCode = response.getStatus();
  11.   long length = response.getContentLength();
  12.   String referer = swallowExceptions( request, r -> r.getHeader( "Referer" ) );
  13.   String userAgent = swallowExceptions( request, r -> r.getHeader( "User-Agent" ) );
  14.   long requestTimeStamp = request != null ? request.getTimeStamp() : -1;
  15.   long now = System.currentTimeMillis();
  16.   long serviceTime = requestTimeStamp < 0 ? -1 : now - requestTimeStamp;
  17.   log.info( "%s - %s [%tc] \"%s\" %s %s \"%s\" \"%s\" %s",
  18.       defaultString( remoteHost ),
  19.       defaultString( user ),
  20.       now,
  21.       defaultString( requestURL ),
  22.       statusCode,
  23.       length,
  24.       defaultString( referer ),
  25.       defaultString( userAgent ),
  26.       serviceTime );
  27. }

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

  1. public String newNonce(Request request)
  2. {
  3.   Nonce nonce;
  4.   do
  5.   {
  6.     byte[] nounce = new byte[24];
  7.     _random.nextBytes(nounce);
  8.     nonce = new Nonce(new String(B64Code.encode(nounce)), request.getTimeStamp(), getMaxNonceCount());
  9.   }
  10.   while (_nonceMap.putIfAbsent(nonce._nonce, nonce) != null);
  11.   _nonceQueue.add(nonce);
  12.   return nonce._nonce;
  13. }

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

  1. long expired = request.getTimeStamp() - getMaxNonceAge();
  2. Nonce nonce = _nonceQueue.peek();
  3. while (nonce != null && nonce._ts < expired)

代码示例来源：origin: i2p/i2p.i2p

  1. buf.append(" [");
  2. if (_logDateCache!=null)
  3.   buf.append(_logDateCache.format(request.getTimeStamp()));
  4. else
  5.   buf.append(request.getTimeStamp());
  6.     _writer.write(Long.toString(System.currentTimeMillis() - request.getTimeStamp()));

代码示例来源：origin: ch.qos.logback/logback-access

  1. @Override
  2. public long getRequestTimestamp() {
  3.   return request.getTimeStamp();
  4. }

代码示例来源：origin: stackoverflow.com

  1. class SortRequest implements Comparator<Request>{
  2.   public int compare(Request r1, Request r2) {
  3.    if(r1.getTimeStamp()!=r2.getTimeStamp())
  4.      return new Integer(r1.getTimeStamp()).compareTo(r2.getTimeStamp());
  5.    if(r1.getSiteId()!=r2.getSiteId())
  6.      return new Integer(r1.getSiteId()).compareTo(r2.getSiteId());
  7.    return 0;      
  8.   }
  9. }

代码示例来源：origin: stackoverflow.com

  1. public int compare(Request r1, Request r2) {
  2.   int diff = Integer.compare(r1.getTimeStamp(), r2.getTimeStamp());
  4.   if (diff != 0)
  5.     return diff;
  7.   return Integer.compare(r1.siteId(), r2.siteId());
  8. }

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

  1. public String newNonce(Request request)
  2. {
  3.   Nonce nonce;
  4.   
  5.   do
  6.   {
  7.     byte[] nounce = new byte[24];
  8.     _random.nextBytes(nounce);
  9.     nonce = new Nonce(new String(B64Code.encode(nounce)),request.getTimeStamp(),_maxNC);
  10.   }
  11.   while (_nonceMap.putIfAbsent(nonce._nonce,nonce)!=null);
  12.   _nonceQueue.add(nonce);
  13.         return nonce._nonce;
  14. }

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

  1. public String newNonce(Request request)
  2. {
  3.   Nonce nonce;
  4.   
  5.   do
  6.   {
  7.     byte[] nounce = new byte[24];
  8.     _random.nextBytes(nounce);
  9.     nonce = new Nonce(new String(B64Code.encode(nounce)),request.getTimeStamp(),_maxNC);
  10.   }
  11.   while (_nonceMap.putIfAbsent(nonce._nonce,nonce)!=null);
  12.   _nonceQueue.add(nonce);
  13.         return nonce._nonce;
  14. }

代码示例来源：origin: com.teradata.airlift/http-server

  1. @Override
  2.   public void log(Request request, Response response)
  3.   {
  4.     Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
  6.     long dispatchTime = request.getTimeStamp();
  8.     Duration schedulingDelay = new Duration(max(0, dispatchTime - request.getTimeStamp()), TimeUnit.MILLISECONDS);
  10.     stats.record(request.getMethod(), response.getStatus(), request.getContentRead(), response.getContentCount(), schedulingDelay, requestTime);
  11.   }
  12. }

代码示例来源：origin: io.airlift/http-server

  1. @Override
  2.   public void log(Request request, Response response)
  3.   {
  4.     Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
  5.     stats.record(request.getContentRead(), response.getContentCount(), requestTime);
  6.   }
  7. }

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

  1. public void onComplete(Continuation continuation)
  2. {
  3.   final Request request = ((AsyncContinuation)continuation).getBaseRequest();
  4.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  5.   
  6.   _requestStats.decrement();
  7.   _requestTimeStats.set(elapsed);
  8.   
  9.   updateResponse(request);
  10.   
  11.   if (!continuation.isResumed())
  12.     _suspendStats.decrement();
  13. }

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

  1. public void onComplete(Continuation continuation)
  2. {
  3.   final Request request = ((AsyncContinuation)continuation).getBaseRequest();
  4.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  5.   
  6.   _requestStats.decrement();
  7.   _requestTimeStats.set(elapsed);
  8.   
  9.   updateResponse(request);
  10.   
  11.   if (!continuation.isResumed())
  12.     _suspendStats.decrement();
  13. }

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

  1. public void onComplete(Continuation continuation)
  2. {
  3.   final Request request = ((AsyncContinuation)continuation).getBaseRequest();
  4.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  5.   
  6.   _requestStats.decrement();
  7.   _requestTimeStats.set(elapsed);
  8.   
  9.   updateResponse(request);
  10.   
  11.   if (!continuation.isResumed())
  12.     _suspendStats.decrement();
  13. }

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

  1. public void onComplete(Continuation continuation)
  2. {
  3.   final Request request = ((AsyncContinuation)continuation).getBaseRequest();
  4.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  5.   
  6.   _requestStats.decrement();
  7.   _requestTimeStats.set(elapsed);
  8.   
  9.   updateResponse(request);
  10.   
  11.   if (!continuation.isResumed())
  12.     _suspendStats.decrement();
  13. }

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

  1. public void onComplete(Continuation continuation)
  2. {
  3.   final Request request = ((AsyncContinuation)continuation).getBaseRequest();
  4.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  5.   
  6.   _requestStats.decrement();
  7.   _requestTimeStats.set(elapsed);
  8.   
  9.   updateResponse(request);
  10.   
  11.   if (!continuation.isResumed())
  12.     _suspendStats.decrement();
  13. }

代码示例来源：origin: Kixeye/chassis

  1. private void updateResponses(Request request) {
  2.     final int response = request.getResponse().getStatus() / 100;
  3.     if (response >= 1 && response <= 5) {
  4.       responses[response - 1].mark();
  5.     }
  6.     activeRequests.dec();
  7.     final long elapsedTime = System.currentTimeMillis() - request.getTimeStamp();
  8.     requests.update(elapsedTime, TimeUnit.MILLISECONDS);
  9.     requestTimer(request.getMethod()).update(elapsedTime, TimeUnit.MILLISECONDS);
  10.   }
  11. }

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

  1. @Override
  2. public void onComplete(AsyncEvent event) throws IOException
  3. {
  4.   HttpChannelState state = (HttpChannelState)event.getAsyncContext();
  5.   
  6.   Request request = state.getBaseRequest();
  7.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  8.   _requestStats.decrement();
  9.   _requestTimeStats.set(elapsed);
  10.   updateResponse(request);
  11.   if (!state.isDispatched())
  12.     _asyncWaitStats.decrement();
  13. }

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

  1. @Override
  2. public void onComplete(AsyncEvent event) throws IOException
  3. {
  4.   HttpChannelState state = (HttpChannelState)event.getAsyncContext();
  5.   
  6.   Request request = state.getBaseRequest();
  7.   final long elapsed = System.currentTimeMillis()-request.getTimeStamp();
  8.   _requestStats.decrement();
  9.   _requestTimeStats.set(elapsed);
  10.   updateResponse(request);
  11.   if (!state.isDispatched())
  12.     _asyncWaitStats.decrement();
  13. }

代码示例来源：origin: com.proofpoint.platform/http-server

  1. @Override
  2.   public void log(Request request, Response response)
  3.   {
  4.     Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
  5.     SSLSession sslSession = (SSLSession) request.getAttribute(REQUEST_SSL_SESSION_ATTRIBUTE);
  7.     stats.record(request.getContentRead(), response.getContentCount(), requestTime);
  8.     detailedRequestStats.requestTimeByCode(response.getStatus(), response.getStatus() / 100).add(requestTime);
  10.     if (sslSession != null) {
  11.       detailedRequestStats.tlsRequest(sslSession.getProtocol(), sslSession.getCipherSuite()).add(1);
  12.     }
  13.   }
  14. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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