跳到主要内容

在webflux中如何使用缓存,缓存Mono和Flux

前言

在传统项目中,使用缓存框架对一个方法的返回做缓存那是再简单不过的事,缓存框架也是有多重选择,比如EHcache,Caffeine,jetcache,Guava Cache等等等。

但是当我真的把webflux应用到真实项目的时候才发现,因为响应式编程中的异步调度,几乎让所有的方法返回都套上了Mono<T>, Flux<T>,似乎之前的缓存框架没有那么简单能融合进项目中。

为此,我收集了常见的缓存框架对project-reactor(webflux中的响应式编程框架)支持,发现并没有我想的这么简单。

如下图:

框架名支持情况相关链接
ehcache不支持Possibility to provide asynchronous or reactive cache in future versions
jetcache不支持jetcache 支持 spring webflux 吗
reactor-extra最新版本已经停止更新reactor-addons
caffeine支持Reactive types support for @Cacheable methods 但是要求是spring 6.1M4版本之后

方法一:使用caffeine + spring @Cacheable

这种方式的集成度最好,而且有spring团队的背书,相信性能和安全性也是有保证的,但是可惜的是,需要spring 6.1 M4之后的版本。

使用方式:

@SpringBootApplication
@Configuration
@EnableCaching
public class MakeSomeToolsApplication {

public static void main(String[] args) {
SpringApplication.run(MakeSomeToolsApplication.class, args);
}

@Bean
public CaffeineCacheManager caffeineCache() {
CaffeineCacheManager caffeineCacheManager = new CaffeineCacheManager();
Caffeine<Object, Object> caffeine = Caffeine.newBuilder()
.expireAfterWrite(60, TimeUnit.MINUTES);
caffeineCacheManager.setCaffeine(caffeine);
caffeineCacheManager.setAsyncCacheMode(true);
return caffeineCacheManager;
}
}
  • 增加@EnableCaching注解
  • 注入bean CaffeineCacheManager,而且要设置setAsyncCacheMode 为true,这是必须的
  • Caffeine.newBuilder() 可以配置你的缓存策略

接着你就可以在方法上使用注解@Cacheable ,原汁原味,很丝滑。缺点是不够定制话,如果你之前有使用过@Cacheable,你就知道,它没法对某个方法的返回值设置过期时间,这些需要自己写代码进行扩展。

方法二:使用AOP实现

这里并不是让你自己写一套AOP拦截方法执行,然后设置缓存策略,而是已经有大佬帮我们写好,我们只需要使用就行。

仓库地址:https://github.com/shaikezr/async-cacheable

把这几个类复制到你的项目中,然后就能在方法上使用@AsyncCacheable

在项目启动的时候,就会自动根据你的配置设置对应缓存策略的,不过目前支持的特性并不多,只有如下三个:

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface AsyncCacheable {

String name() default "default1000Item5MinuteCache";

long maximumSize() default 1000L;

long expireAfterWriteSeconds() default 300L;

}

好消息是如果你想对其进行扩展并不难,只要你知道一些AOP的知识就能在AsyncCacheableMethodProcessor 中自己扩展,所以caffeine 支持的特性,都能在注解上加上。

这个项目相关的一些内容,如果你想知道的话:

Integration Support with Spring Webflux ?

还有高手!

方法一、二你都不满意,还有解决办法,完全的定制化,完全的自主可控。但是需要你有高深的代码能力了。

caffeine缓存的作者在项目中写了个例子,试图教会我们怎么把project-reactor和caffeine的AsyncCacheLoader完美的结合起来。看了一下感觉既需要对project-reactor非常熟练+对caffeine异步缓存相当了解才能写的比较完美。

链接:https://github.com/ben-manes/caffeine/tree/master/examples/coalescing-bulkloader-reactor