spring cache caffeine,

  spring cache caffeine,

  

目录

为什么要在应用程序中添加缓存?Spring Boot提供什么缓存支持?生成依赖缓存配置缓存方法结果测试缓存是否正常工作为什么缓存有时很危险缓存更新/失效缓存复制嵌入式缓存远程缓存服务器缓存自定义缓存关键条件cache @CachePut缓存失效在这篇博客中,我们将讨论如何使用Spring的缓存框架为任何Spring Boot应用添加基本的缓存支持,如果没有正确实现,我们还将讨论一些缓存问题。但最后但同样重要的是,我们将看看几个在现实场景中有用的缓存示例。

 

  00-1010在深入探讨如何给应用添加缓存之前,首先想到的问题是为什么我们需要在应用中使用缓存。

  假设有一个包含客户数据的应用程序,用户发出两个请求来获取客户数据(id=100)。

  这就是没有缓存时的情况。

  如您所见,对于每个请求,应用程序都要去数据库获取数据。从数据库中获取数据是一项成本高昂的操作,因为它涉及IO。

  但是,如果中间有一个缓存存储,可以短时间临时存储数据,那么可以将这些往返保存到数据库,在IO时保存。

  使用缓存时,上面的交互看起来是这样的。

  

为什么要在应用程序中添加缓存

 

  

在Spring Boot应用程序中实现缓存

SpringBoot只提供了一个缓存抽象,您可以使用它透明而轻松地将缓存添加到Spring应用程序中。它不提供实际的缓存存储。但是,它可以与不同类型的缓存提供者一起工作,如Ehcache、Hazelcast、Redis、Caffee等。SpringBoot的缓存抽象可以添加到方法中(使用注释)。基本上,在执行方法之前,Spring框架会检查方法数据是否已经被缓存。如果是,它将从缓存中获取数据。否则,它将执行该方法并缓存数据。它还提供了从缓存中更新或删除数据的抽象。在我们当前的博客中,我们将学习如何使用Caffeine添加缓存,这是一个基于Java8的高性能且接近最优的缓存库。您可以指定使用哪个缓存提供程序来设置application.yaml文件中的spring.cache.type属性。

 

  但是,如果没有提供属性,Spring将根据添加的库自动检测缓存提供者。

  

SpringBoot提供了什么缓存支持?

现在假设您已经启动并运行了基本的Spring boot应用程序,让我们添加缓存依赖项。

 

  打开build.gradle文件并添加以下依赖项以启用Spring Boot缓存

  compile( org . spring framework . boot 3360 spring-boot-starter-cache))接下来我们将添加对咖啡因的依赖。

  编译组: com.github.ben-manes .咖啡因,命名为: 咖啡因,版本: 2.8.5

  

添加生成依赖项

现在我们需要在Spring Boot应用程序中启用缓存。

 

  为此,我们需要创建一个配置类,并提供注释@EnableCaching。

  @ Configuration @ enable caching Public Class Cache Config { }现在这个类是一个空类,但是我们可以向它添加更多的配置(如果需要的话)。

  现在我们已经启用了缓存,让我们提供缓存名称和缓存属性的配置,例如缓存大小、缓存过期时间等。

  最简单的方法是在application.yaml中添加配置

  spring : Cache 3360 Cache-Names 3360客户、用户、角色Caffeine 3360 Spec : maximum size=500,ExpireAccess=60s上述配置执行以下操作

  将可用的缓存名称限制为客户、用户和角色。将最大缓存大小设置为500。当缓存中的对象数量达到此限制时,将根据缓存回收策略从缓存中删除这些对象。将缓存过期时间设置为1分钟。这意味着该项目将在添加到缓存1分钟后从缓存中删除。还有另一种方法来配置缓存,而不是在application.yaml文件中进行配置。

  存。

  您可以在缓存配置类中添加并提供一个CacheManagerBean,该Bean可以完成与上面在application.yaml中的配置完全相同的工作

  

@Beanpublic CacheManager cacheManager() { Caffeine<Object, Object> caffeineCacheBuilder = Caffeine.newBuilder() .maximumSize(500) .expireAfterAccess( 1, TimeUnit.MINUTES); CaffeineCacheManager cacheManager = new CaffeineCacheManager( "customers", "roles", "users"); cacheManager.setCaffeine(caffeineCacheBuilder); return cacheManager;}

在我们的代码示例中,我们将使用Java配置。

 

  我们可以在Java中做更多的事情,比如配置RemovalListener,当一个项从缓存中删除时执行RemovalListener,或者启用缓存统计记录,等等。

  

 

  

