Gemeinschaft Lernen Tools-Bibliothek Freizeit
suchen
Deutsch
Heim > Java > javaLernprogramm > So verwenden Sie die integrierte Caching-Tool-Klasse CacheManager unter SpringBoot

So verwenden Sie die integrierte Caching-Tool-Klasse CacheManager unter SpringBoot

王林
Freigeben： 2023-05-12 19:10:13
nach vorne
1438 Leute haben es durchsucht

1. Benutzerdefinierte Toolklassendefinition

rrree

2. SpringBoot integriert Open-Source-Cache-Komponenten

Cache-KomponenteHAZELCASTINFINISPAN „Verteilter Cache“ CACHE2K Mit Mit der Erweiterung von Bei Hardwaresystemen und Software-Upgrades nimmt der Status und die Anwendbarkeit des Caches in Anwendungen von Tag zu Tag zu. SpringBoot hat zu diesem Zweck eine Reihe allgemeiner Caching-Mechanismen (Spezifikationen) entwickelt. Diese Spezifikation hat zwei Schnittstellen der obersten Ebene entwickelt: Cache und CacheManager. nämlich Cache und Cache-Verwaltung: Durch die Implementierung von CacheManager und die Einführung von Cache-Komponenten können Sie den Cache bequem über Anmerkungen im SpringBoot-Projekt einrichten. Verwenden Sie die automatische Cache-Konfigurationsklasse von SpringBoot, um zu sehen, welche Cache-Komponenten unterstützt werden können wie folgt: 2. Cache-Annotation Funktion aktiviert die Annotation-Cache-Funktion, die im Allgemeinen der Projektstartklasse hinzugefügt wird Wenn ein Cache vorhanden ist, werden die Cache-Informationen zurückgegeben. Wenn sie nicht vorhanden sind, rufen Sie den Wert ab und fügen Sie ihn dem Cache hinzu. @CachePut
Typ
Verteilter Cache
Lokaler Cache 
package com.demo.utils;

import org.springframework.util.StringUtils;

import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * Description: 缓存工具类
 * 1.部分方法未验证，如有问题请自行修改
 * 2.其他方法请自行添加
 *
 * @Author: zhx & moon hongxu_1234@163.com
 * @Date: 2022-04-07 20:54
 * @version: V1.0.0
 */
public class Cache {

    /**
     * 屏蔽工具类的无参构造 避免工具类被实例化
     */
    private Cache(){}

    /**
     * 缓存留存期 30min 1H 24H
     */
    public static final long CACHE_HOLD_TIME_30M = 30 * 60 * 1000L;
    public static final long CACHE_HOLD_TIME_1H = 2 * CACHE_HOLD_TIME_30M;
    public static final long CACHE_HOLD_TIME_24H = 24 * CACHE_HOLD_TIME_1H;
    public static final long CACHE_HOLD_TIME_FOREVER = -1L;

    /**
     * 缓存容量、最少使用容量
     */
    private static final int CACHE_MAX_CAP = 1000;
    private static final int CLEAN_LRU_CAP = 800;

    /**
     * 缓存当前大小
     */
    private static AtomicInteger CACHE_CURRENT_SIZE = new AtomicInteger(0);

    /**
     * 缓存对象
     */
    private static final Map<String,Node> CACHE_MAP = new ConcurrentHashMap<>(CACHE_MAX_CAP);

    /**
     * 最少使用记录
     */
    private static final List<String> LRU_LIST = new LinkedList<>();

    /**
     * 自动清理标志位
     */
    private static volatile boolean CLEAN_RUN_FLAG = false;

    /**
     * 默认30MIN
     * @param key
     * @param val
     */
    public static void put(String key,Object val){
        put(key,val,CACHE_HOLD_TIME_30M);
    }

    /**
     * 添加永久缓存
     * @param key
     * @param val
     */
    public static void putForever(String key,Object val){
        put(key,val,CACHE_HOLD_TIME_FOREVER);
    }

    /**
     * 添加缓存
     * @param key
     * @param val
     * @param ttlTime
     */
    public static void put(String key,Object val,long ttlTime){
        if (!StringUtils.hasLength(key) || null == val){
            return;
        }
        checkSize();
        updateCacheLru(key);
        CACHE_MAP.put(key,new Node(val,ttlTime));
    }

    /**
     * 获取缓存信息
     * @param key
     * @param clazz
     * @param <T>
     * @return
     */
    public static <T> T get(String key,Class<T> clazz){
        if (!StringUtils.hasLength(key) || !CACHE_MAP.containsKey(key)){
            return null;
        }
        updateCacheLru(key);
        return (T) CACHE_MAP.get(key).getVal();
    }

