remove remoteSwagger

Author: chengyouling

core/src/main/java/org/apache/servicecomb/core/definition/ServiceRegistryListener.java

@@ -130,6 +130,13 @@ public void onCreateMicroserviceVersion(CreateMicroserviceVersionEvent event) {
     microserviceVersion.getVendorExtensions().put(CORE_MICROSERVICE_META, microserviceMeta);
   }
 
+  @EnableExceptionPropagation
+  @SubscriberOrder(-800)
+  @Subscribe
+  public void onDestroyMicroserviceEvent(DestroyMicroserviceEvent event) {
+    scbEngine.getSwaggerLoader().removeRemoteSwagger(event.getMicroserviceVersions().getInstances());
+  }
+
   public void destroy() {
     scbEngine.getEventBus().unregister(this);
   }

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

@@ -37,6 +37,7 @@
 import org.apache.servicecomb.swagger.generator.SwaggerGenerator;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Charsets;
@@ -181,7 +182,7 @@ private Swagger loadFromResource(String path) {
 
   private Swagger loadFromRemote(Microservice microservice, Collection<MicroserviceInstance> instances,
       String schemaId) {
-    String key = microservice.getServiceName() + "." + schemaId;
+    String key = microservice.getServiceId() + "." + schemaId;
     Swagger result = remoteSwagger.computeIfAbsent(key, k -> {
       String schemaContent = DiscoveryManager.INSTANCE.getSchema(microservice.getServiceId(), instances, schemaId);
       if (schemaContent != null) {
@@ -197,7 +198,8 @@ private Swagger loadFromRemote(Microservice microservice, Collection<Microservic
       }
       return null;
     });
-
+    LOGGER.info(
+        "load [{}] schema from service center, map size [{}]", microservice.getServiceId(), remoteSwagger.size());
     if (result != null) {
       return result;
     }
@@ -212,4 +214,15 @@ private Swagger loadFromRemote(Microservice microservice, Collection<Microservic
 
     return null;
   }
+
+  public void removeRemoteSwagger(List<MicroserviceInstance> instances) {
+    if (CollectionUtils.isEmpty(instances)) {
+      return;
+    }
+    String serviceId = instances.get(0).getServiceId();
+    int originSize = remoteSwagger.size();
+    remoteSwagger.remove(serviceId);
+    LOGGER.info(
+        "remove [{}] swagger, origin size [{}], current size [{}]", serviceId, originSize, remoteSwagger.size());
+  }
 }