org.slf4j.Logger.info()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.7k)|赞(0)|评价(0)|浏览(697)

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

Logger.info介绍

[英]Log a message at the INFO level.
[中]

代码示例

代码示例来源：origin: apache/kafka

  1. public void updateFailed(Throwable exception) {
  2.   // We depend on pending calls to request another metadata update
  3.   this.state = State.QUIESCENT;
  4.   if (exception instanceof AuthenticationException) {
  5.     log.warn("Metadata update failed due to authentication error", exception);
  6.     this.authException = (AuthenticationException) exception;
  7.   } else {
  8.     log.info("Metadata update failed", exception);
  9.   }
  10. }

代码示例来源：origin: iluwatar/java-design-patterns

  1. /**
  2.  * Stops logging clients. This is a blocking call.
  3.  */
  4. public void stop() {
  5.  service.shutdown();
  6.  if (!service.isTerminated()) {
  7.   service.shutdownNow();
  8.   try {
  9.    service.awaitTermination(1000, TimeUnit.SECONDS);
  10.   } catch (InterruptedException e) {
  11.    LOGGER.error("exception awaiting termination", e);
  12.   }
  13.  }
  14.  LOGGER.info("Logging clients stopped");
  15. }

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

  1. protected void logException() {
  2.   if (exception instanceof JobNotFoundException || exception instanceof ActivitiTaskAlreadyClaimedException) {
  3.     // reduce log level, because this may have been caused because of job deletion due to cancelActiviti="true"
  4.     log.info("Error while closing command context",
  5.          exception);
  6.   } else if (exception instanceof ActivitiOptimisticLockingException) {
  7.     // reduce log level, as normally we're not interested in logging this exception
  8.     log.debug("Optimistic locking exception : " + exception);
  9.   } else {
  10.     log.error("Error while closing command context",
  11.          exception);
  12.   }
  13. }

代码示例来源：origin: apache/storm

  1. private void print(List<List<Object>> keys, List<ValueUpdater> updaters) {
  2.   for (int i = 0; i < keys.size(); i++) {
  3.     ValueUpdater valueUpdater = updaters.get(i);
  4.     Object arg = ((CombinerValueUpdater) valueUpdater).getArg();
  5.     LOG.info("updateCount = {}, keys = {} => updaterArgs = {}", updateCount, keys.get(i), arg);
  6.   }
  7. }

代码示例来源：origin: thinkaurelius/titan

  1. private static IResultsConsumer[] getConsumersUnsafe(IResultsConsumer... additional) throws IOException {
  2.   List<IResultsConsumer> consumers = new ArrayList<IResultsConsumer>();
  3.   consumers.add(new XMLConsumer(new File("jub." + Math.abs(System.nanoTime()) + ".xml")));
  4.   consumers.add(new WriterConsumer()); // defaults to System.out
  5.   consumers.add(new CsvConsumer("target/jub.csv"));
  6.   if (null != System.getenv(ENV_EFFORT_GENERATE)) {
  7.     String file = getEffortFilePath();
  8.     Writer writer = new FileWriter(file, true);
  9.     log.info("Opened " + file + " for appending");
  10.     consumers.add(new TimeScaleConsumer(writer));
  11.   }
  12.   for (IResultsConsumer c : additional) {
  13.     consumers.add(c);
  14.   }
  15.   return consumers.toArray(new IResultsConsumer[consumers.size()]);
  16. }

代码示例来源：origin: ctripcorp/apollo

  1. @Override
  2. public void handleMessage(ReleaseMessage message, String channel) {
  3.  logger.info("message received - channel: {}, message: {}", channel, message);
  4.  String releaseMessage = message.getMessage();
  5.  if (!Topics.APOLLO_RELEASE_TOPIC.equals(channel) || Strings.isNullOrEmpty(releaseMessage)) {
  6.   return;
  7.  }
  8.  List<String> keys = STRING_SPLITTER.splitToList(releaseMessage);
  9.  //message should be appId+cluster+namespace
  10.  if (keys.size() != 3) {
  11.   logger.error("message format invalid - {}", releaseMessage);
  12.   return;
  13.  }
  14.  String appId = keys.get(0);
  15.  String cluster = keys.get(1);
  16.  String namespace = keys.get(2);
  17.  List<GrayReleaseRule> rules = grayReleaseRuleRepository
  18.    .findByAppIdAndClusterNameAndNamespaceName(appId, cluster, namespace);
  19.  mergeGrayReleaseRules(rules);
  20. }

