Commit 89a803bfae4b5f9da76ce7a20cb3093997554950

Authored by unknown
1 parent 22382d46
Exists in master

1.add valid heartbeat client request

build.gradle
... ... @@ -55,7 +55,7 @@ uploadArchives {
55 55 authentication(userName: NEXUS_USERNAME, password: NEXUS_PASSWORD)
56 56 }
57 57 pom.project {
58   - version '1.1.8'
  58 + version '1.1.9'
59 59 artifactId ARTIFACT_Id
60 60 groupId GROUP_ID
61 61 packaging TYPE
... ...
src/main/java/com/taover/heartbeat/ClientHolderImpl.java
... ... @@ -5,6 +5,8 @@ import java.util.HashMap;
5 5 import java.util.List;
6 6 import java.util.Map;
7 7  
  8 +import org.apache.commons.lang3.StringUtils;
  9 +
8 10 import com.taover.heartbeat.bean.ClientInstance;
9 11 import com.taover.heartbeat.bean.ClientRequest;
10 12  
... ... @@ -23,6 +25,9 @@ public class ClientHolderImpl implements ClientHolder{
23 25  
24 26 @Override
25 27 public void registryClientInstance(ClientRequest clientRequest) {
  28 + if(!this.validClientRequest(clientRequest)) {
  29 + return;
  30 + }
26 31 synchronized (this.clientMap) {
27 32 ClientInstance client = null;
28 33 if(clientMap.containsKey(clientRequest.getIdentity())) {
... ... @@ -35,4 +40,14 @@ public class ClientHolderImpl implements ClientHolder{
35 40 client.dealClientRequest(clientRequest);
36 41 }
37 42 }
  43 +
  44 + private boolean validClientRequest(ClientRequest clientRequest) {
  45 + if(StringUtils.isNotBlank(clientRequest.getCode())
  46 + && StringUtils.isNotBlank(clientRequest.getIp())
  47 + && clientRequest.getFixRateSec() > 0) {
  48 + return true;
  49 + }else {
  50 + return false;
  51 + }
  52 + }
38 53 }
... ...