在Spring WebFlow中通过请求生命周期共享数据

Question

在Spring MVC中，我可以使用ThreadLocal通过请求在不同组件之间共享数据，当请求完成时数据将被自动清除。使用WebFlux，由于一个请求可以由多个线程处理，因此该解决方案将不起作用。如何实现类似的解决方案，以便最初一个WebFilter可以在请求上下文中设置一些数据，然后可以在控制器中访问和修改数据，以及请求经过的任何事件处理程序？

我尝试了订阅者Context，但它不起作用。这是我的代码。为什么这不起作用？是否有其他方法可以共享数据？

public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
    exchange.getResponse().beforeCommit(() -> {
        return Mono.subscriberContext()
         .map(context -> {
              context.hasKey("test"); // this returns false
         })
    }

    return Mono.subscriberContext()
        .map(context -> {context.put("test", "test");})
        .flatMap(chain.filter(exchange))
}

Answer 1

如果我没弄错的话，这是因为＜code＞beforeCommit（）订户。

要将值添加到请求的订阅者上下文中。试试这个：

chain.filter(exchange)
  .subscriberContext(context -> context.put("KEY", "VALUE"));

您还可以在ServerWebExchange属性中共享值。不过，这是Spring Web Flux而不是Reactor。例如：

exchange.getAttributes().put("KEY", "VALUE");

现在，您可以在应用程序中访问＜code＞ServerWebExchange

exchange.getAttributes().get("KEY");