0

我在尝试缓存 aMono返回的 a时遇到问题WebClient。代码是这样的：

public Mono<Token> authenticate() {
    return cachedTokenMono = cachedTokenMono
        .switchIfEmpty(
            Mono.defer(() -> 
                    getToken())
                    .cache(token ->
                               Duration.between(Instant.now(), token.getExpires().toInstant()),
                           (Throwable throwable) -> Duration.ZERO,
                           () -> Duration.ZERO));
}

目的是缓存Mono用于接收 a 的Token对象，直到令牌过期。令牌过期后，缓存Mono变为空并请求新令牌。这可以按预期工作，但不幸switchIfEmpty()的是实际上并没有“切换”，而是包装了源代码Mono。结果，随着越来越多的包装SwitchIfEmptyMono被创建，这会产生内存泄漏。在这种情况下，正确的模式是什么？有没有办法用新的代替空Mono的？

4

1 回答 1

5

你可以这样做：

private final Mono<Token> authenticateMono = getToken()
            .cache(
                    token -> Duration.between(Instant.now(), token.getExpires().toInstant()),
                    throwable -> Duration.ZERO,
                    () -> Duration.ZERO)

public Mono<Token> authenticate() {
    return authenticateMono;
}

这个想法是您Mono<Token>为每次调用返回相同的缓存实例authenticate()。.cache操作员确保为每个订阅检查缓存的结果。

具体来说：

  • 如果新订阅到达并且没有缓存值，则缓存操作符将订阅Mono<Token>返回的 from getToken()（这将触发令牌检索）。
  • 如果一个值已经被缓存，并且一个新的订阅在缓存超时之前到达，那么缓存操作符会将缓存的值发送给新的订阅者
  • 如果一个值已被缓存，并且在缓存超时后Mono<Token>有新的订阅到达，则缓存操作符将重新订阅返回的 from getToken()（这将触发令牌重新检索）。
  • 如果从Mono<Token>返回getToken()完成时出现异常，则该异常不会被缓存，因此会传播，并且下一个到达的订阅将再次重新触发令牌检索

这一切都假设：

  • getToken()在订阅者到达之前不做任何工作
  • getToken()检索每个订阅者的令牌
  • 您只需要一个用于所有订阅者的活动令牌

另请注意，根据您的用例，您可能希望令牌在其到期日期之前稍微到期，以解决时钟偏差。即在它实际到期之前抢先检索一个新令牌，以防止返回一个Token将在下游有机会使用它之前到期的令牌。

于 2019-11-14T22:37:00.380 回答