在Spring WebFlux web应用程序中缓存WebClient调用的单声道结果

Question

我希望缓存一个单字（只有在成功的情况下），这是WebClient调用的结果。

通过阅读reactor addons项目文档，我不觉得CacheMono是一个很好的适合，因为它也缓存了错误，这是我不想要的。

因此，我不使用cachemono，而是执行以下操作：

Cache<MyRequestObject, Mono<MyResponseObject>> myCaffeineCache = 
    Caffeine.newBuilder()
            .maximumSize(100)
            .expireAfterWrite(Duration.ofSeconds(60))
            .build();

MyRequestObject myRequestObject = ...;

Mono<MyResponseObject> myResponseObject = myCaffeineCache.get(myRequestObject,
    requestAsKey -> WebClient.create()
                             .post()
                             .uri("http://www.example.com")
                             .syncBody(requestAsKey)
                             .retrieve()
                             .bodyToMono(MyResponseObject.class)
                             .cache()
                             .doOnError(t -> myCaffeineCache.invalidate(requestAsKey)));

Answer 1

这是少数几个实际允许调用非反应库并用反应类型包装它们的用例之一，并在doonxyz等副作用操作符中进行处理，因为：

• 咖啡因是内存中的缓存，所以据我所知不涉及I/O
• 缓存通常不能为缓存值提供强有力的保证（这是非常“开火就忘了”）

在本例中，您可以查询缓存以查看是否存在缓存版本（包装并立即返回），并在doon运算符中缓存成功的实际响应，如下所示：

public class MyService {

    private WebClient client;

    private Cache<MyRequestObject, MyResponseObject> myCaffeineCache;

    public MyService() {
        this.client = WebClient.create();
        this.myCaffeineCache = Caffeine.newBuilder().maximumSize(100)
          .expireAfterWrite(Duration.ofSeconds(60)).build();
    }

    public Mono<MyResponseObject> fetchResponse(MyRequestObject request) {

        MyResponseObject cachedVersion = this.myCaffeineCache.get(myRequestObject);
        if (cachedVersion != null) {
           return Mono.just(cachedVersion);
        } else {
           return this.client.post()
                         .uri("http://www.example.com")
                         .syncBody(request.getKey())
                         .retrieve()
                         .bodyToMono(MyResponseObject.class)
                         .doOnNext(response -> this.myCaffeineCache.put(request.getKey(), response));
    }
}