代码示例来源：origin: opentripplanner/OpenTripPlanner

  1. /** Output this entire chain of rides. */
  2. public void dumpRideChain() {
  3.   List<Ride> rides = Lists.newLinkedList();
  4.   Ride ride = this;
  5.   while (ride != null) {
  6.     rides.add(0, ride);
  7.     ride = ride.previous;
  8.   }
  9.   LOG.info("Path from {} to {}", rides.get(0).from, rides.get(rides.size() - 1).to);
  10.   for (Ride r : rides) LOG.info("  {}", r.toString());
  11. }

代码示例来源：origin: apache/storm

  1. protected List<String> calculateParititionIdsToOwn() {
  2.     List<String> taskPartitions = new ArrayList<String>();
  3.     for (int i = this.taskIndex; i < config.getPartitionCount(); i += this.totalTasks) {
  4.       taskPartitions.add(Integer.toString(i));
  5.       logger.info(String.format("taskIndex %d owns partitionId %d.", this.taskIndex, i));
  6.     }
  8.     return taskPartitions;
  9.   }
  10. }

代码示例来源：origin: apache/flink

  1. @Override
  2.   public void log (int level, String category, String message, Throwable ex) {
  3.     final String logString = "[KRYO " + category + "] " + message;
  4.     switch (level) {
  5.       case Log.LEVEL_ERROR:
  6.         log.error(logString, ex);
  7.         break;
  8.       case Log.LEVEL_WARN:
  9.         log.warn(logString, ex);
  10.         break;
  11.       case Log.LEVEL_INFO:
  12.         log.info(logString, ex);
  13.         break;
  14.       case Log.LEVEL_DEBUG:
  15.         log.debug(logString, ex);
  16.         break;
  17.       case Log.LEVEL_TRACE:
  18.         log.trace(logString, ex);
  19.         break;
  20.     }
  21.   }
  22. }

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

  1. public void close() {
  2.   closed = true;
  3.   if (serverSocket != null) {
  4.     try {
  5.       serverSocket.close();
  6.     } catch (IOException e) {
  7.       logger.error("Failed to close serverSocket", e);
  8.     } finally {
  9.       serverSocket = null;
  10.     }
  11.   }
  12.   logger.info("closing this server");
  13.   synchronized (socketNodeList) {
  14.     for (SocketNode sn : socketNodeList) {
  15.       sn.close();
  16.     }
  17.   }
  18.   if (socketNodeList.size() != 0) {
  19.     logger.warn("Was expecting a 0-sized socketNodeList after server shutdown");
  20.   }
  21. }

代码示例来源：origin: alibaba/canal

  1. private void notifyStart(File instanceDir, String destination, File[] instanceConfigs) {
  2.   try {
  3.     defaultAction.start(destination);
  4.     actions.put(destination, defaultAction);
  5.     // 启动成功后记录配置文件信息
  6.     InstanceConfigFiles lastFile = lastFiles.get(destination);
  7.     List<FileInfo> newFileInfo = new ArrayList<FileInfo>();
  8.     for (File instanceConfig : instanceConfigs) {
  9.       newFileInfo.add(new FileInfo(instanceConfig.getName(), instanceConfig.lastModified()));
  10.     }
  11.     lastFile.setInstanceFiles(newFileInfo);
  12.     logger.info("auto notify start {} successful.", destination);
  13.   } catch (Throwable e) {
  14.     logger.error(String.format("scan add found[%s] but start failed", destination), e);
  15.   }
  16. }

代码示例来源：origin: Atmosphere/atmosphere

  1. public static void interceptorsForHandler(AtmosphereFramework framework, List<Class<? extends AtmosphereInterceptor>> interceptors, List<AtmosphereInterceptor> l) {
  2.   for (Class<? extends AtmosphereInterceptor> i : interceptors) {
  3.     if (!framework.excludedInterceptors().contains(i.getName())
  4.         && (!AtmosphereFramework.DEFAULT_ATMOSPHERE_INTERCEPTORS.contains(i))) {
  5.       try {
  6.         logger.info("Adding {}", i);
  7.         l.add(framework.newClassInstance(AtmosphereInterceptor.class, i));
  8.       } catch (Throwable e) {
  9.         logger.warn("", e);
  10.       }
  11.     }
  12.   }
  13. }

