destroy invoker before client

apache · Jul 22, 2021 · 7534b83 · 7534b83
1 parent b7ddcac
commit 7534b83
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/...rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java b/...rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java
@@ -437,6 +437,9 @@ public void destroy() {
                 }
             }
         }
+        // put here to reduce the chance of accepting new invocation after client closed.
+        // close invoker and then client.
+        super.destroy();
 
         for (String key : new ArrayList<String>(referenceClientMap.keySet())) {
             ExchangeClient client = referenceClientMap.remove(key);
@@ -466,6 +469,5 @@ public void destroy() {
             }
         }
         stubServiceMethodsMap.clear();
-        super.destroy();
     }
 }
diff --git a/...c-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java b/...c-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java
@@ -115,7 +115,7 @@ public ResponseFuture request(Object request, int timeout) throws RemotingExcept
     private void warning(Object request) {
         if (requestWithWarning) {
             if (warningcount.get() % 5000 == 0) {
-                logger.warn(url.getAddress() + " " + url.getServiceKey() + "safe guard client , should not be called ,must have a bug.");
+                logger.warn(url.getAddress() + " " + url.getServiceKey() + " safeguard client get called after real client closed, recreating connection...");
             }
             warningcount.incrementAndGet();
         }

diff --git a/...ubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java b/...ubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java
@@ -167,7 +167,9 @@ public void startClose() {
     private LazyConnectExchangeClient replaceWithLazyClient() {
         // this is a defensive operation to avoid client is closed by accident, the initial state of the client is false
         URL lazyUrl = url.addParameter(Constants.LAZY_CONNECT_INITIAL_STATE_KEY, Boolean.TRUE)
-                .addParameter(Constants.SEND_RECONNECT_KEY, Boolean.TRUE.toString());
+                .addParameter(Constants.SEND_RECONNECT_KEY, Boolean.TRUE.toString())
+                .addParameter(LazyConnectExchangeClient.REQUEST_WITH_WARNING_KEY, true);
+
 
         String key = url.getAddress();
         // in worst case there's only one ghost connection.