8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-25 04:32:12 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

ZookeeperService中增加服务存活统计方法

Browse Source
This commit is contained in:
zengqiao
2022-10-12 11:02:41 +08:00
committed by EricZeng
parent f3b64ca463
commit 6ad29b9565
2 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/ZookeeperService.java
View File

@@ -15,4 +15,16 @@ public interface ZookeeperService {
void batchReplaceDataInDB(Long clusterPhyId, List<ZookeeperInfo> infoList);
List<ZookeeperInfo> listFromDBByCluster(Long clusterPhyId);
/**
* 所有服务挂掉
* @return
*/
boolean allServerDown(Long clusterPhyId);
/**
* 存在服务挂掉
* @return
*/
boolean existServerDown(Long clusterPhyId);
}

23
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/zookeeper/impl/ZookeeperServiceImpl.java
View File

@@ -14,6 +14,7 @@ import com.xiaojukeji.know.streaming.km.common.utils.ConvertUtil;
import com.xiaojukeji.know.streaming.km.common.utils.Tuple;
import com.xiaojukeji.know.streaming.km.common.bean.entity.zookeeper.ZookeeperInfo;
import com.xiaojukeji.know.streaming.km.common.bean.po.zookeeper.ZookeeperInfoPO;
import com.xiaojukeji.know.streaming.km.common.utils.ValidateUtils;
import com.xiaojukeji.know.streaming.km.common.utils.zookeeper.FourLetterWordUtil;
import com.xiaojukeji.know.streaming.km.common.utils.zookeeper.ZookeeperUtils;
import com.xiaojukeji.know.streaming.km.core.service.zookeeper.ZookeeperService;
@@ -105,6 +106,28 @@ public class ZookeeperServiceImpl implements ZookeeperService {
return ConvertUtil.list2List(this.listRawFromDBByCluster(clusterPhyId), ZookeeperInfo.class);
}
@Override
public boolean allServerDown(Long clusterPhyId) {
List<ZookeeperInfo> infoList = this.listFromDBByCluster(clusterPhyId);
if (ValidateUtils.isEmptyList(infoList)) {
return false;
}
// 所有服务挂掉
return infoList.stream().filter(elem -> !elem.alive()).count() == infoList.size();
}
@Override
public boolean existServerDown(Long clusterPhyId) {
List<ZookeeperInfo> infoList = this.listFromDBByCluster(clusterPhyId);
if (ValidateUtils.isEmptyList(infoList)) {
// 不存在挂掉的服务
return false;
}
// 存在挂掉的服务
return infoList.stream().filter(elem -> !elem.alive()).count() > 0;
}
/**************************************************** private method ****************************************************/