Maison > Java > javaDidacticiel > Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

WBOY
Libérer: 2023-05-12 11:34:05
avant
1635 Les gens l'ont consulté

Pourquoi ajouter la mise en cache aux applications

Avant de découvrir comment ajouter la mise en cache aux applications, la première question qui nous vient à l'esprit est de savoir pourquoi nous devons utiliser la mise en cache dans les applications.

Supposons qu'il existe une application qui contient des données client et que l'utilisateur fasse deux requêtes pour obtenir les données du client (id=100).

C'est ce qui se passe sans mise en cache.

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

Comme vous pouvez le constater, pour chaque requête, l'application se rend dans la base de données pour récupérer les données. Obtenir des données à partir de la base de données est une opération coûteuse car elle implique des E/S.

Cependant, si vous disposez d'un magasin de cache au milieu où vous pouvez stocker temporairement des données pendant une courte période de temps, vous pouvez enregistrer ces allers-retours dans la base de données et les enregistrer au moment des IO.

Voici à quoi ressemble l'interaction ci-dessus lors de l'utilisation de la mise en cache.

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

Implémentation de la mise en cache dans les applications Spring Boot

Quelle prise en charge de la mise en cache SpringBoot fournit-elle ?

  • SpringBoot fournit uniquement une abstraction de cache que vous pouvez utiliser pour ajouter du cache de manière transparente et facile à votre application Spring.

  • Il ne fournit pas de véritable stockage de cache.

  • Cependant, il peut fonctionner avec différents types de fournisseurs de cache comme Ehcache, Hazelcast, Redis, Caffee, etc.

  • L'abstraction de la mise en cache de SpringBoot peut être ajoutée aux méthodes (à l'aide d'annotations)

  • Fondamentalement, avant d'exécuter la méthode, le framework Spring vérifiera si les données de la méthode sont déjà mises en cache

  • Si oui, il les récupérera à partir du cache Récupérer les données de.

  • Sinon, il exécutera la méthode et mettra en cache les données

  • Il fournit également une abstraction pour mettre à jour ou supprimer les données du cache.

  • Dans notre blog actuel, nous apprendrons comment ajouter une mise en cache à l'aide de Caffeine, une bibliothèque de mise en cache hautes performances et presque optimale basée sur Java 8.

Vous pouvez spécifier le fournisseur de cache à utiliser dans le fichier application.yaml en définissant la propriété spring.cache.type. application.yaml 文件中指定使用哪个缓存提供程序来设置 spring.cache.type 属性。

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

添加生成依赖项

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

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

compile('org.springframework.boot:spring-boot-starter-cache')
Copier après la connexion

接下来我们将添加对Caffeine的依赖

compile group: 'com.github.ben-manes.caffeine', name: 'caffeine', version: '2.8.5'
Copier après la connexion

缓存配置

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

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

@Configuration
@EnableCaching
public class CacheConfig {
     
}
Copier après la connexion

现在这个类是一个空类,但是我们可以向它添加更多配置(如果需要)。

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

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

spring:
  cache:
    cache-names: customers, users, roles
    caffeine:
      spec: maximumSize=500, expireAfterAccess=60s
Copier après la connexion

上述配置执行以下操作

  • 将可用缓存名称限制为客户、用户和角色。将最大缓存大小设置为500。

  • 当缓存中的对象数达到此限制时,将根据缓存逐出策略从缓存中删除对象。将缓存过期时间设置为1分钟。

  • 这意味着项目将在添加到缓存1分钟后从缓存中删除。

还有另一种配置缓存的方法,而不是在 application.yaml 文件中配置缓存。

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

@Bean
public 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;
}
Copier après la connexion

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

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

缓存方法结果

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

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

提供此选项将确保 CustomerService

Cependant, si aucun attribut n'est fourni, Spring détectera automatiquement le fournisseur de cache en fonction de la bibliothèque ajoutée. 🎜🎜Ajouter des dépendances de construction🎜🎜Maintenant, en supposant que vous disposez d'une application de démarrage Spring de base opérationnelle, ajoutons des dépendances de cache. 🎜🎜Ouvrez le fichier build.gradle et ajoutez les dépendances suivantes pour activer le cache de Spring Boot🎜
@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);
    }
}
Copier après la connexion
Copier après la connexion
🎜Ensuite, nous ajouterons une dépendance sur Caffeine🎜
 代码如下:log.info("Fetching customer by id: {}", customerId);
