admin/lx-admin-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 修复 caffeine共享 key冲突导致的数据问题

Browse Source
This commit is contained in:
疯狂的狮子Li 2024-01-11 23:18:16 +08:00
parent 2ac24d62a0
commit fcabba1087
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java
View File

@ -32,17 +32,21 @@ public class CaffeineCacheDecorator implements Cache {
return cache.getNativeCache(); return cache.getNativeCache();
} }
public String getUniqueKey(Object key) {
return cache.getName() + ":" + key;
}
@Override @Override
public ValueWrapper get(Object key) { public ValueWrapper get(Object key) {
Object o = CAFFEINE.get(key, k -> cache.get(key)); Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key));
Console.log("redisson caffeine -> key: " + key + ",value:" + o); Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o);
return (ValueWrapper) o; return (ValueWrapper) o;
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public <T> T get(Object key, Class<T> type) { public <T> T get(Object key, Class<T> type) {
Object o = CAFFEINE.get(key, k -> cache.get(key, type)); Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key, type));
Console.log("redisson caffeine -> key: " + key + ",value:" + o); Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o);
return (T) o; return (T) o;
} }
@ -63,7 +67,7 @@ public class CaffeineCacheDecorator implements Cache {
public boolean evictIfPresent(Object key) { public boolean evictIfPresent(Object key) {
boolean b = cache.evictIfPresent(key); boolean b = cache.evictIfPresent(key);
if (b) { if (b) {
CAFFEINE.invalidate(key); CAFFEINE.invalidate(getUniqueKey(key));
} }
return b; return b;
} }
@ -80,8 +84,8 @@ public class CaffeineCacheDecorator implements Cache {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
@Override @Override
public <T> T get(Object key, Callable<T> valueLoader) { public <T> T get(Object key, Callable<T> valueLoader) {
Object o = CAFFEINE.get(key, k -> cache.get(key, valueLoader)); Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key, valueLoader));
Console.log("redisson caffeine -> key: " + key + ",value:" + o); Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o);
return (T) o; return (T) o;
} }