在我的应用程序中，我使用的是 spring webflux，并且我正在使用 webclient 从某些 3rd 方 API 中检索详细信息。现在，我想将第一次 webClient 响应存储在内存缓存中，以便第二次可以直接从缓存中获取这些响应。我正在尝试在内存缓存机制和“咖啡因”中使用 Spring Boot。但没有一个按预期工作。应用程序.yml：
spring:
cache:
cache-names: employee
caffiene:
spec: maximumSize=200, expireAfterAccess=5m
EmployeeApplication.java：
@SpringBootApplication
@EnableCaching
public class EmployeeApplication{
public static void main(String[] args){
}
}
EmployeeController.java：employee/all它有一个从第 3 方 API 获取所有员工的休息端点。员工服务.java：
@Service
@Slf4j
public class EmployeeService{
@Autowired
private WebClient webClient;
@Autowired
private CacheManager cacheManager;
@Cacheable("employee")
public Mono<List<Employee>> getAllEmployee(){
log.info("inside employee service {}");
return webClient.get()
.uri("/employees/")
.retrieve()
.bodyToMono(Employee.class);
}
}
虽然我已经配置了缓存名称，但当我第二次点击 url 时，它正在调用服务方法。需要使用什么缓存机制来缓存 Mono 响应？请建议。
有几个选项可以缓存响应式发布者。
cacheAPI 缓存Mono定义的持续时间employeeService.getAllEmployee()
.cache(Duration.ofMinutes(60))
.flatMap(employees -> {
// process data
})
CacheMonofrom一起使用reactor-extra。如果您需要根据不同的输入缓存结果（例如多租户环境），此选项更适合这是 Guava 的示例，但您可以对其进行调整CacheManager
Cache<String, List<Employee>> cache = CacheBuilder.newBuilder()
.expireAfterWrite(cacheTtl)
.build();
Mono<List<Employee>> getEmployee(String tenant) {
return CacheMono.lookup(key -> Mono.justOrEmpty(cache.getIfPresent(key)).map(Signal::next), tenant)
.onCacheMissResume(() -> employeeService.getAllEmployee(tenant))
.andWriteWith((key, signal) -> Mono.fromRunnable(() ->
Optional.ofNullable(signal.get())
.ifPresent(value -> cache.put(key, value))
)
);
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句