reactor.util.Logger类的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(453)

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

Logger介绍

[英]Logger interface designed for internal Reactor usage.
[中]记录器接口设计用于内部反应堆使用。

代码示例

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. @Nullable
  3. public Consumer<? super Throwable> onErrorCall() {
  4.   boolean shouldLogAsDebug = level == Level.FINE && log.isDebugEnabled();
  5.   boolean shouldLogAsTrace = level == Level.FINEST && log.isTraceEnabled();
  6.   boolean shouldLogAsError = level != Level.FINE && level != Level.FINEST && log.isErrorEnabled();
  7.   if ((options & ON_ERROR) == ON_ERROR && (shouldLogAsError || shouldLogAsDebug ||
  8.       shouldLogAsTrace)) {
  9.     if (shouldLogAsTrace) {
  10.       return e -> {
  11.         log.trace(s, SignalType.ON_ERROR, e, source);
  12.         log.trace("", e);
  13.       };
  14.         log.debug(s, SignalType.ON_ERROR, e, source);
  15.         log.debug("", e);
  16.       };
  17.         log.error(s, SignalType.ON_ERROR, e, source);
  18.         log.error("", e);
  19.       };

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Structured logging with level adaptation and operator ascii graph if required.
  3.  *
  4.  * @param signalType the type of signal being logged
  5.  * @param signalValue the value for the signal (use empty string if not required)
  6.  */
  7. void log(SignalType signalType, Object signalValue) {
  8.   String line = fuseable ? LOG_TEMPLATE_FUSEABLE : LOG_TEMPLATE;
  9.   if (operatorLine != null) {
  10.     line = line + " " + operatorLine;
  11.   }
  12.   if (level == Level.FINEST) {
  13.     log.trace(line, signalType, signalValue);
  14.   }
  15.   else if (level == Level.FINE) {
  16.     log.debug(line, signalType, signalValue);
  17.   }
  18.   else if (level == Level.INFO) {
  19.     log.info(line, signalType, signalValue);
  20.   }
  21.   else if (level == Level.WARNING) {
  22.     log.warn(line, signalType, signalValue);
  23.   }
  24.   else if (level == Level.SEVERE) {
  25.     log.error(line, signalType, signalValue);
  26.   }
  27. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public boolean isInfoEnabled() {
  3.   return delegate.isInfoEnabled();
  4. }

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Reset the {@link #onHandleError(BiConsumer)} hook to the default no-op behavior.
  3.  */
  4. public static void resetOnHandleError() {
  5.   if (log.isDebugEnabled()) {
  6.     log.debug("Reset to factory defaults: onHandleError");
  7.   }
  8.   onHandleErrorHook = null;
  9. }

代码示例来源：origin: spring-cloud/spring-cloud-sleuth

  1. @Override
  2. public void onSubscribe(Subscription subscription) {
  3.   if (log.isTraceEnabled()) {
  4.     log.trace("On subscribe");
  5.   }
  6.   this.s = subscription;
  7.   try (Tracer.SpanInScope ws = this.tracer.withSpanInScope(this.span)) {
  8.     if (log.isTraceEnabled()) {
  9.       log.trace("On subscribe - span continued");
  10.     }
  11.     this.subscriber.onSubscribe(this);
  12.   }
  13. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void logErrorUsesErrorWhenInfo() {
  3.   Level level = Level.INFO;
  4.   Mono<String> source = Mono.error(new IllegalStateException("ignored"));
  5.   Logger mockLogger = Mockito.mock(Logger.class);
  6.   when(mockLogger.isErrorEnabled()).thenReturn(true);
  7.   when(mockLogger.isDebugEnabled()).thenReturn(true);
  8.   when(mockLogger.isTraceEnabled()).thenReturn(true);
  9.   SignalLogger<String> sl = new SignalLogger<>(source, null, level,
  10.       false, s -> mockLogger);
  11.   sl.onErrorCall().accept(new IllegalStateException("boom"));
  12.   verify(mockLogger, times(1)).isErrorEnabled();
  13.   verify(mockLogger, never()).isDebugEnabled();
  14.   verify(mockLogger, never()).isTraceEnabled();
  15.   verify(mockLogger, times(1)).error(Mockito.anyString(), (Object[]) Mockito.any());
  16.   verify(mockLogger, times(1)).error(Mockito.anyString(), (Throwable) Mockito.any());
  17.   verifyNoMoreInteractions(mockLogger);
  18. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void onSubscribe(Subscription s) {
  3.   Throwable e = new IllegalStateException("onSubscribe should not be used");
  4.   log.error("Unexpected call to Operators.emptySubscriber()", e);
  5. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void logErrorUsesDebugWhenFine() {
  3.   Level level = Level.FINE;
  4.   Mono<String> source = Mono.error(new IllegalStateException("ignored"));
  5.   Logger mockLogger = Mockito.mock(Logger.class);
  6.   when(mockLogger.isErrorEnabled()).thenReturn(true);
  7.   when(mockLogger.isDebugEnabled()).thenReturn(true);
  8.   when(mockLogger.isTraceEnabled()).thenReturn(true);
  9.   SignalLogger<String> sl = new SignalLogger<>(source, null, level,
  10.       false, s -> mockLogger);
  11.   sl.onErrorCall().accept(new IllegalStateException("boom"));
  12.   verify(mockLogger, never()).isErrorEnabled();
  13.   verify(mockLogger, times(1)).isDebugEnabled();
  14.   verify(mockLogger, never()).isTraceEnabled();
  15.   verify(mockLogger, times(1)).debug(Mockito.anyString(), (Object[]) Mockito.any());
  16.   verify(mockLogger, times(1)).debug(Mockito.anyString(), (Throwable) Mockito.any());
  17.   verifyNoMoreInteractions(mockLogger);
  18. }

代码示例来源：origin: io.projectreactor.ipc/reactor-netty

  1. @Override
  2. public void fireContextError(Throwable err) {
  3.   if (AbortedException.isConnectionReset(err)) {
  4.     if (log.isDebugEnabled()) {
  5.       log.debug("Connection closed remotely", err);
  6.     }
  7.   }
  8.   else if (log.isErrorEnabled()) {
  9.     log.error("Handler failure while no child channelOperation was present", err);
  10.   }
  11. }

代码示例来源：origin: io.projectreactor.ipc/reactor-ipc

  1. final boolean receive(long streamId,
  2.     StreamContext<?> ctx,
  3.     StreamOperationsImpl io) {
  4.   Publisher<?> p = producer(streamId, io);
  5.   try {
  6.     m.invoke(instance, ctx, p);
  7.   }
  8.   catch (Throwable ex) {
  9.     if (log.isErrorEnabled()) {
  10.       log.error("", ex);
  11.     }
  12.     io.sendCancel(streamId, ex.toString());
  13.   }
  14.   return true;
  15. }

代码示例来源：origin: reactor/reactor-core

  1. public void run() {
  2.   LOGGER.debug("expired {}", state);
  3.   @SuppressWarnings("unchecked")
  4.   Signal<T> emptyState = (Signal<T>) EMPTY;
  5.   state = emptyState;
  6. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void logErrorUsesTraceWhenFinest() {
  3.   Level level = Level.FINEST;
  4.   demonstrateLogError(); //added to the test suite so that sanity check can be done
  5.   Mono<String> source = Mono.error(new IllegalStateException("ignored"));
  6.   Logger mockLogger = Mockito.mock(Logger.class);
  7.   when(mockLogger.isErrorEnabled()).thenReturn(true);
  8.   when(mockLogger.isDebugEnabled()).thenReturn(true);
  9.   when(mockLogger.isTraceEnabled()).thenReturn(true);
  10.   SignalLogger<String> sl = new SignalLogger<>(source, null, level,
  11.       false, s -> mockLogger);
  12.   sl.onErrorCall().accept(new IllegalStateException("boom"));
  13.   verify(mockLogger, never()).isErrorEnabled();
  14.   verify(mockLogger, never()).isDebugEnabled();
  15.   verify(mockLogger, times(1)).isTraceEnabled();
  16.   verify(mockLogger, times(1)).trace(Mockito.anyString(), (Object[]) Mockito.any());
  17.   verify(mockLogger, times(1)).trace(Mockito.anyString(), (Throwable) Mockito.any());
  18.   verifyNoMoreInteractions(mockLogger);
  19. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void info(String msg, Throwable t) {
  3.   delegate.info(msg, t);
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void sampleTest() throws Exception {
  3.   CountDownLatch latch = new CountDownLatch(1);
  4.   Disposable top10every1second =
  5.    Flux.fromIterable(PULP_SAMPLE)
  6.        .publishOn(asyncGroup)
  7.        .flatMap(samuelJackson ->
  8.       Flux
  9.        .fromArray(samuelJackson.split(" "))
  10.        .publishOn(asyncGroup)
  11.        .filter(w -> !w.trim().isEmpty())
  12.        .doOnNext(i -> simulateLatency())
  13.     )
  14.        .window(Duration.ofSeconds(2))
  15.        .flatMap(s -> s.groupBy(w -> w)
  16.               .flatMap(w -> w.count().map(c -> Tuples.of(w.key(), c)))
  17.               .collectSortedList((a, b) -> -a.getT2().compareTo(b.getT2()))
  18.               .flatMapMany(Flux::fromIterable)
  19.               .take(10)
  20.               .doAfterTerminate(() -> LOG.info("------------------------ window terminated" +
  21.              "----------------------"))
  22.     )
  23.        .subscribe(
  24.      entry -> LOG.info(entry.getT1() + ": " + entry.getT2()),
  25.      error -> LOG.error("", error),
  26.           latch::countDown
  27.     );
  28.   awaitLatch(top10every1second, latch);
  29. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void warn(String msg) {
  3.   delegate.warn(msg);
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void trace(String msg, Throwable t) {
  3.   delegate.trace(msg, t);
  4. }

代码示例来源：origin: reactor/reactor-netty

  1. void log() {
  2.     if (log.isInfoEnabled()) {
  3.       log.info(COMMON_LOG_FORMAT, address, user, zonedDateTime,
  4.           method, uri, protocol, status, (contentLength > -1 ? contentLength : MISSING), port, duration());
  5.     }
  6.   }
  7. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public boolean isDebugEnabled() {
  3.   return delegate.isDebugEnabled();
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void isTraceEnabled() throws Exception {
  3.   assertThat(logger.isTraceEnabled()).isTrue();
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public boolean isErrorEnabled() {
  3.   return delegate.isErrorEnabled();
  4. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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