Submit a feature that applies graceful up and down (#4670)

Author: chenshouye168

core/src/main/java/org/apache/servicecomb/core/SCBEngine.java

@@ -370,8 +370,6 @@ private void doRun() throws Exception {
     triggerEvent(EventType.BEFORE_REGISTRY);
     registrationManager.run();
     discoveryManager.run();
-    // ensure can invoke services in AFTER_REGISTRY
-    registrationManager.updateMicroserviceInstanceStatus(MicroserviceInstanceStatus.UP);
     status = SCBStatus.UP;
     triggerEvent(EventType.AFTER_REGISTRY);
 

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/DiscoveryManager.java

@@ -183,7 +183,7 @@ private VersionedCache calcAvailableInstance(String application, String serviceN
         continue;
       }
       if (instance.getHistoryStatus() == HistoryStatus.HISTORY
-          && instance.getMicroserviceInstanceStatus() == MicroserviceInstanceStatus.UP
+          && instance.getStatus() == MicroserviceInstanceStatus.UP
           && instance.getPingStatus() == PingStatus.OK
           && instance.getIsolationStatus() == IsolationStatus.NORMAL) {
         result.add(instance);

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/MicroserviceInstance.java

@@ -93,4 +93,10 @@ public interface MicroserviceInstance {
   default String getServiceId() {
     return "";
   }
+
+  /**
+   * Service status(Required): status of this microservice.
+   *
+   */
+  MicroserviceInstanceStatus getStatus();
 }

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/api/RegistrationInstance.java

@@ -20,15 +20,4 @@
  * Microserivce instance registration object.
  */
 public interface RegistrationInstance extends MicroserviceInstance {
-  /**
-   * Initial status when registering(Optional). This method is
-   * implementation specific and may be not used.
-   */
-  MicroserviceInstanceStatus getInitialStatus();
-
-  /**
-   * Ready status when microservice instance is ready for service(Optional).This method is
-   * implementation specific and may be not used.
-   */
-  MicroserviceInstanceStatus getReadyStatus();
 }

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/discovery/InstanceStatusDiscoveryFilter.java

@@ -69,21 +69,21 @@ public void init(DiscoveryContext context, DiscoveryTreeNode parent) {
 
     for (StatefulDiscoveryInstance instance : instances) {
       if (HistoryStatus.CURRENT == instance.getHistoryStatus() &&
-          MicroserviceInstanceStatus.UP == instance.getMicroserviceInstanceStatus() &&
+          MicroserviceInstanceStatus.UP == instance.getStatus() &&
           PingStatus.OK == instance.getPingStatus() &&
           IsolationStatus.NORMAL == instance.getIsolationStatus()) {
         level0.add(instance);
         continue;
       }
       if (HistoryStatus.CURRENT == instance.getHistoryStatus() &&
-          MicroserviceInstanceStatus.UP == instance.getMicroserviceInstanceStatus() &&
+          MicroserviceInstanceStatus.UP == instance.getStatus() &&
           PingStatus.UNKNOWN == instance.getPingStatus() &&
           IsolationStatus.NORMAL == instance.getIsolationStatus()) {
         level1.add(instance);
         continue;
       }
       if (HistoryStatus.HISTORY == instance.getHistoryStatus() &&
-          MicroserviceInstanceStatus.UP == instance.getMicroserviceInstanceStatus() &&
+          MicroserviceInstanceStatus.UP == instance.getStatus() &&
           PingStatus.OK == instance.getPingStatus() &&
           IsolationStatus.NORMAL == instance.getIsolationStatus()) {
         level2.add(instance);

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/discovery/StatefulDiscoveryInstance.java

@@ -46,8 +46,6 @@ public enum HistoryStatus {
 
   private final DiscoveryInstance discoveryInstance;
 
-  private MicroserviceInstanceStatus microserviceInstanceStatus = MicroserviceInstanceStatus.UP;
-
   private IsolationStatus isolationStatus = IsolationStatus.NORMAL;
 
   private long isolatedTime;
@@ -64,15 +62,6 @@ public StatefulDiscoveryInstance(DiscoveryInstance discoveryInstance) {
     this.discoveryInstance = discoveryInstance;
   }
 
-  public MicroserviceInstanceStatus getMicroserviceInstanceStatus() {
-    return microserviceInstanceStatus;
-  }
-
-  public void setMicroserviceInstanceStatus(
-      MicroserviceInstanceStatus microserviceInstanceStatus) {
-    this.microserviceInstanceStatus = microserviceInstanceStatus;
-  }
-
   public IsolationStatus getIsolationStatus() {
     return isolationStatus;
   }

foundations/foundation-registry/src/test/java/org/apache/servicecomb/registry/discovery/TestInstanceStatusDiscoveryFilter.java

@@ -36,22 +36,22 @@ public void test_all_group_correct_init() {
     List<StatefulDiscoveryInstance> instances = new ArrayList<>();
     StatefulDiscoveryInstance instance1 = Mockito.mock(StatefulDiscoveryInstance.class);
     Mockito.when(instance1.getHistoryStatus()).thenReturn(HistoryStatus.CURRENT);
-    Mockito.when(instance1.getMicroserviceInstanceStatus()).thenReturn(MicroserviceInstanceStatus.UP);
+    Mockito.when(instance1.getStatus()).thenReturn(MicroserviceInstanceStatus.UP);
     Mockito.when(instance1.getPingStatus()).thenReturn(PingStatus.OK);
     Mockito.when(instance1.getIsolationStatus()).thenReturn(IsolationStatus.NORMAL);
     StatefulDiscoveryInstance instance2 = Mockito.mock(StatefulDiscoveryInstance.class);
     Mockito.when(instance2.getHistoryStatus()).thenReturn(HistoryStatus.CURRENT);
-    Mockito.when(instance2.getMicroserviceInstanceStatus()).thenReturn(MicroserviceInstanceStatus.UP);
+    Mockito.when(instance2.getStatus()).thenReturn(MicroserviceInstanceStatus.UP);
     Mockito.when(instance2.getPingStatus()).thenReturn(PingStatus.UNKNOWN);
     Mockito.when(instance2.getIsolationStatus()).thenReturn(IsolationStatus.NORMAL);
     StatefulDiscoveryInstance instance3 = Mockito.mock(StatefulDiscoveryInstance.class);
     Mockito.when(instance3.getHistoryStatus()).thenReturn(HistoryStatus.HISTORY);
-    Mockito.when(instance3.getMicroserviceInstanceStatus()).thenReturn(MicroserviceInstanceStatus.UP);
+    Mockito.when(instance3.getStatus()).thenReturn(MicroserviceInstanceStatus.UP);
     Mockito.when(instance3.getPingStatus()).thenReturn(PingStatus.OK);
     Mockito.when(instance3.getIsolationStatus()).thenReturn(IsolationStatus.NORMAL);
     StatefulDiscoveryInstance instance4 = Mockito.mock(StatefulDiscoveryInstance.class);
     Mockito.when(instance4.getHistoryStatus()).thenReturn(HistoryStatus.CURRENT);
-    Mockito.when(instance4.getMicroserviceInstanceStatus()).thenReturn(MicroserviceInstanceStatus.UP);
+    Mockito.when(instance4.getStatus()).thenReturn(MicroserviceInstanceStatus.UP);
     Mockito.when(instance4.getPingStatus()).thenReturn(PingStatus.FAIL);
     Mockito.when(instance4.getIsolationStatus()).thenReturn(IsolationStatus.NORMAL);
     instances.addAll(Arrays.asList(instance1, instance2, instance3, instance4));

foundations/foundation-registry/src/test/resources/log4j2.xml

@@ -16,14 +16,14 @@
     under the License.
 -->
 <Configuration status="INFO">
-    <Appenders>
-        <Console name="Console" target="SYSTEM_OUT">
-            <PatternLayout pattern="[%d][%t][%p][%c:%L] %m%n" />
-        </Console>
-    </Appenders>
-    <Loggers>
-        <Root level="INFO">
-            <AppenderRef ref="Console" />
-        </Root>
-    </Loggers>
+  <Appenders>
+    <Console name="Console" target="SYSTEM_OUT">
+      <PatternLayout pattern="[%d][%t][%p][%c:%L] %m%n"/>
+    </Console>
+  </Appenders>
+  <Loggers>
+    <Root level="INFO">
+      <AppenderRef ref="Console"/>
+    </Root>
+  </Loggers>
 </Configuration>

service-registry/registry-consul/pom.xml

@@ -17,8 +17,8 @@
   -->
 
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <parent>
     <groupId>org.apache.servicecomb</groupId>

service-registry/registry-consul/src/main/java/org/apache/servicecomb/registry/consul/ConsulConfiguration.java

@@ -18,6 +18,7 @@
 package org.apache.servicecomb.registry.consul;
 
 import com.google.common.net.HostAndPort;
+
 import org.apache.commons.lang3.StringUtils;
 import org.apache.servicecomb.config.DataCenterProperties;
 import org.apache.servicecomb.registry.RegistrationId;
@@ -54,7 +55,8 @@ public ConsulDiscoveryProperties consulDiscoveryProperties() {
   @ConditionalOnBean(value = {ConsulProperties.class, ConsulDiscoveryProperties.class})
   @ConditionalOnMissingBean
   public Consul consulClient(ConsulProperties consulProperties, ConsulDiscoveryProperties consulDiscoveryProperties) {
-    Consul.Builder builder = Consul.builder().withHostAndPort(HostAndPort.fromParts(consulProperties.getHost(), consulProperties.getPort()));
+    Consul.Builder builder = Consul.builder()
+        .withHostAndPort(HostAndPort.fromParts(consulProperties.getHost(), consulProperties.getPort()));
     if (StringUtils.isNotBlank(consulDiscoveryProperties.getAclToken())) {
       builder.withAclToken(consulDiscoveryProperties.getAclToken());
     }