Elgato_dark/sol-cloud
1
0
Fork 0
mirror of https://github.com/BgaSol/sol-cloud synced 2026-05-24 09:38:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat(service): Optimize data query efficiency through cache

Browse source
This commit is contained in:
Sol 2025-06-13 00:53:33 +08:00
parent 1871139cc9
commit 3fa8dfa1ca
1 changed files with 37 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
cloud/common/common-base-web/src/main/java/com/bgasol/common/core/base/service/BaseService.java
View file

@ -23,8 +23,7 @@ import org.springframework.transaction.annotation.Transactional;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.lang.reflect.ParameterizedType; import java.lang.reflect.ParameterizedType;
import java.util.Arrays; import java.util.*;
import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static com.bgasol.common.constant.value.RedisConfigValues.DEFAULT_TIME_UNIT; import static com.bgasol.common.constant.value.RedisConfigValues.DEFAULT_TIME_UNIT;
@ -265,6 +264,38 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
return entity; return entity;
} }
@Transactional(readOnly = true)
public List<ENTITY> findIds(String... ids) {
// 优先从缓存查询结果
if (ObjectUtils.isEmpty(commonBaseRedissonClient())) {
return commonBaseMapper().selectByIds(Arrays.asList(ids));
}
// 先获取缓存中的结果
RMapCache<String, ENTITY> mapCache = getRMapCache();
Map<String, ENTITY> cacheList = mapCache.getAll(Set.of(ids));
// 缓存中没有的查询数据库
List<String> noneCacheIds = Arrays.stream(ids).filter(id -> !cacheList.containsKey(id)).toList();
List<ENTITY> entities = commonBaseMapper().selectByIds(noneCacheIds);
// 准备缓存的新数据 数据库中也没有查到的数据制作为NULL_PLACEHOLDER实体
Map<String, ENTITY> toCacheDate = noneCacheIds.stream().collect(Collectors.toMap(id -> id,
id -> entities.stream().filter(entity -> entity.getId().equals(id)).findFirst().orElse(
(ENTITY) BaseEntity.builder().id(NULL_PLACEHOLDER).build()))
);
// 将数据库查询的结果，缓存到redis中
mapCache.putAll(toCacheDate, randomizeTtl(), DEFAULT_TIME_UNIT);
// 合并缓存和数据库的结果 （将防止缓存穿透的空对象扔掉）
List<ENTITY> result = new ArrayList<>(cacheList.values().stream().filter(entity -> !entity.getId().equals(NULL_PLACEHOLDER)).toList());
result.addAll(entities);
this.findOtherTable(result);
return result;
}
/** /**
* 分页查询 * 分页查询
* *
@ -373,7 +404,7 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
*/ */
@Transactional(readOnly = true) @Transactional(readOnly = true)
public void findOtherTable(List<ENTITY> list) { public void findOtherTable(List<ENTITY> list) {
if (list == null || list.isEmpty()) { if (ObjectUtils.isEmpty(list)) {
return; return;
} }
@ -431,10 +462,9 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
* 删除缓存 * 删除缓存
*/ */
public void cacheDelete(String id) { public void cacheDelete(String id) {
if (ObjectUtils.isEmpty(commonBaseRedissonClient())) { if (ObjectUtils.isNotEmpty(commonBaseRedissonClient())) {
return; RMapCache<String, ENTITY> mapCache = getRMapCache();
mapCache.remove(id);
} }
RMapCache<String, ENTITY> mapCache = getRMapCache();
mapCache.remove(id);
} }
} }