    /**
     * 更新最近使用位置
     * @param key
     */
    private static void updateCacheLru(String key){
        synchronized (LRU_LIST){
            LRU_LIST.remove(key);
            LRU_LIST.add(0,key);
        }
    }

    /**
     * 删除,成功则容量-1
     * @param key
     */
    private static boolean remove(String key){
        Node node = CACHE_MAP.remove(key);
        if (null!=node){
            CACHE_CURRENT_SIZE.getAndDecrement();
            return true;
        }
        return false;
    }

    /**
     * 检查是否超过容量,先清理过期,在清理最少使用
     */
    private static void checkSize(){
        if (CACHE_CURRENT_SIZE.intValue() > CACHE_MAX_CAP){
            deleteTimeOut();
        }
        if (CACHE_CURRENT_SIZE.intValue() > CLEAN_LRU_CAP){
            deleteLru();
        }
    }

    /**
     * 删除最久未使用,尾部删除
     * 永久缓存不会被清除
     */
    private static void deleteLru(){
        synchronized (LRU_LIST){
            while (LRU_LIST.size() > CLEAN_LRU_CAP){
                int lastIndex = LRU_LIST.size() - 1;
                String key = LRU_LIST.get(lastIndex);
                if (!CACHE_MAP.get(key).isForever() && remove(key)){
                    LRU_LIST.remove(lastIndex);
                }
            }
        }
    }

    /**
     * 删除过期
     */
    private static void deleteTimeOut(){
        List<String> del = new LinkedList<>();
        for (Map.Entry<String,Node> entry:CACHE_MAP.entrySet()){
            if (entry.getValue().isExpired()){
                del.add(entry.getKey());
            }
        }
        for (String k:del){
            remove(k);
        }
    }

    /**
     * 缓存是否已存在,过期则删除返回False
     * @param key
     * @return
     */
    public static boolean contains(String key){
        if (CACHE_MAP.containsKey(key)){
            if (!CACHE_MAP.get(key).isExpired()){
                return true;
            }
            if (remove(key)){
                return false;
            }
            return true;
        }
        return false;
    }

    /**
     * 清空缓存
     */
    public static void clear(){
        CACHE_MAP.clear();
        CACHE_CURRENT_SIZE.set(0);
        LRU_LIST.clear();
    }

    /**
     * 重置自动清理标志
     * @param flag
     */
    public static void setCleanRunFlag(boolean flag){
        CLEAN_RUN_FLAG = flag;
    }

