caffeine 与 reactor mono 一起使用产生的缓存错误问题

布满荆棘的人生 2024-03-24 17:29 57阅读 0赞

## 现象 ##

与reactor mono一起使用，发现get key时，返回的一直都是抛出的错误信息，没有预期中的如果cache loader 返回null 或 错误时，caffeine自动剔除key，重新加载，而是将一次cache loader返回的错误future记录下来了，后续每次都是返回这个错误future。

## 处理 ##

参考了一个下这个issue，其中有一段推荐使用的代码[AsyncLoadingCaches will cache Mono's in error. · Issue \#260 · ben-manes/caffeine · GitHub][AsyncLoadingCaches will cache Mono_s in error. _ Issue _260 _ ben-manes_caffeine _ GitHub]

public static <KEY, VALUE> Mono<VALUE> lookupAndWrite2(
    		AsyncLoadingCache<KEY, VALUE> cache, KEY key, Mono<VALUE> mono) {
    	return Mono.defer(() -> Mono.fromFuture(cache.get(key, (k, e) -> {
    		CompletableFuture<VALUE> future = mono.toFuture();
    		return future.whenCompleteAsync((r, t) -> {
    			if (t != null) {
    				cache.synchronous().invalidate(key);
    			}
    		}, e);
    	})));
    }

主要是这个，使用whenCompleteAsync判断返回的结果有没有错误，如果有错误，强制剔除一下 cache.synchronous().invalidate(key); ，把有错误的key剔除掉。

future.whenCompleteAsync((r, t) -> \{  
if (t != null) \{  
cache.synchronous().invalidate(key);  
\}  
\}, e);

这种错误在并发下会偶现，目前使用这种方式修改正在观察中..... 后续如果有错误再反馈上...

[AsyncLoadingCaches will cache Mono_s in error. _ Issue _260 _ ben-manes_caffeine _ GitHub]: https://github.com/ben-manes/caffeine/issues/260

发表评论取消回复

表情：

评论列表（有 0 条评论，57人围观）

还没有评论，来说两句吧...

相关阅读

相关 Caffeine本地缓存

自定义的缓存状态收集器的作用：每当缓存有操作发生时，不管是查询，加载，存入，都会使得缓存的某些状态指标发生改变，哪些状态指标发生了改变，就会自动触发收集器中对应的方法执行...

秒速五厘米/ 2024年05月23日 22:27/ 0 赞/ 60 阅读

相关 Java本地缓存之Caffeine的使用

文章目录一、什么是缓存二、缓存的作用三、缓存的优点四、为什么用缓存就更快？(表面理解) 五、缓

ゝ一世哀愁。/ 2024年04月01日 06:13/ 0 赞/ 200 阅读

相关 caffeine 与 reactor mono 一起使用产生的缓存错误问题

现象与reactor mono一起使用，发现get key时，返回的一直都是抛出的错误信息，没有预期中的如果cache loader 返回null 或错误时，caff

布满荆棘的人生/ 2024年03月24日 17:29/ 0 赞/ 58 阅读

相关 Caffeine本地缓存

1、Caffine简介 > 简单说，Caffine 是一款高性能的本地缓存组件 > 由下面三幅图可见：不管在并发读、并发写还是并发读写的场景下，Caffeine 的性

朱雀/ 2024年03月16日 10:46/ 0 赞/ 60 阅读

相关 Caffeine缓存使用

package com.study.caffeine_cache; import com.alibaba.fastjson.JSON; imp

Bertha 。/ 2023年10月09日 12:24/ 0 赞/ 8 阅读

相关 springboot之本地缓存（guava与caffeine）

1. 场景描述因项目要使用本地缓存，具体为啥不用redis等，就不讨论，记录下过程，希望能帮到需要的朋友。 2.解决方案 2.1 使用google的guava

旧城等待，/ 2023年06月06日 10:37/ 0 赞/ 56 阅读

相关 springboot学习(十二)：缓存caffeine的使用

说明在上篇博文中，我使用了guava作为spring的本地缓存，来实现在加载数据到本地的需求。在这个篇博文中，我将记录总结使用caffeine作为本地缓存。在sprin

女爷i/ 2022年03月27日 11:18/ 0 赞/ 1077 阅读

相关 Caffeine缓存

简介我们来看看 [Caffeine][] — 一个高性能的 Java 缓存库。缓存和 Map 之间的根本区别在于缓存可以回收存储的 item。回收策略为在指定时

爱被打了一巴掌/ 2021年11月10日 18:28/ 0 赞/ 438 阅读

相关异步请求使用reactor中mono和flux所遇到的问题

最近在项目升级改造的过程中，需要用到异步请求，技术选型为reactor的mono和flux，实际用的过程中遇到不少问题，简单记录一下，分享给大家避免踩同样的坑。项目需

谁践踏了优雅/ 2021年09月23日 06:00/ 0 赞/ 535 阅读

相关 Reactor3 Mono

1 Mono 创建 Mono.just(1).mergeWith(Flux.just(1, 2, 3)).subscribe(System.out::print)

迷南。/ 2021年09月16日 10:55/ 0 赞/ 395 阅读