Browse Source

update configuration

shjung 6 days ago
parent
commit
dd92a00148

+ 13 - 0
its-cluster/src/main/java/com/its/common/cluster/config/AbstractClusterConfig.java

@@ -1,5 +1,6 @@
 package com.its.common.cluster.config;
 
+import com.its.common.cluster.vo.ClusterNET;
 import com.its.common.cluster.vo.ClusterNode;
 import io.netty.util.AttributeKey;
 import lombok.Data;
@@ -38,6 +39,18 @@ public abstract class AbstractClusterConfig {
         }
     }
 
+    public boolean isClusterAlive(int clusterId) {
+        ClusterNode clusterNode = this.clusterMap.get(clusterId);
+        if (clusterNode == null) {
+            return true;
+        }
+        return clusterNode.getElectionState().getState() != ClusterNET.CLOSED;
+    }
+
+    public ClusterNode getClusterNode(int clusterId) {
+        return this.clusterMap.get(clusterId);
+    }
+
     public void loggingInfo() {
         log.info("Cluster config enabled: {}", this.enabled);
         log.info("                    id: {}", this.id);

+ 4 - 0
its-cluster/src/main/java/com/its/common/cluster/vo/ClusterNetState.java

@@ -35,6 +35,10 @@ public class ClusterNetState {
         this.disconnectTime = null;
     }
 
+    public boolean isAlive() {
+        return (this.state != ClusterNET.CLOSED);
+    }
+
     public void setLastRecvTime() {
         this.lastRecvTime = System.currentTimeMillis();
     }