From 1930f11620b1ca86a923fd9d5f2d01726aaecaeb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E8=81=AA=E6=B4=8B?= <1601081222@qq.com> Date: Thu, 18 Jul 2024 21:30:22 +0800 Subject: [PATCH] delete SpringCloudServiceInstanceNotificationCustomizer --- ...ServiceInstanceNotificationCustomizer.java | 70 ------------------- ...data.ServiceInstanceNotificationCustomizer | 1 - 2 files changed, 71 deletions(-) delete mode 100644 dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/metadata/SpringCloudServiceInstanceNotificationCustomizer.java delete mode 100644 dubbo-registry/dubbo-registry-api/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.ServiceInstanceNotificationCustomizer diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/metadata/SpringCloudServiceInstanceNotificationCustomizer.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/metadata/SpringCloudServiceInstanceNotificationCustomizer.java deleted file mode 100644 index e0509b0a37a..00000000000 --- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/metadata/SpringCloudServiceInstanceNotificationCustomizer.java +++ /dev/null @@ -1,70 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.dubbo.registry.client.metadata; - -import org.apache.dubbo.common.ProtocolServiceKey; -import org.apache.dubbo.metadata.MetadataInfo; -import org.apache.dubbo.registry.client.ServiceInstance; - -import java.util.Collections; -import java.util.HashMap; -import java.util.List; -import java.util.concurrent.ConcurrentHashMap; - -public class SpringCloudServiceInstanceNotificationCustomizer implements ServiceInstanceNotificationCustomizer { - @Override - public void customize(List serviceInstance) { - if (serviceInstance.isEmpty()) { - return; - } - - if (!serviceInstance.stream() - .allMatch(instance -> "SPRING_CLOUD".equals(instance.getMetadata("preserved.register.source")))) { - return; - } - - for (ServiceInstance instance : serviceInstance) { - MetadataInfo.ServiceInfo serviceInfo = - new MetadataInfo.ServiceInfo("*", "*", "*", "rest", instance.getPort(), "*", new HashMap<>()); - String revision = "SPRING_CLOUD-" + instance.getServiceName() + "-" + instance.getAddress() + "-" - + instance.getPort(); - MetadataInfo metadataInfo = - new MetadataInfo( - instance.getServiceName(), - revision, - new ConcurrentHashMap<>(Collections.singletonMap("*", serviceInfo))) { - @Override - public List getMatchedServiceInfos(ProtocolServiceKey consumerProtocolServiceKey) { - getServices() - .putIfAbsent( - consumerProtocolServiceKey.getServiceKeyString(), - new MetadataInfo.ServiceInfo( - consumerProtocolServiceKey.getInterfaceName(), - consumerProtocolServiceKey.getGroup(), - consumerProtocolServiceKey.getVersion(), - consumerProtocolServiceKey.getProtocol(), - instance.getPort(), - consumerProtocolServiceKey.getInterfaceName(), - new HashMap<>())); - return super.getMatchedServiceInfos(consumerProtocolServiceKey); - } - }; - - instance.setServiceMetadata(metadataInfo); - } - } -} diff --git a/dubbo-registry/dubbo-registry-api/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.ServiceInstanceNotificationCustomizer b/dubbo-registry/dubbo-registry-api/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.ServiceInstanceNotificationCustomizer deleted file mode 100644 index 7746df631bb..00000000000 --- a/dubbo-registry/dubbo-registry-api/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.ServiceInstanceNotificationCustomizer +++ /dev/null @@ -1 +0,0 @@ -spring-cloud=org.apache.dubbo.registry.client.metadata.SpringCloudServiceInstanceNotificationCustomizer