[dubbo] branch 3.0 updated: Fix MetadataService connections leak (#8555)

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new f7933b7  Fix MetadataService connections leak (#8555)
f7933b7 is described below

commit f7933b735b4e051b7378418cc0688c3c3890069b
Author: Albumen Kevin <jh...@gmail.com>
AuthorDate: Mon Aug 23 13:40:12 2021 +0800

    Fix MetadataService connections leak (#8555)
---
 .../registry/client/event/listener/ServiceInstancesChangedListener.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/event/listener/ServiceInstancesChangedListener.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/event/listener/ServiceInstancesChangedListener.java
index bae3450..a023275 100644
--- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/event/listener/ServiceInstancesChangedListener.java
+++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/event/listener/ServiceInstancesChangedListener.java
@@ -336,6 +336,7 @@ public class ServiceInstancesChangedListener {
                 // change the instance used to communicate to avoid all requests route to the same instance
                 MetadataService metadataServiceProxy = MetadataUtils.getMetadataServiceProxy(instance);
                 metadataInfo = metadataServiceProxy.getMetadataInfo(ServiceInstanceMetadataUtils.getExportedServicesRevision(instance));
+                MetadataUtils.destroyMetadataServiceProxy(instance);
             }
         } catch (Exception e) {
             logger.error("Failed to load service metadata, meta type is " + metadataType, e);