io.vertx.core.logging.Logger类的使用及代码示例

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

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

Logger介绍

[英]This class allows us to isolate all our logging dependencies in one place. It also allows us to have zero runtime 3rd party logging jar dependencies, since we default to JUL by default.

By default logging will occur using JUL (Java-Util-Logging). The logging configuration file (logging.properties) used by JUL will taken from the default logging.properties in the JDK installation if no java.util.logging.config.file system property is set.

If you would prefer to use Log4J or SLF4J instead of JUL then you can set a system property called vertx.logger-delegate-factory-class-name to the class name of the delegate for your logging system. For Log4J the value is io.vertx.core.logging.Log4jLogDelegateFactory, for SLF4J the value is io.vertx.core.logging.SLF4JLogDelegateFactory. You will need to ensure whatever jar files required by your favourite log framework are on your classpath.

Keep in mind that logging backends use different formats to represent replaceable tokens in parameterized messages. As a consequence, if you rely on parameterized logging methods, you won't be able to switch backends without changing your code.
[中]这个类允许我们在一个地方隔离所有日志依赖项。它还允许我们没有运行时第三方日志jar依赖项，因为我们默认为JUL。
默认情况下，将使用JUL（JavautilLogging）进行日志记录。JUL使用的日志配置文件（logging.properties）将取自默认日志。如果没有java，则JDK安装中的属性。util。登录中。配置。已设置文件系统属性。
如果您希望使用Log4J或SLF4J而不是JUL，那么可以设置一个名为vertx的系统属性。logger delegate factory类名为您的日志记录系统的代理的类名。对于Log4J，该值为io。维特斯。果心登录中。Log4jLogDelegateFactory，对于SLF4J，值为io。维特斯。果心登录中。SLF4JLogDelegateFactory。您需要确保您喜爱的日志框架所需的任何jar文件都位于类路径上。
请记住，日志后端使用不同的格式来表示参数化消息中的可替换令牌。因此，如果您依赖于参数化日志记录方法，您将无法在不更改代码的情况下切换后端。

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

  1. /**
  2.  * Undeploys  the previously deployed verticle.
  3.  *
  4.  * @param completionHandler the completion handler
  5.  */
  6. public void undeploy(Handler<AsyncResult<Void>> completionHandler) {
  7.  vertx.undeploy(deploymentId, res -> {
  8.   if (res.failed()) {
  9.    log.error("Failed in undeploying " + deploymentId, res.cause());
  10.   } else {
  11.    log.info("Succeeded in undeploying " + deploymentId);
  12.   }
  13.   deploymentId = null;
  14.   completionHandler.handle(res);
  15.  });
  16. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. private static void logInternal(final String perms) {
  2.  if (perms != null && log.isDebugEnabled()) {
  3.   log.debug("You are running on Windows and POSIX style file permissions are not supported");
  4.  }
  5. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. AtomicBoolean failed = new AtomicBoolean();
  2. for (Closeable hook : copy) {
  3.  Future<Void> a = Future.future();
  4.  a.setHandler(ar -> {
  5.   if (ar.failed()) {
  6.    if (failed.compareAndSet(false, true)) {
  7.     completionHandler.handle(Future.failedFuture(ar.cause()));
  8.     completionHandler.handle(Future.succeededFuture());
  9.   hook.close(a);
  10.  } catch (Throwable t) {
  11.   log.warn("Failed to run close hooks", t);
  12.   a.tryFail(t);
  13. completionHandler.handle(Future.succeededFuture());

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void deployHADeployments() {
  2.  int size = toDeployOnQuorum.size();
  3.  if (size != 0) {
  4.   log.info("There are " + size + " HA deploymentIDs waiting on a quorum. These will now be deployed");
  5.   Runnable task;
  6.   while ((task = toDeployOnQuorum.poll()) != null) {
  7.    try {
  8.     task.run();
  9.    } catch (Throwable t) {
  10.     log.error("Failed to run redeployment task", t);
  11.    }
  12.   }
  13.  }
  14. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void doDeployVerticle(final String verticleName, DeploymentOptions deploymentOptions,
  2.                final Handler<AsyncResult<String>> doneHandler) {
  3.  final Handler<AsyncResult<String>> wrappedHandler = ar1 -> {
  4.   vertx.<String>executeBlocking(fut -> {
  5.    if (ar1.succeeded()) {
  6.     // Tell the other nodes of the cluster about the verticle for HA purposes
  7.     String deploymentID = ar1.result();
  8.     addToHA(deploymentID, verticleName, deploymentOptions);
  9.     fut.complete(deploymentID);
  10.    } else {
  11.     fut.fail(ar1.cause());
  12.    }
  13.   }, false, ar2 -> {
  14.    if (doneHandler != null) {
  15.     doneHandler.handle(ar2);
  16.    } else if (ar2.failed()) {
  17.     log.error("Failed to deploy verticle", ar2.cause());
  18.    }
  19.   });
  20.  };
  21.  deploymentManager.deployVerticle(verticleName, deploymentOptions, wrappedHandler);
  22. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void removeSub(String subName, ClusterNodeInfo node, Handler<AsyncResult<Void>> completionHandler) {
  2.  subs.remove(subName, node, ar -> {
  3.   if (!ar.succeeded()) {
  4.    log.error("Failed to remove sub", ar.cause());
  5.   } else {
  6.    if (ar.result()) {
  7.     if (completionHandler != null) {
  8.      completionHandler.handle(Future.succeededFuture());
  9.     }
  10.    } else {
  11.     if (completionHandler != null) {
  12.      completionHandler.handle(Future.failedFuture("sub not found"));
  13.     }
  14.    }
  15.   }
  16.  });
  17. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. /**
  2.  * test socks4a proxy for accessing arbitrary server port using an already resolved address.
  3.  */
  4. @Test
  5. public void testWithSocks4LocalResolver() throws Exception {
  6.  NetClientOptions clientOptions = new NetClientOptions()
  7.    .setProxyOptions(new ProxyOptions().setType(ProxyType.SOCKS4).setPort(11080));
  8.  NetClient client = vertx.createNetClient(clientOptions);
  9.  server.connectHandler(sock -> {
  10.  });
  11.  proxy = new Socks4Proxy(null).start(vertx);
  12.  server.listen(1234, "localhost", ar -> {
  13.   assertTrue(ar.succeeded());
  14.   client.connect(1234, "127.0.0.1", ar2 -> {
  15.    if (ar2.failed()) {
  16.     log.warn("failed", ar2.cause());
  17.    }
  18.    assertTrue(ar2.succeeded());
  19.    // make sure we have gone through the proxy
  20.    assertEquals("127.0.0.1:1234", proxy.getLastUri());
  21.    testComplete();
  22.   });
  23.  });
  24.  await();
  25. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. bindFuture = AsyncResolveConnectHelper.doBind(vertx, socketAddress, bootstrap);
  2.  bindFuture.addListener(res -> {
  3.   if (res.succeeded()) {
  4.    Channel ch = res.result();
  5.    log.trace("Net server listening on " + (hostOrPath) + ":" + ch.localAddress());
  6.   vertx.runOnContext(v ->  listenHandler.handle(Future.failedFuture(t)));
  7.  } else {
  8.   log.error(t);
  9. if (listenHandler != null) {
  10.  AsyncResult<Void> ares;
  11.  if (res.succeeded()) {
  12.   ares = Future.succeededFuture();
  13.  } else {
  14.   listening = false;
  15.   ares = Future.failedFuture(res.cause());
  16.  listenContext.runOnContext(v -> listenHandler.handle(ares));
  17. } else if (res.failed()) {
  18.  log.error("Failed to listen", res.cause());
  19.  listening = false;

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void createHaManager(VertxOptions options, Handler<AsyncResult<Vertx>> resultHandler) {
  2.  this.<Map<String, String>>executeBlocking(fut -> {
  3.   fut.complete(clusterManager.getSyncMap(CLUSTER_MAP_NAME));
  4.  }, false, ar -> {
  5.   if (ar.succeeded()) {
  6.    Map<String, String> clusterMap = ar.result();
  7.    haManager = new HAManager(this, deploymentManager, clusterManager, clusterMap, options.getQuorumSize(), options.getHAGroup(), options.isHAEnabled());
  8.    startEventBus(resultHandler);
  9.   } else {
  10.    log.error("Failed to start HAManager", ar.cause());
  11.    resultHandler.handle(Future.failedFuture(ar.cause()));
  12.   }
  13.  });
  14. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void initializeHaManager(Handler<AsyncResult<Vertx>> resultHandler) {
  2.  this.executeBlocking(fut -> {
  3.   // Init the manager (i.e register listener and check the quorum)
  4.   // after the event bus has been fully started and updated its state
  5.   // it will have also set the clustered changed view handler on the ha manager
  6.   haManager.init();
  7.   fut.complete();
  8.  }, false, ar -> {
  9.   if (ar.succeeded()) {
  10.    if (metrics != null) {
  11.     metrics.vertxCreated(this);
  12.    }
  13.    resultHandler.handle(Future.succeededFuture(this));
  14.   } else {
  15.    log.error("Failed to initialize HAManager", ar.cause());
  16.    resultHandler.handle(Future.failedFuture(ar.cause()));
  17.   }
  18.  });
  19. }

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

  1. if (replyAddress != null) {
  2.  replyHandler = result -> {
  3.   if (result.succeeded()) {
  4.    Message message = result.result();
  5.    deliverMessage(sock, replyAddress, message);
  6.   } else {
  7.    ReplyException cause = (ReplyException) result.cause();
  8.    JsonObject envelope =
  9.     new JsonObject()
  10.      .put("type", "err")
  11.      .put("address", replyAddress)
  12.      .put("failureCode", cause.failureCode())
  13.      .put("failureType", cause.failureType().name())
  14.  replyHandler = null;
  15. if (log.isDebugEnabled()) {
  16.  log.debug("Forwarding message to address " + address + " on event bus");

代码示例来源：origin: eclipse-vertx/vert.x

  1. final String verticleName = failedVerticle.getString("verticle_name");
  2. final CountDownLatch latch = new CountDownLatch(1);
  3. final AtomicReference<Throwable> err = new AtomicReference<>();
  4. JsonObject options = failedVerticle.getJsonObject("options");
  5. try {
  6.  doDeployVerticle(verticleName, new DeploymentOptions(options), result -> {
  7.   if (result.succeeded()) {
  8.    log.info("Successfully redeployed verticle " + verticleName + " after failover");
  9.   } else {
  10.    log.error("Failed to redeploy verticle after failover", result.cause());
  11.    err.set(result.cause());

代码示例来源：origin: io.vertx/vertx-mail-service

  1. @Before
  2. public void startVerticle(TestContext testContext) {
  3.  Async async = testContext.async();
  4.  JsonObject config = new JsonObject("{\"config\":{\"address\":\"vertx.mail\",\"hostname\":\"localhost\",\"port\":1587}}");
  5.  DeploymentOptions deploymentOptions = new DeploymentOptions(config);
  6.  vertx.deployVerticle("io.vertx.ext.mail.MailServiceVerticle", deploymentOptions ,r -> {
  7.   if(r.succeeded()) {
  8.    log.info(r.result());
  9.    async.complete();
  10.   } else {
  11.    log.info("exception", r.cause());
  12.    testContext.fail(r.cause());
  13.   }
  14.  });
  15. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. completionHandler.handle(Future.succeededFuture());
  2. deploymentManager.undeployAll(ar1 -> {
  3.  HAManager haManager = haManager();
  4.  Future<Void> haFuture = Future.future();
  5.  if (haManager != null) {
  6.   this.executeBlocking(fut -> {
  7.    haManager.stop();
  8.    fut.complete();
  9.   }, false, haFuture);
  10.  } else {
  11.       if (res.failed()) {
  12.        log.error("Failure in shutting down server", res.cause());

代码示例来源：origin: eclipse-vertx/vert.x

  1. Vertx instance;
  2. if (isClustered()) {
  3.  log.info("Starting clustering...");
  4.  if (!Objects.equals(options.getClusterHost(), VertxOptions.DEFAULT_CLUSTER_HOST)) {
  5.   clusterHost = options.getClusterHost();
  6.   clusterHost = getDefaultAddress();
  7.   if (clusterHost == null) {
  8.    log.error("Unable to find a default network interface for clustering. Please specify one using -cluster-host");
  9.    return null;
  10.   } else {
  11.    log.info("No cluster-host specified so using address " + clusterHost);
  12.  try {
  13.   if (!latch.await(2, TimeUnit.MINUTES)) {
  14.    log.error("Timed out in starting clustered Vert.x");
  15.    return null;
  16.   log.error("Thread interrupted in startup");
  17.   Thread.currentThread().interrupt();
  18.   return null;
  19.  if (result.get().failed()) {
  20.   log.error("Failed to form cluster");
  21.   result.get().cause().printStackTrace();
  22.   return null;

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

  1. log.error("Will not send message, reply address is > 36 chars");
  2.  replyError(sock, "invalid_reply_address");
  3.  return;
  4. final boolean debug = log.isDebugEnabled();
  5. if (debug) {
  6.  log.debug("Received msg from client in bridge. address:" + address + " message:" + body);
  7.   if (webUser != null) {
  8.    authorise(curMatch, webUser, res -> {
  9.     if (res.succeeded()) {
  10.      if (res.result()) {
  11.       checkAndSend(send, address, body, headers, sock, replyAddress, null);
  12.      } else {
  13.       replyError(sock, "access_denied");
  14.       if (debug) {
  15.        log.debug("Inbound message for address " + address + " rejected because is not authorised");
  16.      log.error("Error in performing authorisation", res.cause());
  17.     log.debug("Inbound message for address " + address +
  18.      " rejected because it requires auth and user is not authenticated");
  19.   log.debug("Inbound message for address " + address + " rejected because there is no match");

代码示例来源：origin: eclipse-vertx/vert.x

  1. private void startEventBus(Handler<AsyncResult<Vertx>> resultHandler) {
  2.  eventBus.start(ar -> {
  3.   if (ar.succeeded()) {
  4.    initializeHaManager(resultHandler);
  5.   } else {
  6.    log.error("Failed to start event bus", ar.cause());
  7.    resultHandler.handle(Future.failedFuture(ar.cause()));
  8.   }
  9.  });
  10. }

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

  1. final boolean debug = log.isDebugEnabled();
  2. final String address = rawMsg.getString("address");
  3. if (address == null) {
  4.  replyError(sock, "missing_address");
  5.  return;
  6. } else if (address.length() > maxAddressLength) {
  7.  log.warn("Refusing to register as address length > max_address_length");
  8.  replyError(sock, "max_address_length_reached");
  9.  return;
  10.    if (curMatch.requiredAuthority != null) {
  11.     authorise(curMatch, sock.webUser(), res -> {
  12.      if (res.succeeded()) {
  13.       if (res.result()) {
  14.        checkAddAccceptedReplyAddress(msg);
  15.        deliverMessage(sock, address, msg);
  16.       } else {
  17.        if (debug) {
  18.         log.debug("Outbound message for address " + address + " rejected because auth is required and socket is not authed");
  19.       log.error(res.cause());
  20.     log.debug("Outbound message for address " + address + " rejected because there is no inbound match");
  21.   log.debug("Cannot register handler for address " + address + " because there is no inbound match");

代码示例来源：origin: de.braintags/vertx-util

  1. protected void undeployVerticle(TestContext context, AbstractVerticle verticle) {
  2.  LOGGER.debug("undeploying verticle " + verticle.deploymentID());
  3.  Async async = context.async();
  4.  vertx.undeploy(verticle.deploymentID(), result -> {
  5.   if (result.failed()) {
  6.    LOGGER.error(result.cause());
  7.    context.fail(result.cause());
  8.    async.complete();
  9.   } else {
  10.    LOGGER.debug("succeeded undeploying verticle " + verticle.deploymentID());
  11.    async.complete();
  12.   }
  13.  });
  14.  async.awaitSuccess();
  15.  LOGGER.debug("finished undeploying verticle " + verticle.deploymentID());
  16. }

代码示例来源：origin: eclipse-vertx/vert.x

  1. HttpServerOptions options = new HttpServerOptions();
  2. options.setHost("localhost").setPort(PORT);
  3. server = vertx.createHttpServer(options);
  4. server.requestHandler(request -> {
  5.  HttpMethod method = request.method();
  6.    NetClient netClient = vertx.createNetClient(netOptions);
  7.    netClient.connect(port, host, result -> {
  8.     if (result.succeeded()) {
  9.      NetSocket serverSocket = request.netSocket();
  10.      NetSocket clientSocket = result.result();
  11.      serverSocket.closeHandler(v -> clientSocket.close());
  12.      clientSocket.closeHandler(v -> serverSocket.close());
  13.    uri = forceUri;
  14.   HttpClient client = vertx.createHttpClient();
  15.   HttpClientRequest clientRequest = client.getAbs(uri, ar -> {
  16.    if (ar.succeeded()) {
  17.     HttpClientResponse resp = ar.result();
  18.     for (String name : resp.headers().names()) {
  19.    } else {
  20.     Throwable e = ar.cause();
  21.     log.debug("exception", e);
  22.     int status;
  23.     if (e instanceof UnknownHostException) {

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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