io.vertx.core.logging.Logger.isTraceEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(11.3k)|赞(0)|评价(0)|浏览(279)

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

Logger.isTraceEnabled介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-web

  1. protected void sendInvalidJSON(HttpServerResponse response) {
  2.  if (log.isTraceEnabled()) log.trace("Broken JSON");
  3.  response.setStatusCode(500);
  4.  response.end("Broken JSON encoding.");
  5. }

代码示例来源：origin: vert-x3/vertx-web

  1. private String getFile(String path, RoutingContext context) {
  2.  String file = webRoot + Utils.pathOffset(path, context);
  3.  if (log.isTraceEnabled()) log.trace("File to serve is " + file);
  4.  return file;
  5. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void sendFrame(final String body) {
  2.  if (log.isTraceEnabled()) log.trace("WS, sending frame");
  3.  if (!closed) {
  4.   ws.writeTextMessage(body);
  5.  }
  6. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void handle(RoutingContext rc) {
  2.   if (log.isTraceEnabled()) log.trace("In Info handler");
  3.   rc.response().putHeader("Content-Type", "application/json; charset=UTF-8");
  4.   setNoCacheHeaders(rc);
  5.   JsonObject json = new JsonObject();
  6.   json.put("websocket", websocket);
  7.   json.put("cookie_needed", options.isInsertJSESSIONID());
  8.   json.put("origins", new JsonArray().add("*:*"));
  9.   // Java ints are signed, so we need to use a long and add the offset so
  10.   // the result is not negative
  11.   json.put("entropy", RAND_OFFSET + new Random().nextInt());
  12.   setCORS(rc);
  13.   rc.response().end(json.encode());
  14.  }
  15. };

代码示例来源：origin: vert-x3/vertx-web

  1. protected void addCloseHandler(HttpServerResponse resp, final SockJSSession session) {
  2.  resp.closeHandler(v -> {
  3.    if (log.isTraceEnabled()) log.trace("Connection closed (from client?), closing session");
  4.    // Connection has been closed from the client or network error so
  5.    // we remove the session
  6.    session.shutdown();
  7.    closed = true;
  8.  });
  9. }

代码示例来源：origin: vert-x3/vertx-web

  1. @Override
  2. public void handle(HttpServerRequest request) {
  3.  if (log.isTraceEnabled()) log.trace("Router: " + System.identityHashCode(this) +
  4.   " accepting request " + request.method() + " " + request.absoluteURI());
  5.  new RoutingContextImpl(null, this, request, routes).next();
  6. }

代码示例来源：origin: vert-x3/vertx-web

  1. @Override
  2. public void handle(RoutingContext context) {
  3.  if (log.isTraceEnabled()) {
  4.   log.trace("Got request in sockjs server: " + context.request().uri());
  5.  }
  6.  router.handleContext(context);
  7. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void close() {
  2.   if (log.isTraceEnabled()) log.trace("XHR stream closing listener");
  3.   if (!closed) {
  4.    session.resetListener();
  5.    try {
  6.     rc.response().end();
  7.     rc.response().close();
  8.     closed = true;
  9.    } catch (IllegalStateException e) {
  10.     // Underlying connection might already be closed - that's fine
  11.    }
  12.   }
  13.  }
  14. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void close() {
  2.   if (log.isTraceEnabled()) log.trace("XHR poll closing listener");
  3.   if (!closed) {
  4.    try {
  5.     session.resetListener();
  6.     rc.response().end();
  7.     rc.response().close();
  8.     closed = true;
  9.    } catch (IllegalStateException e) {
  10.     // Underlying connection might already be closed - that's fine
  11.    }
  12.   }
  13.  }
  14. }

代码示例来源：origin: vert-x3/vertx-web

  1. static Handler<RoutingContext> createCORSOptionsHandler(SockJSHandlerOptions options, String methods) {
  2.  return rc -> {
  3.   if (log.isTraceEnabled()) log.trace("In CORS options handler");
  4.   rc.response().putHeader("Cache-Control", "public,max-age=31536000");
  5.   long oneYearSeconds = 365 * 24 * 60 * 60;
  6.   long oneYearms = oneYearSeconds * 1000;
  7.   String expires = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss zzz").format(new Date(System.currentTimeMillis() + oneYearms));
  8.   rc.response().putHeader("Expires", expires)
  9.    .putHeader("Access-Control-Allow-Methods", methods)
  10.    .putHeader("Access-Control-Max-Age", String.valueOf(oneYearSeconds));
  11.   setCORS(rc);
  12.   setJSESSIONID(options, rc);
  13.   rc.response().setStatusCode(204);
  14.   rc.response().end();
  15.  };
  16. }

代码示例来源：origin: vert-x3/vertx-web

  1. private Handler<RoutingContext> createIFrameHandler(String iframeHTML) {
  2.  String etag = getMD5String(iframeHTML);
  3.  return rc -> {
  4.   try {
  5.    if (log.isTraceEnabled()) log.trace("In Iframe handler");
  6.    if (etag != null && etag.equals(rc.request().getHeader("if-none-match"))) {
  7.     rc.response().setStatusCode(304);
  8.     rc.response().end();
  9.    } else {
  10.     long oneYear = 365 * 24 * 60 * 60 * 1000L;
  11.     String expires = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss zzz").format(new Date(System.currentTimeMillis() + oneYear));
  12.     rc.response().putHeader("Content-Type", "text/html; charset=UTF-8")
  13.      .putHeader("Cache-Control", "public,max-age=31536000")
  14.      .putHeader("Expires", expires).putHeader("ETag", etag).end(iframeHTML);
  15.    }
  16.   } catch (Exception e) {
  17.    log.error("Failed to server iframe", e);
  18.   }
  19.  };
  20. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void sendFrame(String body) {
  2.  if (log.isTraceEnabled()) log.trace("HtmlFile, sending frame");
  3.  if (!headersWritten) {
  4.   String htmlFile = HTML_FILE_TEMPLATE.replace("{{ callback }}", callback);
  5.   rc.response().putHeader("Content-Type", "text/html; charset=UTF-8");
  6.   setNoCacheHeaders(rc);
  7.   rc.response().setChunked(true);
  8.   setJSESSIONID(options, rc);
  9.   rc.response().write(htmlFile);
  10.   headersWritten = true;
  11.  }
  12.  body = escapeForJavaScript(body);
  13.  String sb = "<script>\np(\"" +
  14.   body +
  15.   "\");\n</script>\r\n";
  16.  Buffer buff = buffer(sb);
  17.  rc.response().write(buff);
  18.  bytesSent += buff.length();
  19.  if (bytesSent >= maxBytesStreaming) {
  20.   if (log.isTraceEnabled()) log.trace("More than maxBytes sent so closing connection");
  21.   // Reset and close the connection
  22.   close();
  23.  }
  24. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void sendFrame(String body) {
  2.  if (log.isTraceEnabled()) log.trace("EventSource, sending frame");
  3.  if (!headersWritten) {
  4.   // event stream data is always UTF8
  5.   // https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events#Event_stream_format
  6.   // no need to specify the character encoding
  7.   rc.response().putHeader("Content-Type", "text/event-stream");
  8.   setNoCacheHeaders(rc);
  9.   setJSESSIONID(options, rc);
  10.   rc.response().setChunked(true).write("\r\n");
  11.   headersWritten = true;
  12.  }
  13.  String sb = "data: " +
  14.   body +
  15.   "\r\n\r\n";
  16.  Buffer buff = buffer(sb);
  17.  rc.response().write(buff);
  18.  bytesSent += buff.length();
  19.  if (bytesSent >= maxBytesStreaming) {
  20.   if (log.isTraceEnabled()) log.trace("More than maxBytes sent so closing connection");
  21.   // Reset and close the connection
  22.   close();
  23.  }
  24. }

代码示例来源：origin: vert-x3/vertx-web

  1. private void handleSendMessage(RoutingContext rc, SockJSSession session, Buffer body) {
  2.  String msgs = body.toString();
  3.  if (msgs.equals("")) {
  4.   rc.response().setStatusCode(500);
  5.   rc.response().end("Payload expected.");
  6.   return;
  7.  }
  8.  if (!session.handleMessages(msgs)) {
  9.   sendInvalidJSON(rc.response());
  10.  } else {
  11.   rc.response().putHeader("Content-Type", "text/plain; charset=UTF-8");
  12.   setNoCacheHeaders(rc);
  13.   setJSESSIONID(options, rc);
  14.   setCORS(rc);
  15.   rc.response().setStatusCode(204);
  16.   rc.response().end();
  17.  }
  18.  if (log.isTraceEnabled()) log.trace("XHR send processed ok");
  19. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void sendFrame(String body) {
  2.  if (log.isTraceEnabled()) log.trace("XHR sending frame");
  3.  if (!headersWritten) {
  4.   HttpServerResponse resp = rc.response();
  5.   resp.putHeader("Content-Type", "application/javascript; charset=UTF-8");
  6.   setJSESSIONID(options, rc);
  7.   setCORS(rc);
  8.   if (rc.request().version() != HttpVersion.HTTP_1_0) {
  9.    resp.setChunked(true);
  10.   }
  11.   // NOTE that this is streaming!!!
  12.   // Client are not expecting to see Content-Length as we don't know it's value
  13.   headersWritten = true;
  14.  }
  15. }

代码示例来源：origin: vert-x3/vertx-web

  1. HtmlFileTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
  2.          Handler<SockJSSocket> sockHandler) {
  3.  super(vertx, sessions, options);
  4.  String htmlFileRE = COMMON_PATH_ELEMENT_RE + "htmlfile.*";
  5.  router.getWithRegex(htmlFileRE).handler(rc -> {
  6.   if (log.isTraceEnabled()) log.trace("HtmlFile, get: " + rc.request().uri());
  7.   String callback = rc.request().getParam("callback");
  8.   if (callback == null) {
  9.    callback = rc.request().getParam("c");
  10.    if (callback == null) {
  11.     rc.response().setStatusCode(500).end("\"callback\" parameter required\n");
  12.     return;
  13.    }
  14.   }
  15.   if (CALLBACK_VALIDATION.matcher(callback).find()) {
  16.    rc.response().setStatusCode(500);
  17.    rc.response().end("invalid \"callback\" parameter\n");
  18.    return;
  19.   }
  20.   HttpServerRequest req = rc.request();
  21.   String sessionID = req.params().get("param0");
  22.   SockJSSession session = getSession(rc, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  23.   session.register(req, new HtmlFileListener(options.getMaxBytesStreaming(), rc, callback, session));
  24.  });
  25. }

代码示例来源：origin: vert-x3/vertx-web

  1. @Override
  2. public void handle(RoutingContext context) {
  3.  HttpServerRequest request = context.request();
  4.  if (request.method() != HttpMethod.GET && request.method() != HttpMethod.HEAD) {
  5.   if (log.isTraceEnabled()) log.trace("Not GET or HEAD so ignoring request");
  6.   context.next();
  7.  } else {
  8.   String path = HttpUtils.removeDots(URIDecoder.decodeURIComponent(context.normalisedPath(), false));
  9.   // if the normalized path is null it cannot be resolved
  10.   if (path == null) {
  11.    log.warn("Invalid path: " + context.request().path());
  12.    context.next();
  13.    return;
  14.   }
  15.   // only root is known for sure to be a directory. all other directories must be identified as such.
  16.   if (!directoryListing && "/".equals(path)) {
  17.    path = indexPage;
  18.   }
  19.   // can be called recursive for index pages
  20.   sendStatic(context, path);
  21.  }
  22. }

代码示例来源：origin: vert-x3/vertx-web

  1. EventSourceTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
  2.            Handler<SockJSSocket> sockHandler) {
  3.  super(vertx, sessions, options);
  4.  String eventSourceRE = COMMON_PATH_ELEMENT_RE + "eventsource";
  5.  router.getWithRegex(eventSourceRE).handler(rc -> {
  6.   if (log.isTraceEnabled()) log.trace("EventSource transport, get: " + rc.request().uri());
  7.   String sessionID = rc.request().getParam("param0");
  8.   SockJSSession session = getSession(rc, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  9.   HttpServerRequest req = rc.request();
  10.   session.register(req, new EventSourceListener(options.getMaxBytesStreaming(), rc, session));
  11.  });
  12. }

代码示例来源：origin: vert-x3/vertx-web

  1. public void sendFrame(String body) {
  2.  if (log.isTraceEnabled()) log.trace("JsonP, sending frame");
  3.  if (!headersWritten) {
  4.   rc.response()
  5.    .setChunked(true)
  6.    // protect against SWF JSONP exploit
  7.    .putHeader("X-Content-Type-Options", "nosniff")
  8.    .putHeader("Content-Type", "application/javascript; charset=UTF-8");
  9.   setNoCacheHeaders(rc);
  10.   setJSESSIONID(options, rc);
  11.   headersWritten = true;
  12.  }
  13.  body = escapeForJavaScript(body);
  14.  // prepend comment to avoid SWF exploit https://github.com/sockjs/sockjs-node/issues/163
  15.  String sb = "/**/" + callback + "(\"" +
  16.   body +
  17.   "\");\r\n";
  18.  //End the response and close the HTTP connection
  19.  rc.response().write(sb);
  20.  close();
  21. }

代码示例来源：origin: vert-x3/vertx-web

  1. private void registerHandler(Router router, Handler<SockJSSocket> sockHandler, String re,
  2.                boolean streaming, SockJSHandlerOptions options) {
  3.  router.postWithRegex(re).handler(rc -> {
  4.   if (log.isTraceEnabled()) log.trace("XHR, post, " + rc.request().uri());
  5.   setNoCacheHeaders(rc);
  6.   String sessionID = rc.request().getParam("param0");
  7.   SockJSSession session = getSession(rc, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  8.   HttpServerRequest req = rc.request();
  9.   session.register(req, streaming? new XhrStreamingListener(options.getMaxBytesStreaming(), rc, session) : new XhrPollingListener(rc, session));
  10.  });
  11. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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