opensource/Chat2DB
1
0
Fork 0
mirror of https://github.com/CodePhiliaX/Chat2DB.git synced 2025-08-02 21:50:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

Change 'Ehcache' to 'Guava Cache'` [Issue #741](https://github.com/chat2db/Chat2DB/issues/741)

Browse Source
This commit is contained in:
JiaJu Zhuang
2023-11-04 22:41:00 +08:00
parent 696591753e
commit c8b9ddcff3
1 changed files with 11 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
chat2db-server/chat2db-server-domain/chat2db-server-domain-core/src/main/java/ai/chat2db/server/domain/core/cache/MemoryCacheManage.java vendored
View File

@ -1,17 +1,14 @@
package ai.chat2db.server.domain.core.cache;
import java.io.Serializable;
import java.time.Duration;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.Weigher;
import org.apache.commons.lang3.SerializationUtils;
import org.apache.commons.lang3.StringUtils;
import org.ehcache.Cache;
import org.ehcache.config.builders.CacheConfigurationBuilder;
import org.ehcache.config.builders.CacheManagerBuilder;
import org.ehcache.config.builders.ExpiryPolicyBuilder;
import org.ehcache.config.builders.ResourcePoolsBuilder;
import org.ehcache.config.units.MemoryUnit;
import org.springframework.cache.support.NullValue;
/**
@ -22,19 +19,17 @@ import org.springframework.cache.support.NullValue;
public class MemoryCacheManage {
private static final byte[] NULL_BYTES = SerializationUtils.serialize((NullValue)NullValue.INSTANCE);
private static final String CACHE = "memory_cache";
private static final String SYNCHRONIZED_PREFIX = "MemoryCache:";
private static Cache<String, byte[]> cache;
static {
cache = CacheManagerBuilder.newCacheManagerBuilder()
.build(true)
.createCache(CACHE,
CacheConfigurationBuilder.newCacheConfigurationBuilder(String.class, byte[].class,
ResourcePoolsBuilder.newResourcePoolsBuilder()
.offheap(5, MemoryUnit.MB))
.withExpiry(ExpiryPolicyBuilder.timeToLiveExpiration(Duration.ofMinutes(10))));
cache = CacheBuilder.newBuilder()
// 5M
.maximumWeight(5 * 1024 * 1024)
.weigher((Weigher<String, byte[]>)(key, value) -> value.length)
.expireAfterAccess(10, TimeUnit.MINUTES)
.build();
}
/**
@ -78,7 +73,7 @@ public class MemoryCacheManage {
if (StringUtils.isBlank(key)) {
return null;
}
byte[] bytes = cache.get(key);
byte[] bytes = cache.getIfPresent(key);
if (bytes == null) {
return null;
}