diff --git a/build.gradle b/build.gradle index 1225c95..cf794f4 100644 --- a/build.gradle +++ b/build.gradle @@ -55,7 +55,7 @@ uploadArchives { authentication(userName: NEXUS_USERNAME, password: NEXUS_PASSWORD) } pom.project { - version '1.1.8' + version '1.1.9' artifactId ARTIFACT_Id groupId GROUP_ID packaging TYPE diff --git a/src/main/java/com/taover/heartbeat/ClientHolderImpl.java b/src/main/java/com/taover/heartbeat/ClientHolderImpl.java index e496780..92a9b66 100644 --- a/src/main/java/com/taover/heartbeat/ClientHolderImpl.java +++ b/src/main/java/com/taover/heartbeat/ClientHolderImpl.java @@ -5,6 +5,8 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import org.apache.commons.lang3.StringUtils; + import com.taover.heartbeat.bean.ClientInstance; import com.taover.heartbeat.bean.ClientRequest; @@ -23,6 +25,9 @@ public class ClientHolderImpl implements ClientHolder{ @Override public void registryClientInstance(ClientRequest clientRequest) { + if(!this.validClientRequest(clientRequest)) { + return; + } synchronized (this.clientMap) { ClientInstance client = null; if(clientMap.containsKey(clientRequest.getIdentity())) { @@ -35,4 +40,14 @@ public class ClientHolderImpl implements ClientHolder{ client.dealClientRequest(clientRequest); } } + + private boolean validClientRequest(ClientRequest clientRequest) { + if(StringUtils.isNotBlank(clientRequest.getCode()) + && StringUtils.isNotBlank(clientRequest.getIp()) + && clientRequest.getFixRateSec() > 0) { + return true; + }else { + return false; + } + } } -- libgit2 0.21.2