Caffeine 缓存 动态的为每个值设置过期时间

引入jar

2.         <dependency>
3.             <groupId>org.springframework.boot</groupId>
4.             <artifactId>spring-boot-starter-cache</artifactId>
5.         </dependency>
6.         <dependency>
7.             <groupId>com.github.ben-manes.caffeine</groupId>
8.             <artifactId>caffeine</artifactId>
9.             <version>2.5.5</version>
10.         </dependency>
11.         <dependency>
12.             <groupId>org.checkerframework</groupId>
13.             <artifactId>checker-qual</artifactId>
14.             <version>3.5.0</version>
15.         </dependency>
16.         <dependency>
17.             <groupId>org.checkerframework</groupId>
18.             <artifactId>checker-compat-qual</artifactId>
19.             <version>2.5.5</version>
20.         </dependency>

复制代码

实现方法

1. import com.github.benmanes.caffeine.cache.Cache;
2. import com.github.benmanes.caffeine.cache.Caffeine;
3. import com.github.benmanes.caffeine.cache.Expiry;
4. import lombok.AllArgsConstructor;
5. import lombok.Data;
6. import lombok.NoArgsConstructor;
7. import org.checkerframework.checker.index.qual.NonNegative;
8. import org.checkerframework.checker.nullness.qual.NonNull;
9. import org.springframework.cache.annotation.EnableCaching;
10. import org.springframework.context.annotation.Configuration;
11. import org.springframework.stereotype.Component;
13. import java.util.*;
14. import java.util.concurrent.TimeUnit;
16. /**
17. * Caffeine本地内存缓存操作
18. */
19. @Component
20. public class CaffeineEntryCacheUtil {
21.     private Cache<String, CaffeineEntry> cache;
23.     /**
24.      * 初始化，创建可自定义控制过期时间的cache
25.      * l1是当前键剩余的时间
26.      *
27. //     * @param maximumSize
28.      */
29.     private CaffeineEntryCacheUtil() {
30.         Cache<String, CaffeineEntry> build = Caffeine.newBuilder()
31.                 .maximumSize(100)
32.                 .expireAfter(new Expiry<String, CaffeineEntry>() {
33.                     @Override
34.                     public long expireAfterCreate(@NonNull String s, @NonNull CaffeineEntry caffeineEntry, long l) {
35.                         return caffeineEntry.getExpireTime();
36.                     }
38.                     @Override
39.                     public long expireAfterUpdate(@NonNull String s, @NonNull CaffeineEntry caffeineEntry, long l, @NonNegative long l1) {
40.                         return caffeineEntry.getExpireTime();
41.                     }
43.                     @Override
44.                     public long expireAfterRead(@NonNull String s, @NonNull CaffeineEntry caffeineEntry, long l, @NonNegative long l1) {
45.                         if (caffeineEntry.isAccessFresh()) {
46.                             return caffeineEntry.getExpireTime();
47.                         }
48.                         return l1;
49.                     }
50.                 }).build();
51.         this.cache = build;
52.     }
54.     /**
55.      * 加入缓存，默认过期时间24小时且读后不刷新
56.      *
57.      * @param key
58.      * @param value
59.      */
60.     public void putIntoCache(String key, Object value) {
61.         putIntoCache(key, value, 24, TimeUnit.HOURS, false);
62.     }
64.     /**
65.      * 加入缓存，可指定过期时间，默认不刷新 默认是分钟
66.      *
67.      * @param key
68.      * @param value
69.      * @param duration
70.      */
71.     public void putIntoCache(String key, Object value, long duration) {
72.         putIntoCache(key, value, duration, TimeUnit.MINUTES, false);
73.     }
75.     /**
76.      * 加入缓存，可指定过期时间、读后是否刷新
77.      *
78.      * @param key
79.      * @param value
80.      * @param duration
81.      * @param timeUnit
82.      * @param accessFresh
83.      */
84.     public void putIntoCache(String key, Object value, long duration, TimeUnit timeUnit, boolean accessFresh) {
85.         CaffeineEntry caffeineEntry = new CaffeineEntry();
86.         caffeineEntry.setKey(key);
87.         caffeineEntry.setValue(value);
88.         caffeineEntry.setExpireTime(timeUnit.toNanos(duration));
89.         caffeineEntry.setAccessFresh(accessFresh);
90.         cache.put(key, caffeineEntry);
91.     }
93.     /**
94.      * 获取缓存对象
95.      *
96.      * @param key
97.      * @param clazz
98.      * @param <T>
99.      * @return
100.      */
101.     public <T> T getCacheObject(String key, Class<T> clazz) {
102.         final Object result = getCacheObject(key);
103.         return Objects.nonNull(result) ? clazz.cast(result) : null;
104.     }
106.     /**
107.      * 获取缓存集合
108.      *
109.      * @param key
110.      * @param clazz
111.      * @param <T>
112.      * @return
113.      */
114.     public <T> List<T> getCacheObjectList(String key, Class<T> clazz) {
115.         final Object result = getCacheObject(key);
116.         if (Objects.nonNull(result)) {
117.             Collection<?> collection = (Collection<?>) result;
118.             List<T> list = new ArrayList<>();
119.             collection.forEach(item -> list.add(clazz.cast(item)));
120.             return list;
121.         }
122.         return null;
123.     }
125.     /**
126.      * 获取基本缓存对象
127.      *
128.      * @param key
129.      * @return
130.      */
131.     public Object getCacheObject(String key) {
132.         final Object[] value = {null};
133.         Optional.ofNullable(cache.getIfPresent(key))
134.                 .ifPresent(item -> {
135.                     value[0] = item.getValue();
136.                 });
137.         return value[0];
138.     }
140.     /**
141.      * 删除单个缓存
142.      * @param key
143.      */
144.     public void deleteCacheObject(String key) {
145.         cache.invalidate(key); // 手动删除指定键的缓存项
146.     }
148.     /**
149.      * 删除所有缓存
150.      */
151.     public void deleteCacheObject() {
152.         cache.invalidateAll();
153.     }
156.     @Data
157.     @AllArgsConstructor
158.     @NoArgsConstructor
159.     static class CaffeineEntry {
160.         private String key;
161.         private Object value;
162.         private long expireTime;
163.         private boolean accessFresh;
164.     }
165. }

复制代码

调用访问

1.    @Resource
2.     private CaffeineEntryCacheUtil caffeineEntryCacheUtil;
4. public static void main(String[] args) {
5.          List<Class> cacheList = caffeineEntryCacheUtil.getCacheObject("name",List.class);
6.         if (cacheList != null && cacheList.size() != 0) {
7.             list=cacheList;
8.         } else {
9.             //实现查询数据
10.              list = null;
11.             //保存缓存
12.             caffeineEntryCacheUtil.putIntoCache("name",list);
13.         }
14.     }

复制代码

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。