    /**
     * 自动清理过期缓存
     */
    private static void startAutoClean(){

        if (!CLEAN_RUN_FLAG){
            setCleanRunFlag(true);
            ScheduledExecutorService scheduledExecutor = new ScheduledThreadPoolExecutor(1);
            scheduledExecutor.scheduleAtFixedRate(()->{
                try {
                    Cache.setCleanRunFlag(true);
                    while (CLEAN_RUN_FLAG){
                        Cache.deleteTimeOut();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            },10,Cache.CACHE_HOLD_TIME_1H, TimeUnit.SECONDS);
        }
    }

    /**
     * 缓存对象类
     */
    public static class Node{
        /**
         * 缓存值
         */
        private Object val;
        /**
         * 过期时间
         */
        private long ttlTime;

        public Node(Object val,long ttlTime){
            this.val = val;
            if (ttlTime<0){
                this.ttlTime = ttlTime;
            }else{
                this.ttlTime = System.currentTimeMillis() + ttlTime;
            }
        }

        public Object getVal(){
            return this.val;
        }

        public boolean isExpired(){
            if (this.ttlTime<0){
                return false;
            }
            return System.currentTimeMillis() > this.ttlTime;
        }

        public boolean isForever(){
            if (this.ttlTime<0){
                return true;
            }
            return false;
        }

    }


}
Nach dem Login kopieren
Annotation
@EenableCacheing
@Cacheable
Fügen Sie den Cache hinzu, der zum Aktualisieren der Methode verwendet werden kann (erzwingen Sie die Methodenrückgabewert, der zum angegebenen Schlüssel hinzugefügt werden soll)


@CacheEvict

Löschen Sie den Cache

@ CachingBeim Paketieren werden die oben genannten Anmerkungen zur Funktion gepackt@CacheConfigAllgemein Konfigurationsanmerkung: Wenn Sie einen Cache für ein Objekt festlegen möchten, können Sie diese Anmerkung in der Klasse markieren, um den Cache-Namen und den Primärschlüsselgenerierungsserver usw. festzulegen. 1.Pom-Abhängigkeiten 
//org.springframework.boot.autoconfigure.cache.CacheConfigurations
static {
    Map<CacheType, String> mappings = new EnumMap<>(CacheType.class);
    mappings.put(CacheType.GENERIC, GenericCacheConfiguration.class.getName());
    mappings.put(CacheType.HAZELCAST, HazelcastCacheConfiguration.class.getName());
    mappings.put(CacheType.INFINISPAN, InfinispanCacheConfiguration.class.getName());
    mappings.put(CacheType.JCACHE, JCacheCacheConfiguration.class.getName());
    mappings.put(CacheType.COUCHBASE, CouchbaseCacheConfiguration.class.getName());
    mappings.put(CacheType.REDIS, RedisCacheConfiguration.class.getName());
    mappings.put(CacheType.CAFFEINE, CaffeineCacheConfiguration.class.getName());
    mappings.put(CacheType.CACHE2K, Cache2kCacheConfiguration.class.getName());
    mappings.put(CacheType.SIMPLE, SimpleCacheConfiguration.class.getName());
    mappings.put(CacheType.NONE, NoOpCacheConfiguration.class.getName());
    MAPPINGS = Collections.unmodifiableMap(mappings);
}
Nach dem Login kopieren
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>LenovoTest</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>19</maven.compiler.source>
        <maven.compiler.target>19</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <spring.version>3.0.0</spring.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>${spring.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-log4j2</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-cache</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>com.github.ben-manes.caffeine</groupId>
            <artifactId>caffeine</artifactId>
            <version>3.1.2</version>
        </dependency>
        
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.24</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.14.graal</version>
        </dependency>
    </dependencies>
</project>
Nach dem Login kopieren
Wenn der Cache-Implementierungstyp nicht über Yml angegeben wird, wird die Standardimplementierung verwendet.
server:
  port: 8088

spring:
  cache:
   type: caffeine

custom-caffeine:
  specs:
    ## 用户信息写入10S后过期
    userInfo: maximumSize=10,expireAfterWrite=10s
    ## 登陆信息写入5S后过期
    accessInfo: maximumSize=10,expireAfterWrite=5s
Nach dem Login kopieren
Verwenden Sie Cacheable, um zu versuchen, den Cache zu aktualisieren (geben Sie den vorhandenen Wert zurück).Verwenden Sie Cacheable erneut. Versuchen Sie, den Cache zu aktualisieren Cache (Sie können ihn aktualisieren, nachdem Sie ihn oben gelöscht haben)
3. Cache-Test (Koffein) Integrieren Caffeine über SpringBoot für relevante Versionsinformationen finden Sie unter Abhängigkeiten
2.Yml-Konfiguration (Cache-Implementierungstyp angeben) 4. Benutzerdefinierter Cache Konfiguration
5. Testklasse. Definieren Sie ein Benutzerobjekt. Testaufzeichnung Starten Sie das Projekt und fügen Sie erzwungenes Caching hinzu
Löschen Sie den Cache.

Automatischer Ablauftest, Benutzerinformationen über CachePut hinzufügen
Versuchen Sie, den Cache mit Cacheable zu aktualisieren, er wird nach 10 Sekunden wirksam

Danach 10 Sekunden

Cache-Objektinformationen

Das obige ist der detaillierte Inhalt vonSo verwenden Sie die integrierte Caching-Tool-Klasse CacheManager unter SpringBoot. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Verwandte Etiketten：
springboot cachemanager
Quelle：yisu.com
Vorheriger Artikel：So implementieren Sie ein chinesisches Schachspiel mit Java Nächster Artikel：So implementieren Sie eine dynamische Sprachwiedergabe basierend auf SpringBoot und Vue
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Neueste Artikel des Autors
Aktuelle Ausgaben
Die POST-Anfrage funktioniert einwandfrei, wenn Postman verwendet wird, jedoch nicht, wenn React Axios und das Spring Boot-Backend verwendet werden Von der Reaktionskonsole erhalte ich die Fehlermeldung „Ressource kann nicht geladen werde...
Aus 2024-04-05 13:07:01
0
1
396
SQL Server: Verwendung des CASE WHEN-Ausdrucks mit der WHERE-Klausel Ich habe ein neues SpringBoot-Projekt mit SQLServer und muss die nativen MySQL-Abfragen fü...
Aus 2024-04-03 14:46:55
0
1
351
Was sind die Architekturschichten einer Spring Boot + React + MySQL-Anwendung? Ich versuche, eine Dokumentation über die Anwendung zu schreiben, weiß aber nicht, wie ich...
Aus 2024-04-03 10:07:06
0
1
410
verwandte Themen
Mehr>
Beliebte Empfehlungen
Beliebte Tutorials
Mehr>
Verwandte Tutorials
Beliebte Empfehlungen
Aktuelle Kurse
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage