code format

Author: 呈铭

dubbo-registry/dubbo-registry-nacos/src/main/java/org/apache/dubbo/registry/nacos/NacosRegistry.java

@@ -92,8 +92,8 @@ public class NacosRegistry extends FailbackRegistry {
     /**
      * All supported categories
      */
-    private static final List<String> ALL_SUPPORTED_CATEGORIES =
-            Arrays.asList(PROVIDERS_CATEGORY, CONSUMERS_CATEGORY, ROUTERS_CATEGORY, CONFIGURATORS_CATEGORY);
+    private static final List<String> ALL_SUPPORTED_CATEGORIES = Arrays.asList(PROVIDERS_CATEGORY, CONSUMERS_CATEGORY
+            , ROUTERS_CATEGORY, CONFIGURATORS_CATEGORY);
 
     private static final int CATEGORY_INDEX = 0;
 
@@ -108,9 +108,8 @@ public class NacosRegistry extends FailbackRegistry {
     private static final String UP = "UP";
 
     /**
-     * The separator for service name
-     * Change a constant to be configurable, it's designed for Windows file name that is compatible with old
-     * Nacos binary release(< 0.6.1)
+     * The separator for service name Change a constant to be configurable, it's designed for Windows file name that is
+     * compatible with old Nacos binary release(< 0.6.1)
      */
     private static final String SERVICE_NAME_SEPARATOR = System.getProperty("nacos.service.name.separator", ":");
 
@@ -166,8 +165,8 @@ public List<URL> lookup(final URL url) {
             List<URL> urls = new LinkedList<>();
             Set<String> serviceNames = getServiceNames(url, null);
             for (String serviceName : serviceNames) {
-                List<Instance> instances =
-                        namingService.getAllInstances(serviceName, getUrl().getGroup(Constants.DEFAULT_GROUP));
+                List<Instance> instances = namingService.getAllInstances(serviceName,
+                        getUrl().getGroup(Constants.DEFAULT_GROUP));
                 urls.addAll(buildURLs(url, instances));
             }
             return urls;
@@ -198,7 +197,8 @@ public void doRegister(URL url) {
                 }
 
                 /**
-                 *  namingService.registerInstance with {@link org.apache.dubbo.registry.support.AbstractRegistry#registryUrl}
+                 *  namingService.registerInstance with
+                 *  {@link org.apache.dubbo.registry.support.AbstractRegistry#registryUrl}
                  *  default {@link DEFAULT_GROUP}
                  *
                  * in https://github.com/apache/dubbo/issues/5978
@@ -207,8 +207,8 @@ public void doRegister(URL url) {
                     namingService.registerInstance(service, getUrl().getGroup(Constants.DEFAULT_GROUP), instance);
                 }
             } else {
-                logger.info(
-                        "Please set 'dubbo.registry.parameters.register-consumer-url=true' to turn on consumer url registration.");
+                logger.info("Please set 'dubbo.registry.parameters.register-consumer-url=true' to turn on consumer "
+                        + "url registration.");
             }
         } catch (SkipFailbackWrapperException exception) {
             throw exception;
@@ -236,8 +236,8 @@ public void doUnregister(final URL url) {
             }
 
             for (String service : serviceNames) {
-                namingService.deregisterInstance(
-                        service, getUrl().getGroup(Constants.DEFAULT_GROUP), instance.getIp(), instance.getPort());
+                namingService.deregisterInstance(service, getUrl().getGroup(Constants.DEFAULT_GROUP),
+                        instance.getIp(), instance.getPort());
             }
         } catch (SkipFailbackWrapperException exception) {
             throw exception;
@@ -250,8 +250,7 @@ public void doUnregister(final URL url) {
     @Override
     public void doSubscribe(final URL url, final NotifyListener listener) {
         NacosAggregateListener nacosAggregateListener = new NacosAggregateListener(listener);
-        originToAggregateListener
-                .computeIfAbsent(url, k -> new ConcurrentHashMap<>())
+        originToAggregateListener.computeIfAbsent(url, k -> new ConcurrentHashMap<>())
                 .put(listener, nacosAggregateListener);
 
         Set<String> serviceNames = getServiceNames(url, nacosAggregateListener);
@@ -267,14 +266,15 @@ private void doSubscribe(final URL url, final NacosAggregateListener listener, f
                  * Get all instances with serviceNames to avoid instance overwrite and but with empty instance mentioned
                  * in https://github.com/apache/dubbo/issues/5885 and https://github.com/apache/dubbo/issues/5899
                  *
-                 * namingService.getAllInstances with {@link org.apache.dubbo.registry.support.AbstractRegistry#registryUrl}
+                 * namingService.getAllInstances with
+                 * {@link org.apache.dubbo.registry.support.AbstractRegistry#registryUrl}
                  * default {@link DEFAULT_GROUP}
                  *
                  * in https://github.com/apache/dubbo/issues/5978
                  */
                 for (String serviceName : serviceNames) {
-                    List<Instance> instances =
-                            namingService.getAllInstances(serviceName, getUrl().getGroup(Constants.DEFAULT_GROUP));
+                    List<Instance> instances = namingService.getAllInstances(serviceName,
+                            getUrl().getGroup(Constants.DEFAULT_GROUP));
                     notifySubscriber(url, serviceName, listener, instances);
                 }
                 for (String serviceName : serviceNames) {
@@ -283,8 +283,8 @@ private void doSubscribe(final URL url, final NacosAggregateListener listener, f
             } else {
                 for (String serviceName : serviceNames) {
                     List<Instance> instances = new LinkedList<>();
-                    instances.addAll(
-                            namingService.getAllInstances(serviceName, getUrl().getGroup(Constants.DEFAULT_GROUP)));
+                    instances.addAll(namingService.getAllInstances(serviceName,
+                            getUrl().getGroup(Constants.DEFAULT_GROUP)));
                     String serviceInterface = serviceName;
                     String[] segments = serviceName.split(SERVICE_NAME_SEPARATOR, -1);
                     if (segments.length == 4) {
@@ -305,8 +305,8 @@ private void doSubscribe(final URL url, final NacosAggregateListener listener, f
     }
 
     /**
-     * Since 2.7.6 the legacy service name will be added to serviceNames
-     * to fix bug with https://github.com/apache/dubbo/issues/5442
+     * Since 2.7.6 the legacy service name will be added to serviceNames to fix bug with
+     * https://github.com/apache/dubbo/issues/5442
      *
      * @param url
      * @return
@@ -322,13 +322,8 @@ public void doUnsubscribe(URL url, NotifyListener listener) {
         } else {
             Map<NotifyListener, NacosAggregateListener> listenerMap = originToAggregateListener.get(url);
             if (listenerMap == null) {
-                logger.warn(
-                        REGISTRY_NACOS_EXCEPTION,
-                        "",
-                        "",
-                        String.format(
-                                "No aggregate listener found for url %s, this service might have already been unsubscribed.",
-                                url));
+                logger.warn(REGISTRY_NACOS_EXCEPTION, "", "", String.format("No aggregate listener found for url %s, "
+                        + "this service might have already been unsubscribed.", url));
                 return;
             }
             NacosAggregateListener nacosAggregateListener = listenerMap.remove(listener);
@@ -337,12 +332,8 @@ public void doUnsubscribe(URL url, NotifyListener listener) {
                 try {
                     doUnsubscribe(url, nacosAggregateListener, serviceNames);
                 } catch (NacosException e) {
-                    logger.error(
-                            REGISTRY_NACOS_EXCEPTION,
-                            "",
-                            "",
-                            "Failed to unsubscribe " + url + " to nacos " + getUrl() + ", cause: " + e.getMessage(),
-                            e);
+                    logger.error(REGISTRY_NACOS_EXCEPTION, "", "",
+                            "Failed to unsubscribe " + url + " to nacos " + getUrl() + ", cause: " + e.getMessage(), e);
                 }
             }
             if (listenerMap.isEmpty()) {
@@ -352,8 +343,9 @@ public void doUnsubscribe(URL url, NotifyListener listener) {
     }
 
     private void doUnsubscribe(
-            final URL url, final NacosAggregateListener nacosAggregateListener, final Set<String> serviceNames)
-            throws NacosException {
+            final URL url,
+            final NacosAggregateListener nacosAggregateListener,
+            final Set<String> serviceNames) throws NacosException {
         for (String serviceName : serviceNames) {
             unsubscribeEventListener(serviceName, url, nacosAggregateListener);
         }
@@ -392,7 +384,8 @@ private Set<String> getServiceNames0(URL url) {
             if (supportLegacyServiceName) {
                 // Add the legacy service name since 2.7.6
                 String legacySubscribedServiceName = getLegacySubscribedServiceName(url);
-                if (!serviceName.toString().equals(legacySubscribedServiceName)) {
+                if (!serviceName.toString()
+                        .equals(legacySubscribedServiceName)) {
                     // avoid duplicated service names
                     serviceNames.add(legacySubscribedServiceName);
                 }
@@ -407,24 +400,22 @@ private Set<String> getServiceNames0(URL url) {
     private Set<String> filterServiceNames(NacosServiceName serviceName) {
         try {
             Set<String> serviceNames = new LinkedHashSet<>();
-            serviceNames.addAll(
-                    namingService
-                            .getServicesOfServer(1, Integer.MAX_VALUE, getUrl().getGroup(Constants.DEFAULT_GROUP))
-                            .getData()
-                            .stream()
-                            .filter(this::isConformRules)
-                            .map(NacosServiceName::new)
-                            .filter(serviceName::isCompatible)
-                            .map(NacosServiceName::toString)
-                            .collect(Collectors.toList()));
+            serviceNames.addAll(namingService.getServicesOfServer(1, Integer.MAX_VALUE,
+                            getUrl().getGroup(Constants.DEFAULT_GROUP))
+                    .getData()
+                    .stream()
+                    .filter(this::isConformRules)
+                    .map(NacosServiceName::new)
+                    .filter(serviceName::isCompatible)
+                    .map(NacosServiceName::toString)
+                    .collect(Collectors.toList()));
             return serviceNames;
         } catch (SkipFailbackWrapperException exception) {
             throw exception;
         } catch (Throwable cause) {
             throw new RpcException(
                     "Failed to filter serviceName from nacos, url: " + getUrl() + ", serviceName: " + serviceName
-                            + ", cause: " + cause.getMessage(),
-                    cause);
+                            + ", cause: " + cause.getMessage(), cause);
         }
     }
 
@@ -457,7 +448,8 @@ private String getLegacySubscribedServiceName(URL url) {
     private void appendIfPresent(StringBuilder target, URL url, String parameterName) {
         String parameterValue = url.getParameter(parameterName);
         if (!StringUtils.isBlank(parameterValue)) {
-            target.append(SERVICE_NAME_SEPARATOR).append(parameterValue);
+            target.append(SERVICE_NAME_SEPARATOR)
+                    .append(parameterValue);
         }
     }
 
@@ -468,25 +460,21 @@ private boolean isAdminProtocol(URL url) {
     private void scheduleServiceNamesLookup(final URL url, final NacosAggregateListener listener) {
         if (scheduledExecutorService == null) {
             scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
-            scheduledExecutorService.scheduleAtFixedRate(
-                    () -> {
-                        Set<String> serviceNames = getAllServiceNames();
-                        filterData(serviceNames, serviceName -> {
-                            boolean accepted = false;
-                            for (String category : ALL_SUPPORTED_CATEGORIES) {
-                                String prefix = category + SERVICE_NAME_SEPARATOR;
-                                if (serviceName != null && serviceName.startsWith(prefix)) {
-                                    accepted = true;
-                                    break;
-                                }
-                            }
-                            return accepted;
-                        });
-                        doSubscribe(url, listener, serviceNames);
-                    },
-                    LOOKUP_INTERVAL,
-                    LOOKUP_INTERVAL,
-                    TimeUnit.SECONDS);
+            scheduledExecutorService.scheduleAtFixedRate(() -> {
+                Set<String> serviceNames = getAllServiceNames();
+                filterData(serviceNames, serviceName -> {
+                    boolean accepted = false;
+                    for (String category : ALL_SUPPORTED_CATEGORIES) {
+                        String prefix = category + SERVICE_NAME_SEPARATOR;
+                        if (serviceName != null && serviceName.startsWith(prefix)) {
+                            accepted = true;
+                            break;
+                        }
+                    }
+                    return accepted;
+                });
+                doSubscribe(url, listener, serviceNames);
+            }, LOOKUP_INTERVAL, LOOKUP_INTERVAL, TimeUnit.SECONDS);
         }
     }
 
@@ -506,8 +494,8 @@ private Set<String> getAllServiceNames() {
         try {
             final Set<String> serviceNames = new LinkedHashSet<>();
             int pageIndex = 1;
-            ListView<String> listView = namingService.getServicesOfServer(
-                    pageIndex, PAGINATION_SIZE, getUrl().getGroup(Constants.DEFAULT_GROUP));
+            ListView<String> listView = namingService.getServicesOfServer(pageIndex, PAGINATION_SIZE,
+                    getUrl().getGroup(Constants.DEFAULT_GROUP));
             // First page data
             List<String> firstPageData = listView.getData();
             // Append first page into list
@@ -523,17 +511,16 @@ private Set<String> getAllServiceNames() {
             }
             // If more than 1 page
             while (pageIndex < pageNumbers) {
-                listView = namingService.getServicesOfServer(
-                        ++pageIndex, PAGINATION_SIZE, getUrl().getGroup(Constants.DEFAULT_GROUP));
+                listView = namingService.getServicesOfServer(++pageIndex, PAGINATION_SIZE,
+                        getUrl().getGroup(Constants.DEFAULT_GROUP));
                 serviceNames.addAll(listView.getData());
             }
             return serviceNames;
         } catch (SkipFailbackWrapperException exception) {
             throw exception;
         } catch (Throwable cause) {
-            throw new RpcException(
-                    "Failed to get all serviceName from nacos, url: " + getUrl() + ", cause: " + cause.getMessage(),
-                    cause);
+            throw new RpcException("Failed to get all serviceName from nacos, url: " + getUrl() + ", cause: "
+                    + cause.getMessage(), cause);
         }
     }
 
@@ -614,11 +601,8 @@ private List<URL> toUrlWithEmpty(URL consumerURL, Collection<Instance> instances
         List<URL> urls = buildURLs(consumerURL, instances);
         // Nacos does not support configurators and routers from registry, so all notifications are of providers type.
         if (urls.size() == 0 && !getUrl().getParameter(ENABLE_EMPTY_PROTECTION_KEY, DEFAULT_ENABLE_EMPTY_PROTECTION)) {
-            logger.warn(
-                    REGISTRY_NACOS_EXCEPTION,
-                    "",
-                    "",
-                    "Received empty url address list and empty protection is disabled, will clear current available addresses");
+            logger.warn(REGISTRY_NACOS_EXCEPTION, "", "", "Received empty url address list and empty protection is "
+                    + "disabled, will clear current available addresses");
             URL empty = URLBuilder.from(consumerURL)
                     .setProtocol(EMPTY_PROTOCOL)
                     .addParameter(CATEGORY_KEY, DEFAULT_CATEGORY)
@@ -641,21 +625,25 @@ private List<URL> buildURLs(URL consumerURL, Collection<Instance> instances) {
         return urls;
     }
 
-    private void subscribeEventListener(String serviceName, final URL url, final NacosAggregateListener listener)
-            throws NacosException {
-        Map<NacosAggregateListener, Map<String, EventListener>> listeners =
-                nacosListeners.computeIfAbsent(url, k -> new ConcurrentHashMap<>());
+    private void subscribeEventListener(
+            String serviceName,
+            final URL url,
+            final NacosAggregateListener listener) throws NacosException {
+        Map<NacosAggregateListener, Map<String, EventListener>> listeners = nacosListeners.computeIfAbsent(url,
+                k -> new ConcurrentHashMap<>());
 
         Map<String, EventListener> eventListeners = listeners.computeIfAbsent(listener, k -> new ConcurrentHashMap<>());
 
-        EventListener eventListener = eventListeners.computeIfAbsent(
-                serviceName, k -> new RegistryChildListenerImpl(serviceName, url, listener));
+        EventListener eventListener = eventListeners.computeIfAbsent(serviceName,
+                k -> new RegistryChildListenerImpl(serviceName, url, listener));
 
         namingService.subscribe(serviceName, getUrl().getGroup(Constants.DEFAULT_GROUP), eventListener);
     }
 
-    private void unsubscribeEventListener(String serviceName, final URL url, final NacosAggregateListener listener)
-            throws NacosException {
+    private void unsubscribeEventListener(
+            String serviceName,
+            final URL url,
+            final NacosAggregateListener listener) throws NacosException {
         Map<NacosAggregateListener, Map<String, EventListener>> listenerToServiceEvent = nacosListeners.get(url);
         if (listenerToServiceEvent == null) {
             return;
@@ -668,8 +656,8 @@ private void unsubscribeEventListener(String serviceName, final URL url, final N
         if (eventListener == null) {
             return;
         }
-        namingService.unsubscribe(
-                serviceName, getUrl().getParameter(GROUP_KEY, Constants.DEFAULT_GROUP), eventListener);
+        namingService.unsubscribe(serviceName, getUrl().getParameter(GROUP_KEY, Constants.DEFAULT_GROUP),
+                eventListener);
         if (serviceToEventMap.isEmpty()) {
             listenerToServiceEvent.remove(listener);
         }
@@ -692,8 +680,8 @@ private void notifySubscriber(
             //  Instances
             filterEnabledInstances(enabledInstances);
         }
-        List<URL> aggregatedUrls =
-                toUrlWithEmpty(url, listener.saveAndAggregateAllInstances(serviceName, enabledInstances));
+        List<URL> aggregatedUrls = toUrlWithEmpty(url, listener.saveAndAggregateAllInstances(serviceName,
+                enabledInstances));
         NacosRegistry.this.notify(url, listener.getNotifyListener(), aggregatedUrls);
     }
 
@@ -809,8 +797,7 @@ public boolean equals(Object o) {
                 return false;
             }
             RegistryChildListenerImpl that = (RegistryChildListenerImpl) o;
-            return Objects.equals(serviceName, that.serviceName)
-                    && Objects.equals(consumerUrl, that.consumerUrl)
+            return Objects.equals(serviceName, that.serviceName) && Objects.equals(consumerUrl, that.consumerUrl)
                     && Objects.equals(listener, that.listener);
         }