温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Java本地缓存工具LoadingCache怎么使用

发布时间:2022-01-05 16:04:47 来源:亿速云 阅读:315 作者:iii 栏目:开发技术

这篇文章主要介绍“Java本地缓存工具LoadingCache怎么使用”,在日常操作中,相信很多人在Java本地缓存工具LoadingCache怎么使用问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java本地缓存工具LoadingCache怎么使用”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

环境依赖

先添加maven依赖

        <dependency>             <groupId>com.google.guava</groupId>             <artifactId>guava</artifactId>             <version>30.1.1-jre</version>         </dependency>         <dependency>             <groupId>cn.hutool</groupId>             <artifactId>hutool-all</artifactId>             <version>5.5.2</version>         </dependency>         <dependency>             <groupId>org.projectlombok</groupId>             <artifactId>lombok</artifactId>             <optional>true</optional>         </dependency>

代码

不废话,上代码了。

package ai.guiji.csdn.tools;   import cn.hutool.core.thread.ThreadUtil; import com.google.common.cache.*; import lombok.extern.slf4j.Slf4j;   import java.text.MessageFormat; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.function.Consumer; import java.util.function.Function; import java.util.stream.LongStream;   /** @Author 剑客阿良_ALiang @Date 2021/12/30 17:57 @Description: 缓存工具 */ @Slf4j public class CacheUtils {     private static LoadingCache<Long, String> cache;     /**    * 初始化缓存方法    *    * @param totleCount 缓存池上限    * @param overtime 超时时间    * @param unit 时间单位    * @param handleNotExist 处理不存在key方法    * @param handleRemove 移除主键消费    */   private static void initCache(       Integer totleCount,       Integer overtime,       TimeUnit unit,       Function<Long, String> handleNotExist,       Consumer<Long> handleRemove) {     cache =         CacheBuilder.newBuilder()             // 缓存池大小             .maximumSize(totleCount)             // 设置时间对象没有被读/写访问则对象从内存中删除             .expireAfterWrite(overtime, unit)             // 移除监听器             .removalListener(                 new RemovalListener<Long, String>() {                   @Override                   public void onRemoval(RemovalNotification<Long, String> rn) {                     handleRemove.accept(rn.getKey());                   }                 })             .recordStats()             .build(                 new CacheLoader<Long, String>() {                   @Override                   public String load(Long aLong) throws Exception {                     return handleNotExist.apply(aLong);                   }                 });     log.info("初始化缓存");   }     /**    * 存入缓存    *    * @param key 键    * @param value 值    */   public static void put(Long key, String value) {     try {       log.info("缓存存入:[{}]-[{}]", key, value);       cache.put(key, value);     } catch (Exception exception) {       log.error("存入缓存异常", exception);     }   }     /**    * 批量存入缓存    *    * @param map 映射    */   public static void putMap(Map<Long, String> map) {     try {       log.info("批量缓存存入:[{}]", map);       cache.putAll(map);     } catch (Exception exception) {       log.error("批量存入缓存异常", exception);     }   }     /**    * 获取缓存    *    * @param key 键    */   public static String get(Long key) {     try {       return cache.get(key);     } catch (Exception exception) {       log.error("获取缓存异常", exception);       return null;     }   }     /**    * 删除缓存    *    * @param key 键    */   public static void removeKey(Long key) {     try {       cache.invalidate(key);     } catch (Exception exception) {       log.error("删除缓存异常", exception);     }   }     /**    * 批量删除缓存    *    * @param keys 键    */   public static void removeAll(Iterable<Long> keys) {     try {       cache.invalidateAll(keys);     } catch (Exception exception) {       log.error("批量删除缓存异常", exception);     }   }     /** 清理缓存 */   public static void clear() {     try {       cache.invalidateAll();     } catch (Exception exception) {       log.error("清理缓存异常", exception);     }   }     /**    * 获取缓存大小    *    * @return 长度    */   public static long size() {     return cache.size();   }     public static void main(String[] args) {     initCache(         Integer.MAX_VALUE,         10,         TimeUnit.SECONDS,         k -> {           log.info("缓存:[{}],不存在", k);           return "";         },         x -> log.info("缓存:[{}],已经移除", x));     System.out.println(size());     LongStream.range(0, 10).forEach(a -> put(a, MessageFormat.format("tt-{0}", a)));     System.out.println(cache.asMap());     ThreadUtil.sleep(5000);     LongStream.range(0, 10)         .forEach(             a -> {               System.out.println(get(a));               ThreadUtil.sleep(1000);             });     System.out.println(cache.asMap());     ThreadUtil.sleep(10000);     System.out.println(cache.asMap());   } }

代码说明

1、在初始化loadingCache的时候,可以添加缓存的最大数量、消逝时间、消逝或者移除监听事件、不存在键处理等等。在上面的代码中,我初始化缓存大小为Integer的最大值,写入10秒后消逝,如不存在key返回空字符串等等。

2、该类也提供了put、putAll、get、remove、removeAll、clear、size方法,可以对缓存进行存、取、删、清理、大小等操作。

3、main演示方法中,先往缓存存入10个数据,然后过5秒后每秒取一个数据,并且打印一下缓存中的全部内容。

4、补充一句LoadingCache是线程安全的哦。

演示一下

15:31:53.495 [main] INFO ai.guiji.csdn.tools.CacheUtils - 初始化缓存
0
15:31:53.502 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[0]-[tt-0]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[1]-[tt-1]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[2]-[tt-2]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[3]-[tt-3]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[4]-[tt-4]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[5]-[tt-5]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[6]-[tt-6]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[7]-[tt-7]
15:31:53.509 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[8]-[tt-8]
15:31:53.509 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存存入:[9]-[tt-9]
{6=tt-6, 5=tt-5, 0=tt-0, 8=tt-8, 7=tt-7, 2=tt-2, 1=tt-1, 9=tt-9, 3=tt-3, 4=tt-4}
tt-0
tt-1
tt-2
tt-3
tt-4
15:32:03.572 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[5],已经移除
15:32:03.573 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[6],已经移除
15:32:03.573 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[5],不存在
15:32:04.581 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[6],不存在
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[0],已经移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[7],已经移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[8],已经移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[7],不存在
15:32:06.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[8],不存在
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[1],已经移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[2],已经移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[9],已经移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 缓存:[9],不存在
{6=, 5=, 8=, 7=, 9=}
{}
Process finished with exit code 0

可以看到,后面的5-9在内存中已经不存在对应的值了。

到此,关于“Java本地缓存工具LoadingCache怎么使用”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI