允许在Spring WebFlux中填充ServerWebExchange.logPrefix以进行UniqueRequestId日志记录

Question

Springwebflux提供处理程序，它接受ServerRequest并且是我们实现代码的地方。根据下面的文章，Spring有一个logid概念，它似乎是我所说的uniqueRequestId。当抛出异常时，框架将通过AbstracTerrorWebExceptionHandler/ServerWebExchange将LogID放入日志条目。我的情况涉及到有许多服务相互调用并共享一个uniqueRequestId。因此，我们不希望Spring生成这个ID，而是希望通过HTTP请求头（例如x-request-id）来设置logid。我的理由是，一个服务的日志可以与另一个服务的日志相关。我找不到关于如何实现这一点的文章。

一些相关的背景：我管理了一个90%的替代解决方案，通过将UniqueRequestId设置到MDC(ThreadLocal)中，然后基于此特性通过反应链传递UniqueRequestId到日志中（https://projectreactor.io/docs/core/release/reference/#context->请参见“Adding a Context to a reactive sequence”）。这适用于在我的反应序列+处理程序中处理的代码，但如果我的代码抛出exception或mono.error（...），那么似乎Spring WebFlux框架将日志分派到异步线程，因此MDC和上下文都丢失了。因此，我希望通过将我的UniqueRequestId插入LogID来解决最后的问题。

https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html#webflux-logging-id

Spring:Boot:2.4.1，Web+WebFlux:5.3.2

Answer 1

您是否希望使用uniqueRequestId为自己实现相关部分？

如果您只希望能够跟踪服务上或跨服务的处理，那么您应该查看跟踪解决方案，这些解决方案通常可以在应用程序性能监视库中找到。

我认为您可以使用spring-cloud-sleuth，只使用日志相关性(https://cloud.spring.io/spring-cloud-sleuth/reference/html/#only-sleuth-log-correlation)

Sleuth支持reactor（spring webflux）,它会自动添加一些数据到日志中

1. trace.id跟踪表示可能发生在多个服务上的操作或数据流。对我来说，这是您正在寻找的，该跟踪被发送到其他服务，以便它们在日志中重用它。允许您通过多个服务跟踪特定呼叫。
2. transaction.id事务表示同一服务内的操作或数据流。

例如（下面的代码不起作用，它只是给你一个想法）：

null

public class serviceA() {

  private final ServiceBClient serviceBClient;

  @Get
  public Flux<Cat> getSomething() {
    log.info('Calling serviceB');
    return serviceBClient
      .listAllCats()
      .then(() -> {    log.info('Called serviceB') });
  }

}

public class serviceB() {

  private final CatRepository catRepository;

  @Get
  public Flux<Cat> listCats() {
    log.info('Asking for cats');
    return catRepository.listAll()
     .doOnSuccess(() -> { log.info('Request success!') })
  }

}

[INFO] .... Calling serviceB, trace.id=1321313543121, transaction.id=123546   
[INFO] .... Called serviceB, trace.id=1321313543121, transaction.id=123546

[INFO] .... Asking for cats, trace.id=1321313543121, transaction.id=224465   
[INFO] .... Called serviceB, trace.id=1321313543121, transaction.id=224465

Sleuth还应该将trace.id添加到错误日志中