增加非空判断

Author: ZMRWEGO

grpc-server-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/server/autoconfigure/GrpcMetaDataZookeeperConfiguration.java

@@ -17,6 +17,8 @@
 
 package net.devh.boot.grpc.server.autoconfigure;
 
+import java.util.Objects;
+
 import javax.annotation.PostConstruct;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -47,11 +49,13 @@ public class GrpcMetaDataZookeeperConfiguration {
 
     @PostConstruct
     public void init() {
-        final String port = String.valueOf(grpcServerProperties.getPort());
-        zookeeperRegistration.setPort(0);
-        if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
-            zookeeperRegistration.getServiceInstance().getPayload().getMetadata()
-                    .put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT, port);
+        if (!Objects.isNull(zookeeperRegistration)) {
+            final String port = String.valueOf(grpcServerProperties.getPort());
+            zookeeperRegistration.setPort(0);
+            if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
+                zookeeperRegistration.getServiceInstance().getPayload().getMetadata()
+                        .put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT, port);
+            }
         }
     }
 }

grpc-server-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/server/autoconfigure/GrpcMetadataConsulConfiguration.java

@@ -51,12 +51,14 @@ public class GrpcMetadataConsulConfiguration {
 
     @PostConstruct
     public void init() {
-        final String port = String.valueOf(grpcProperties.getPort());
-        List<String> tags = consulRegistration.getService().getTags();
-        tags = Objects.isNull(tags) ? new ArrayList<>() : tags;
-        if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
-            tags.add(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT + "=" + port);
-            consulRegistration.getService().setTags(tags);
+        if (!Objects.isNull(consulRegistration)) {
+            final String port = String.valueOf(grpcProperties.getPort());
+            List<String> tags = consulRegistration.getService().getTags();
+            tags = Objects.isNull(tags) ? new ArrayList<>() : tags;
+            if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
+                tags.add(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT + "=" + port);
+                consulRegistration.getService().setTags(tags);
+            }
         }
     }
 }

grpc-server-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/server/autoconfigure/GrpcMetadataEurekaConfiguration.java

@@ -17,6 +17,8 @@
 
 package net.devh.boot.grpc.server.autoconfigure;
 
+import java.util.Objects;
+
 import javax.annotation.PostConstruct;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -47,9 +49,12 @@ public class GrpcMetadataEurekaConfiguration {
 
     @PostConstruct
     public void init() {
-        final String port = String.valueOf(grpcProperties.getPort());
-        if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
-            eurekaRegistration.getInstanceConfig().getMetadataMap().put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT, port);
+        if (!Objects.isNull(eurekaRegistration)) {
+            final String port = String.valueOf(grpcProperties.getPort());
+            if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
+                eurekaRegistration.getInstanceConfig().getMetadataMap().put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT,
+                        port);
+            }
         }
     }
 

grpc-server-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/server/autoconfigure/GrpcMetadataNacosConfiguration.java

@@ -17,6 +17,8 @@
 
 package net.devh.boot.grpc.server.autoconfigure;
 
+import java.util.Objects;
+
 import javax.annotation.PostConstruct;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -47,10 +49,13 @@ public class GrpcMetadataNacosConfiguration {
 
     @PostConstruct
     public void init() {
-        final String port = String.valueOf(grpcProperties.getPort());
-        if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
-            nacosRegistration.getMetadata().put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT, port);
+        if (!Objects.isNull(nacosRegistration)) {
+            final String port = String.valueOf(grpcProperties.getPort());
+            if (!GrpcUtils.INTER_PROCESS_DISABLE.equals(port)) {
+                nacosRegistration.getMetadata().put(GrpcUtils.CLOUD_DISCOVERY_METADATA_PORT, port);
+            }
         }
+
     }
 
 }