From 6c235963d6fc46b38ea59d9b19c6519b892e080b Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 16 May 2022 09:42:06 +0800
Subject: [PATCH] 20220516 逻辑删除，更新字段IS_Delete字段为已删除，默认为空，删除后其余信息从查询中过滤了
---
zq-erp/src/main/java/com/matrix/system/common/init/LocalCache.java | 96 +++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 87 insertions(+), 9 deletions(-)
diff --git a/zq-erp/src/main/java/com/matrix/system/common/init/LocalCache.java b/zq-erp/src/main/java/com/matrix/system/common/init/LocalCache.java
index 00aa8b5..ed624c2 100644
--- a/zq-erp/src/main/java/com/matrix/system/common/init/LocalCache.java
+++ b/zq-erp/src/main/java/com/matrix/system/common/init/LocalCache.java
@@ -2,11 +2,16 @@
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.matrix.core.tools.LogUtil;
+import com.matrix.core.tools.StringUtils;
+import lombok.Data;
import java.util.Iterator;
import java.util.Map;
+import java.util.Objects;
import java.util.Set;
import java.util.concurrent.*;
+import java.util.concurrent.atomic.AtomicLong;
+import java.util.stream.Collectors;
public class LocalCache {
@@ -17,6 +22,20 @@
private static ConcurrentMap<String, Value> localCache = new ConcurrentHashMap(60);
+ /**
+ * 根据key匹配多个缓存值
+ *
+ * @param key
+ * @param <T>
+ * @return
+ */
+ public static <T> Map<String, T> getValues(String key) {
+ return localCache.entrySet().stream()
+ .filter(item -> StringUtils.isMatch(key, item.getKey()))
+ .map(Map.Entry::getValue)
+ .filter(item -> Objects.nonNull(item.value))
+ .collect(Collectors.toMap(Value::getKey, item -> (T) item.value));
+ }
/**
* 获取本地缓存
@@ -26,7 +45,46 @@
* @return
*/
public static <T> T get(String key) {
- return (T) localCache.get(key);
+ Value value = localCache.get(key);
+ if (Objects.nonNull(value)) {
+ return (T) value.value;
+ }
+ return null;
+ }
+
+ /**
+ * 删除缓存
+ *
+ * @param key
+ * @param <T>
+ * @return
+ */
+ public static <T> T remove(String key) {
+ Value value = localCache.remove(key);
+ if (Objects.nonNull(value)) {
+ return (T) value.value;
+ }
+ return null;
+ }
+
+ /**
+ * 批量删除缓存
+ *
+ * @param key
+ * @return
+ */
+ public static int batchRemove(String key) {
+ int count = 0;
+ Set<Map.Entry<String, Value>> entries = localCache.entrySet();
+ Iterator<Map.Entry<String, Value>> iterator = entries.iterator();
+ while (iterator.hasNext()) {
+ Map.Entry<String, Value> next = iterator.next();
+ if (StringUtils.isMatch(key, next.getKey())) {
+ remove(next.getKey());
+ count++;
+ }
+ }
+ return count;
}
/**
@@ -36,7 +94,7 @@
* @param value
*/
public static void save(String key, Object value) {
- if (null != localCache.put(key, buildValue(value))) {
+ if (null != localCache.put(key, buildValue(key, value))) {
LogUtil.debug("覆盖原有缓存{}", key);
}
}
@@ -49,10 +107,22 @@
* @param timeOut 毫秒
*/
public static void save(String key, Object value, long timeOut) {
- if (null != localCache.put(key, buildValue(value, timeOut))) {
+ if (null != localCache.put(key, buildValue(key, value, timeOut))) {
LogUtil.debug("覆盖原有缓存{}", key);
}
startClearThread();
+ }
+
+ /**
+ * 重置缓存失效时间
+ * @param key
+ */
+ public static void resetExpire(String key) {
+ Objects.requireNonNull(key);
+ Value value = localCache.get(key);
+ if(Objects.nonNull(value)){
+ value.getCreateTime().set(System.currentTimeMillis());
+ }
}
/**
@@ -78,7 +148,7 @@
continue;
}
- boolean isTimeOut = (System.currentTimeMillis() - next.getValue().createTime) > next.getValue().timeOut;
+ boolean isTimeOut = (System.currentTimeMillis() - next.getValue().getCreateTime().longValue()) > next.getValue().timeOut;
if (isTimeOut) {
Value removed = localCache.remove(next.getKey());
LogUtil.debug("清除过期对象:{}", removed.value);
@@ -97,29 +167,37 @@
}
- private static Value buildValue(Object value) {
- return buildValue(value, 0);
+ private static Value buildValue(String key, Object value) {
+ return buildValue(key, value, 0);
}
- private static Value buildValue(Object value, long timeOut) {
+ private static Value buildValue(String key, Object value, long timeOut) {
Value instances = new Value();
- instances.createTime = System.currentTimeMillis();
+ instances.createTime = new AtomicLong(System.currentTimeMillis());
+ instances.key = key;
instances.value = value;
instances.timeOut = timeOut;
return instances;
}
+
+
/**
* 缓存对象
*/
+ @Data
static class Value {
/**
* 过期时间,0 表示不过期,单位毫秒
*/
private long timeOut = 0;
+ /**
+ * 缓存key
+ */
+ private String key;
/**
* 缓存值
*/
@@ -128,7 +206,7 @@
/**
* 缓存创建时间
*/
- private long createTime;
+ private AtomicLong createTime;
}
--
Gitblit v1.9.1