缓存方法结果

在我们使用的示例Spring boot应用程序中,我们已经有了以下API GET/API/v1/customer/{id}来检索客户记录。

 

  

 

  我们将向CustomerService类的getCustomerByd(longCustomerId)方法添加缓存。

  要做到这一点,我们只需要做两件事

  1. 将注释@CacheConfig(cacheNames=customers)添加到CustomerService

  提供此选项将确保CustomerService的所有可缓存方法都将使用缓存名称customers

  2. 向方法Optional getCustomerById(Long customerId)添加注释@Cacheable

  

@Service@Log4j2@CacheConfig(cacheNames = "customers")public class CustomerService { @Autowired private CustomerRepository customerRepository; @Cacheable public Optional<Customer> getCustomerById(Long customerId) { log.info("Fetching customer by id: {}", customerId); return customerRepository.findById(customerId); }}

另外,在方法getCustomerById()中添加一个LOGGER语句,以便我们知道服务方法是否得到执行,或者值是否从缓存返回。

 

  

 代码如下:log.info("Fetching customer by id: {}", customerId);

 

  

测试缓存是否正常工作

这就是缓存工作所需的全部内容。现在是测试缓存的时候了。

 

  启动您的应用程序,并点击客户获取url

  http://localhost:8080/api/v1/customer/

  在第一次API调用之后,您将在日志中看到以下行—Fetching customer by id

  但是,如果再次点击API,您将不会在日志中看到任何内容。这意味着该方法没有得到执行,并且从缓存返回客户记录。

  现在等待一分钟(因为缓存过期时间设置为1分钟)。

  一分钟后再次点击GETAPI,您将看到下面的语句再次被记录——通过id获取客户。

  这意味着客户记录在1分钟后从缓存中删除,必须再次从数据库中获取。

  

 

  

为什么缓存有时会很危险

 

  

缓存更新/失效

通常我们缓存GET调用,以提高性能。

 

  但我们需要非常小心的是缓存对象的更新/删除。

  

@CachePut@cacheexecute

如果未将@CachePut/@cacheexecute放入更新/删除方法中,GET调用中缓存返回的对象将与数据库中存储的对象不同。考虑下面的示例场景。

 

  

 

  如您所见,第二个请求已将人名更新为John Smith。但由于它没有更新缓存,因此从此处开始的所有请求都将从缓存中获取过时的个人记录(John Doe),直到该项在缓存中被删除/更新。

  

 

  

缓存复制

大多数现代web应用程序通常有多个应用程序节点,并且在大多数情况下都有一个负载平衡器,可以将用户请求重定向到一个可用的应用程序节点。

 

  

 

  这种类型的部署为应用程序提供了可伸缩性,任何用户请求都可以由任何一个可用的应用程序节点提供服务。

  在这些分布式环境(具有多个应用服务器节点)中,缓存可以通过两种方式实现

  应用服务器中的嵌入式缓存(正如我们现在看到的)远程缓存服务器

 

  

嵌入式缓存

嵌入式缓存驻留在应用程序服务器中,它随应用程序服务器启动/停止。由于每台服务器都有自己的缓存副本,因此对其缓存的任何更改/更新都不会自动反映在其他应用程序服务器的缓存中。

 

  考虑具有嵌入式缓存的多节点应用服务器的下面场景,其中用户可以根据应用服务器为其请求服务而得到不同的结果。

  

 

  正如您在上面的示例中所看到的,更新请求更新了Application Node2的数据库和嵌入式缓存。

  但是,Application Node1的嵌入式缓存未更新,并且包含过时数据。因此,Application Node1的任何请求都将继续服务于旧数据。

  要解决这个问题,您需要实现CACHE REPLICATION—其中任何一个缓存中的任何更新都会自动复制到其他缓存(下图中显示为蓝色虚线)

  

 

  

 

  

远程缓存服务器

解决上述问题的另一种方法是使用远程缓存服务器(如下所示)。

 

  

 

  然而,这种方法的最大缺点是增加了响应时间——这是由于从远程缓存服务器获取数据时的网络延迟(与内存缓存相比)

  

 

  

缓存自定义

到目前为止,我们看到的缓存示例是向应用程序添加基本缓存所需的唯一代码。

 

  然而,现实世界的场景可能不是那么简单,可能需要进行一些定制。在本节中,我们将看到几个这样的例子

  

 

  

缓存密钥