代码示例来源：origin: apache/flink

  1. @Override
  2. public void initializeState(StateInitializationContext context) throws Exception {
  3.   super.initializeState(context);
  4.   checkState(checkpointedState == null,    "The reader state has already been initialized.");
  5.   checkpointedState = context.getOperatorStateStore().getSerializableListState("splits");
  6.   int subtaskIdx = getRuntimeContext().getIndexOfThisSubtask();
  7.   if (context.isRestored()) {
  8.     LOG.info("Restoring state for the {} (taskIdx={}).", getClass().getSimpleName(), subtaskIdx);
  9.     // this may not be null in case we migrate from a previous Flink version.
  10.     if (restoredReaderState == null) {
  11.       restoredReaderState = new ArrayList<>();
  12.       for (TimestampedFileInputSplit split : checkpointedState.get()) {
  13.         restoredReaderState.add(split);
  14.       }
  15.       if (LOG.isDebugEnabled()) {
  16.         LOG.debug("{} (taskIdx={}) restored {}.", getClass().getSimpleName(), subtaskIdx, restoredReaderState);
  17.       }
  18.     }
  19.   } else {
  20.     LOG.info("No state to restore for the {} (taskIdx={}).", getClass().getSimpleName(), subtaskIdx);
  21.   }
  22. }

代码示例来源：origin: apache/hive

  1. static void logException(String msg, Exception e) {
  2.  if (LOG.isDebugEnabled()) {
  3.   LOG.debug(msg, e);
  4.  } else {
  5.   LOG.info(msg + ": " + e.getMessage());
  6.  }
  7. }

代码示例来源：origin: apache/hbase

  1. TableDescriptor[] getTableDescriptors(List<TableName> tableNames) {
  2.   LOG.info("getTableDescriptors == tableNames => " + tableNames);
  3.  try (Connection conn = ConnectionFactory.createConnection(getConf());
  4.    Admin admin = conn.getAdmin()) {
  5.   List<TableDescriptor> tds = admin.listTableDescriptors(tableNames);
  6.   return tds.toArray(new TableDescriptor[tds.size()]);
  7.  } catch (IOException e) {
  8.   LOG.debug("Exception getting table descriptors", e);
  9.  }
  10.  return new TableDescriptor[0];
  11. }

代码示例来源：origin: eirslett/frontend-maven-plugin

  1. @Override
  2.   protected void processLine(final String line, final int logLevel) {
  3.     if (logLevel == 0) {
  4.       logger.info(line);
  5.     } else {
  6.       if (line.startsWith("npm WARN ")) {
  7.         logger.warn(line);
  8.       } else {
  9.         logger.error(line);
  10.       }
  11.     }
  12.   }
  13. }

代码示例来源：origin: apache/storm

  1. protected void rotateOutputFile(Writer writer) throws IOException {
  2.   LOG.info("Rotating output file...");
  3.   long start = System.currentTimeMillis();
  4.   synchronized (this.writeLock) {
  5.     writer.close();
  6.     LOG.info("Performing {} file rotation actions.", this.rotationActions.size());
  7.     for (RotationAction action : this.rotationActions) {
  8.       action.execute(this.fs, writer.getFilePath());
  9.     }
  10.   }
  11.   long time = System.currentTimeMillis() - start;
  12.   LOG.info("File rotation took {} ms.", time);
  13. }

代码示例来源：origin: apache/kafka

  1. private boolean threadShouldExit(long now, long curHardShutdownTimeMs) {
  2.   if (!hasActiveExternalCalls()) {
  3.     log.trace("All work has been completed, and the I/O thread is now exiting.");
  4.     return true;
  5.   }
  6.   if (now >= curHardShutdownTimeMs) {
  7.     log.info("Forcing a hard I/O thread shutdown. Requests in progress will be aborted.");
  8.     return true;
  9.   }
  10.   log.debug("Hard shutdown in {} ms.", curHardShutdownTimeMs - now);
  11.   return false;
  12. }

代码示例来源：origin: apache/hbase

  1. @Override
  2.  public void run() {
  3.   try {
  4.    LOG.info("Hook closing fs=" + this.fs);
  5.    this.fs.close();
  6.   } catch (NullPointerException npe) {
  7.    LOG.debug("Need to fix these: " + npe.toString());
  8.   } catch (IOException e) {
  9.    LOG.warn("Running hook", e);
  10.   }
  11.  }
  12. }

代码示例来源：origin: apache/geode

  1. @Override
  2. protected void rebalanceCache() {
  3.  try {
  4.   getLogger().info("Rebalancing: " + this.cache);
  5.   RebalanceResults results = RegionHelper.rebalanceCache(this.cache);
  6.   if (getLogger().isDebugEnabled()) {
  7.    getLogger().debug("Done rebalancing: " + this.cache);
  8.    getLogger().debug(RegionHelper.getRebalanceResultsMessage(results));
  9.   }
  10.  } catch (Exception e) {
  11.   getLogger().warn("Rebalance failed because of the following exception:", e);
  12.  }
  13. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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