8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-05 13:08:48 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

部分后台任务获取Topic列表时不走缓存

Browse Source
This commit is contained in:
zengqiao
2021-04-22 16:06:37 +08:00
parent 59df5b24fe
commit d6559be3fc
5 changed files with 19 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/TopicManagerService.java
View File

@@ -22,6 +22,8 @@ import java.util.Map;
public interface TopicManagerService { public interface TopicManagerService {
List<TopicDO> listAll(); List<TopicDO> listAll();
List<TopicDO> getByClusterIdFromCache(Long clusterId);
List<TopicDO> getByClusterId(Long clusterId); List<TopicDO> getByClusterId(Long clusterId);
TopicDO getByTopicName(Long clusterId, String topicName); TopicDO getByTopicName(Long clusterId, String topicName);

8
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
View File

@@ -95,6 +95,14 @@ public class TopicManagerServiceImpl implements TopicManagerService {
return new ArrayList<>(); return new ArrayList<>();
} }
@Override
public List<TopicDO> getByClusterIdFromCache(Long clusterId) {
if (clusterId == null) {
return new ArrayList<>();
}
return topicDao.getByClusterIdFromCache(clusterId);
}
@Override @Override
public List<TopicDO> getByClusterId(Long clusterId) { public List<TopicDO> getByClusterId(Long clusterId) {
if (clusterId == null) { if (clusterId == null) {

2
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicServiceImpl.java
View File

@@ -381,7 +381,7 @@ public class TopicServiceImpl implements TopicService {
return new ArrayList<>(); return new ArrayList<>();
} }
List<TopicDO> topicDOList = topicManagerService.getByClusterId(clusterId); List<TopicDO> topicDOList = topicManagerService.getByClusterIdFromCache(clusterId);
if (ValidateUtils.isNull(topicDOList)) { if (ValidateUtils.isNull(topicDOList)) {
topicDOList = new ArrayList<>(); topicDOList = new ArrayList<>();
} }

2
kafka-manager-dao/src/main/java/com/xiaojukeji/kafka/manager/dao/TopicDao.java
View File

@@ -15,6 +15,8 @@ public interface TopicDao {
TopicDO getByTopicName(Long clusterId, String topicName); TopicDO getByTopicName(Long clusterId, String topicName);
List<TopicDO> getByClusterIdFromCache(Long clusterId);
List<TopicDO> getByClusterId(Long clusterId); List<TopicDO> getByClusterId(Long clusterId);
List<TopicDO> getByAppId(String appId); List<TopicDO> getByAppId(String appId);

7
kafka-manager-dao/src/main/java/com/xiaojukeji/kafka/manager/dao/impl/TopicDaoImpl.java
View File

@@ -62,11 +62,16 @@ public class TopicDaoImpl implements TopicDao {
} }
@Override @Override
public List<TopicDO> getByClusterId(Long clusterId) { public List<TopicDO> getByClusterIdFromCache(Long clusterId) {
updateTopicCache(); updateTopicCache();
return new ArrayList<>(TOPIC_MAP.getOrDefault(clusterId, Collections.emptyMap()).values()); return new ArrayList<>(TOPIC_MAP.getOrDefault(clusterId, Collections.emptyMap()).values());
} }
@Override
public List<TopicDO> getByClusterId(Long clusterId) {
return sqlSession.selectList("TopicDao.getByClusterId", clusterId);
}
@Override @Override
public List<TopicDO> getByAppId(String appId) { public List<TopicDO> getByAppId(String appId) {
return sqlSession.selectList("TopicDao.getByAppId", appId); return sqlSession.selectList("TopicDao.getByAppId", appId);