我们知道缓存是密钥、值对的存储。

 

  示例1:默认缓存键–具有单参数的方法

  最简单的缓存键是当方法只有一个参数,并且该参数成为缓存键时。在下面的示例中,Long customerId是缓存键

  

 

  示例2:默认缓存键–具有多个参数的方法

  在下面的示例中,缓存键是所有三个参数的SimpleKey–countryIdregionIdpersonId

  

 

  示例3:自定义缓存密钥

  在下面的示例中,我们将此人的emailAddress指定为缓存的密钥

  

 

  示例4:使用KeyGenerator的自定义缓存密钥

  让我们看看下面的示例–如果要缓存当前登录用户的所有角色,该怎么办。

  

 

  该方法中没有提供任何参数,该方法在内部获取当前登录用户并返回其角色。

  为了实现这个需求,我们需要创建一个如下所示的自定义密钥生成器

  

 

  然后我们可以在我们的方法中使用这个键生成器,如下所示。

  

 

  

 

  

条件缓存

在某些用例中,我们只希望在满足某些条件的情况下缓存结果

 

  示例1(支持java.util.Optional–仅当存在时才缓存)

  仅当结果中存在person对象时,才缓存person对象。

  

@Cacheable( value = "persons", unless = "#result?.id")public Optional<Person> getPerson(Long personId)

示例2(如果需要,by-pass缓存)

 

  

@Cacheable(value = "persons", condition="#fetchFromCache")public Optional<Person> getPerson(long personId, boolean fetchFromCache)

仅当方法参数fetchFromCache为true时,才从缓存中获取人员。通过这种方式,方法的调用方有时可以决定绕过缓存并直接从数据库获取值。

 

  示例3(基于对象属性的条件计算)

  仅当价格低于500且产品有库存时,才缓存产品。

  

@Cacheable( value="products", condition="#product.price<500", unless="#result.outOfStock")public Product findProduct(Product product)

 

  

@CachePut

我们已经看到@Cacheable用于将项目放入缓存。

 

  但是,如果该对象被更新,并且我们想要更新缓存,该怎么办?

  我们已经在前面的一节中看到,不更新缓存post任何更新操作都可能导致从缓存返回错误的结果。

  

@CachePut(key = "#person.id")public Person update(Person person)

但是如果@Cacheable@CachePut都将一个项目放入缓存,它们之间有什么区别?

 

  主要区别在于实际的方法执行

  

@Cacheable@CachePut

 

  

缓存失效

缓存失效与将对象放入缓存一样重要。

 

  当我们想要从缓存中删除一个或多个对象时,有很多场景。让我们看一些例子。

  例1

  假设我们有一个用于批量导入个人记录的API。

  我们希望在调用此方法之前,应该清除整个person缓存(因为大多数person记录可能会在导入时更新,而缓存可能会过时)。我们可以这样做如下

  

@CacheEvict( value = "persons", allEntries = true, beforeInvocation = true)public void importPersons()

例2

 

  我们有一个Delete Person API,我们希望它在删除时也能从缓存中删除Person记录。

  

@CacheEvict( value = "persons", key = "#person.emailAddress")public void deletePerson(Person person)

默认情况下@CacheEvict在方法调用后运行。

 

  到此这篇关于SpringBoot使用Caffeine实现缓存的示例代码的文章就介绍到这了,更多相关SpringBoot Caffeine缓存内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT!

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

相关文章阅读

  • spring编程式事务处理,spring编程事务
  • spring编程式事务处理,spring编程事务,详解Spring学习之编程式事务管理
  • spring的核心功能模块有几个,列举一些重要的spring模块
  • spring的核心功能模块有几个,列举一些重要的spring模块,七个Spring核心模块详解
  • spring注解和springmvc的注解,SpringMVC常用注解
  • spring注解和springmvc的注解,SpringMVC常用注解,详解springmvc常用5种注解
  • spring实现ioc的四种方法,spring的ioc的三种实现方式
  • spring实现ioc的四种方法,spring的ioc的三种实现方式,简单实现Spring的IOC原理详解
  • spring事务失效问题分析及解决方案怎么做,spring 事务失效情况
  • spring事务失效问题分析及解决方案怎么做,spring 事务失效情况,Spring事务失效问题分析及解决方案
  • spring5.0新特性,spring4新特性
  • spring5.0新特性,spring4新特性,spring5新特性全面介绍
  • spring ioc以及aop原理,springmvc aop原理
  • spring ioc以及aop原理,springmvc aop原理,深入浅析Spring 的aop实现原理
  • Spring cloud网关,spring cloud zuul作用
  • 留言与评论(共有 条评论)
       
    验证码: