From 1c0025c87a69aa72f46bd80e154cff9105d90c1f Mon Sep 17 00:00:00 2001 From: 13693261870 <252740454@qq.com> Date: 星期四, 27 四月 2023 14:39:10 +0800 Subject: [PATCH] 1 --- src/main/java/com/yssh/utils/CacheUtils.java | 35 +++++++++++++++++ src/main/java/com/yssh/run/InitDataRunner.java | 41 ++++++++++---------- pom.xml | 11 +++-- 3 files changed, 62 insertions(+), 25 deletions(-) diff --git a/pom.xml b/pom.xml index dc680bd..0d90f91 100644 --- a/pom.xml +++ b/pom.xml @@ -191,11 +191,12 @@ <version>22.0</version> <scope>compile</scope> </dependency> - <dependency> - <groupId>com.google.guava</groupId> - <artifactId>guava</artifactId> - <version>31.1-jre</version> - </dependency> + <!--Caffeine缂撳瓨--> + <dependency> + <groupId>com.github.ben-manes.caffeine</groupId> + <artifactId>caffeine</artifactId> + <version>2.9.3</version> + </dependency> </dependencies> <profiles> diff --git a/src/main/java/com/yssh/run/InitDataRunner.java b/src/main/java/com/yssh/run/InitDataRunner.java index c21ac04..0080de9 100644 --- a/src/main/java/com/yssh/run/InitDataRunner.java +++ b/src/main/java/com/yssh/run/InitDataRunner.java @@ -1,6 +1,6 @@ package com.yssh.run; - +import com.yssh.utils.CacheUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -11,25 +11,26 @@ import com.yssh.service.ICommonService; import com.yssh.service.IDictRecordService; - @Component -public class InitDataRunner implements ApplicationRunner{ +public class InitDataRunner implements ApplicationRunner { - protected final Logger logger = LoggerFactory.getLogger(this.getClass()); - - @Autowired - private ICommonService commonService; - - @Autowired - private IDictRecordService dictRecordService; - - @Override - public void run(ApplicationArguments args) throws Exception { - boolean tableExists = commonService.checkTableExists("dict_record"); - if (!tableExists) { - dictRecordService.createDictRecoTable(); - } - //璇诲彇dat鏁版嵁 - commonService.readDatData(); - } + protected final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private ICommonService commonService; + + @Autowired + private IDictRecordService dictRecordService; + + @Override + public void run(ApplicationArguments args) throws Exception { + CacheUtils.init(); + + boolean tableExists = commonService.checkTableExists("dict_record"); + if (!tableExists) { + dictRecordService.createDictRecoTable(); + } + //璇诲彇dat鏁版嵁 + commonService.readDatData(); + } } diff --git a/src/main/java/com/yssh/utils/CacheUtils.java b/src/main/java/com/yssh/utils/CacheUtils.java new file mode 100644 index 0000000..10527b1 --- /dev/null +++ b/src/main/java/com/yssh/utils/CacheUtils.java @@ -0,0 +1,35 @@ +package com.yssh.utils; + +import com.github.benmanes.caffeine.cache.Cache; +import com.github.benmanes.caffeine.cache.Caffeine; +import org.checkerframework.checker.nullness.qual.NonNull; + +import java.util.concurrent.TimeUnit; + +public class CacheUtils { + private static @NonNull Cache<String, Object> cache; + + public static void init() { + cache = Caffeine.newBuilder() + .initialCapacity(2) + .maximumSize(1024) + .expireAfterWrite(24, TimeUnit.HOURS) + .build(); + } + + public static Object get(String key) { + return cache.getIfPresent(key); + } + + public static void put(String key, Object obj) { + cache.put(key, obj); + } + + public static void remove(String key) { + cache.invalidate(key); + } + + public static void clear() { + cache.invalidateAll(); + } +} -- Gitblit v1.9.3