topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-10 11:07:06 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(improvement)(chat) Reduce the number of database queries when retrieving system configuration parameters. (#1466)

Browse Source
This commit is contained in:
lexluo09
2024-07-26 18:26:19 +08:00
committed by GitHub
parent 8f620480c6
commit ebbb519c07
1 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
common/src/main/java/com/tencent/supersonic/common/service/impl/SystemConfigServiceImpl.java
View File

@@ -3,17 +3,19 @@ package com.tencent.supersonic.common.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fasterxml.jackson.core.type.TypeReference;
import com.tencent.supersonic.common.config.SystemConfig;
import com.tencent.supersonic.common.persistence.dataobject.SystemConfigDO;
import com.tencent.supersonic.common.persistence.mapper.SystemConfigMapper;
import com.tencent.supersonic.common.pojo.Parameter;
import com.tencent.supersonic.common.config.SystemConfig;
import com.tencent.supersonic.common.service.SystemConfigService;
import com.tencent.supersonic.common.util.JsonUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.util.List;
import java.util.concurrent.atomic.AtomicReference;
@Service
public class SystemConfigServiceImpl
@@ -22,8 +24,21 @@ public class SystemConfigServiceImpl
@Autowired
private Environment environment;
// Cache field to store the system configuration
private AtomicReference<SystemConfig> cachedSystemConfig = new AtomicReference<>();
@Override
public SystemConfig getSystemConfig() {
SystemConfig cachedConfig = cachedSystemConfig.get();
if (cachedConfig != null) {
return cachedConfig;
}
SystemConfig systemConfigDb = getSystemConfigFromDB();
cachedSystemConfig.set(systemConfigDb);
return systemConfigDb;
}
private SystemConfig getSystemConfigFromDB() {
List<SystemConfigDO> list = list();
if (CollectionUtils.isEmpty(list)) {
SystemConfig systemConfig = new SystemConfig();
@@ -46,6 +61,7 @@ public class SystemConfigServiceImpl
public void save(SystemConfig sysConfig) {
SystemConfigDO systemConfigDO = convert(sysConfig);
saveOrUpdate(systemConfigDO);
cachedSystemConfig.set(sysConfig);
}
private SystemConfig convert(SystemConfigDO systemConfigDO) {