Copier après la connexion
Copier après la connexion
🎜Configuration du cache🎜🎜Maintenant, nous devons configurer Spring Boot Activez la mise en cache dans les applications de démarrage. 🎜🎜Pour cela, nous devons créer une classe de configuration et fournir l'annotation @EnableCaching . 🎜
@CachePut
@cacheexecute
Copier après la connexion
Copier après la connexion
🎜 Pour le moment, cette classe est une classe vide, mais nous pouvons y ajouter plus de configuration si nécessaire. 🎜🎜Maintenant que le cache est activé, fournissons la configuration du nom du cache et des propriétés du cache, telles que la taille du cache, le délai d'expiration du cache, etc. 🎜🎜Le moyen le plus simple est d'ajouter la configuration dans application.yaml< /code> 🎜 <div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:java;">@Cacheable( value = &quot;persons&quot;, unless = &quot;#result?.id&quot;) public Optional&lt;Person&gt; getPerson(Long personId)</pre><div class="contentsignin">Copier après la connexion</div></div><div class="contentsignin">Copier après la connexion</div></div>🎜La configuration ci-dessus fait ce qui suit🎜🎜🎜🎜Limite les noms de cache disponibles aux clients, utilisateurs et rôles. Définissez la taille maximale du cache sur 500. 🎜🎜🎜🎜Lorsque le nombre d'objets dans le cache atteint cette limite, les objets seront supprimés du cache conformément à la politique d'expulsion du cache. Définissez le délai d'expiration du cache sur 1 minute. 🎜🎜🎜🎜Cela signifie que l'élément sera supprimé du cache 1 minute après avoir été ajouté au cache. 🎜🎜🎜🎜Il existe une autre façon de configurer le cache au lieu de configurer le cache dans le fichier <code>application.yaml. 🎜🎜Vous pouvez ajouter et fournir un bean CacheManager dans la classe de configuration du cache, qui peut faire exactement le même travail que la configuration ci-dessus dans application.yaml 🎜
@Cacheable(value = "persons", condition="#fetchFromCache")
public Optional<Person> getPerson(long personId, boolean fetchFromCache)
Copier après la connexion
Copier après la connexion
🎜 Dans notre exemples de code, nous utiliserons la configuration Java. 🎜🎜Nous pouvons faire plus de choses en Java, comme configurer RemovalListener, exécuter RemovalListener lorsqu'un élément est supprimé du cache, ou activer la journalisation des statistiques du cache, etc. 🎜🎜Résultats de la méthode de cache🎜🎜Dans l'exemple d'application Spring Boot que nous utilisons, nous disposons déjà de l'API GET /API/v1/customer/{id} suivante pour récupérer les enregistrements client. 🎜🎜Comment SpringBoot utilise la caféine pour implémenter la mise en cache🎜🎜Nous appliquerons le Classe CustomerService La méthode getCustomerByd(longCustomerId) ajoute la mise en cache. 🎜🎜Pour ce faire, il suffit de faire deux choses🎜🎜1. Ajouter l'annotation @CacheConfig(cacheNames="customers") à la classe CustomerService🎜🎜 Fournir cette option garantira que toutes les méthodes pouvant être mises en cache de CustomerService utiliseront le nom de cache "clients" 🎜

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);
    }
}
Copier après la connexion
Copier après la connexion

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

 代码如下:log.info("Fetching customer by id: {}", customerId);
Copier après la connexion
Copier après la connexion

测试缓存是否正常工作

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

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

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

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

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

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

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

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

为什么缓存有时会很危险

缓存更新/失效

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

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

@CachePut
@cacheexecute
Copier après la connexion
Copier après la connexion

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

缓存复制

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

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

  • 远程缓存服务器

嵌入式缓存

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

远程缓存服务器

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

缓存自定义

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

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

缓存密钥

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

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

示例3:自定义缓存密钥

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

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

Comment SpringBoot utilise Caffeine pour implémenter la mise en cache

条件缓存

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

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

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

@Cacheable( value = "persons", unless = "#result?.id")
public Optional<Person> getPerson(Long personId)
Copier après la connexion
Copier après la connexion

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

@Cacheable(value = "persons", condition="#fetchFromCache")
public Optional<Person> getPerson(long personId, boolean fetchFromCache)
Copier après la connexion
Copier après la connexion

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

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

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

@Cacheable( 
   value="products", 
   condition="#product.price<500",
   unless="#result.outOfStock")
public Product findProduct(Product product)
Copier après la connexion

@CachePut

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

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

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

@CachePut(key = "#person.id")
public Person update(Person person)
Copier après la connexion

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

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

@Cacheable
@CachePut
Copier après la connexion

缓存失效

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

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

例1

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

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

@CacheEvict(
   value = "persons", 
   allEntries = true, 
   beforeInvocation = true)
public void importPersons()
Copier après la connexion

例2

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

@CacheEvict(
   value = "persons", 
   key = "#person.emailAddress")
public void deletePerson(Person person)
Copier après la connexion

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

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Étiquettes associées:
source:yisu.com
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal