Guava 中的条件记忆

Question

我知道如何memoize a single object。但是，我只想在满足某些条件时才记住。我正在调用一项服务，该服务有时会返回不成功的响应。如果服务响应成功，我只想记住它。

MyResponse myResponse = myService.call()
boolean success = myResponse.isSuccessful();

我的缓存是这样创建的：

private Supplier<MyResponse> cache;

private void createCache() {
    this.cache = Suppliers
        .memoizeWithExpiration(myService::call, timeout,
            TimeUnit.MINUTES);
}

问题： 只有在使用传递给memoizeWithExpiration方法的供应商成功的情况下，是否可以以某种方式缓存响应？

---

我发现这样做的唯一解决方法是，在检索值时，首先调用cache.get()，检查存储在缓存中的对象是否成功，如果不是，再次调用createCache()清除它然后再次获得价值。这样，如果后续的服务调用返回一个有效的对象，它就会被存储，如果没有，每个后续的调用都会清除缓存并再次调用该服务。

 public MyResponse getResponse() {
    MyResponse myResponse = cache.get();
    if (myResponse.isSuccess()) {
      return myResponse;
    } else {
      createCache();
      return cache.get();
    }
  }

但是，在这个解决方案中，如果缓存是空的并且服务返回不成功的响应，它会立即被再次调用。

Answer 1

您可以在 Service 类或任何其他合适的地方创建一个方法 callUntilSuccess（这里我假设它在您的 Service 中）。您还可以在此方法中定义最大尝试次数，之后它将返回 null，因此您可以避免无限期地调用您的服务（此建议未在下面提供的代码中实现，但这样做很容易）。由于 Guava 方法需要一个供应商，您甚至可以使用此逻辑创建一个 lambda，并将其直接传递给 memoizeWithExpiration 方法。

public MyResponse callUntilSuccess() {

    MyResponse response = myService.call();
    while (!response.isSuccessful()) {
        response = myService.call();
    }
    return response;
}   

然后这样做memoization：

private void createCache() {
    this.cache = Suppliers
         .memoizeWithExpiration(myService::callUntilSuccess, timeout,
                TimeUnit.MINUTES);
}   

Answer 2

这就是你要找的吗？

    private void createCache() {
        this.cache = Suppliers.memoizeWithExpiration(
           Suppliers.compose(
               response -> (response.isSuccess() ? response : null),
               myService::call
           ),
           timeout,
           TimeUnit.MINUTES
        );
    }

在这里，它会缓存响应，或者为空，这取决于它是否成功。

更多关于compose的信息在这里https://github.com/google/guava/blob/master/guava/src/com/google/common/base/Suppliers.java#L45

编辑： 如果你需要在成功时缓存该值，而在失败时将缓存留空，同时返回失败的请求，那么你自己就差不多了，只需在getResponse 中更改返回逻辑，如下所示：

    public MyResponse getResponse() {
        final MyResponse myResponse = cache.get();
        if (!myResponse.isSuccess()) {
            this.createCache(); // clear cache
        }
        return myResponse; // don't call .get() again!
    }