Fix mistaken deletion of reconnect interval (#15613)

Author: oxsean

dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/AbstractNettyConnectionClient.java

@@ -177,15 +177,21 @@ protected void doDisConnect() {
         NettyChannel.removeChannelIfDisconnected(getNettyChannel());
     }
 
-    protected void doReconnect() {
-        connectivityExecutor.execute(() -> {
-            try {
-                doConnect();
-            } catch (RemotingException e) {
-                logger.error(
-                        TRANSPORT_FAILED_RECONNECT, "", "", "Failed to reconnect to server: " + getConnectAddress());
-            }
-        });
+    protected void scheduleReconnect(long reconnectDuration, TimeUnit unit) {
+        connectivityExecutor.schedule(
+                () -> {
+                    try {
+                        doConnect();
+                    } catch (RemotingException e) {
+                        logger.error(
+                                TRANSPORT_FAILED_RECONNECT,
+                                "",
+                                "",
+                                "Failed to connect to server: " + getConnectAddress());
+                    }
+                },
+                reconnectDuration,
+                unit);
     }
 
     @Override
@@ -378,7 +384,7 @@ public void operationComplete(ChannelFuture future) {
             // Notify the connection is unavailable.
             disconnectedPromise.trySuccess(null);
 
-            doReconnect();
+            scheduleReconnect(reconnectDuration, TimeUnit.MILLISECONDS);
         }
     }
 }

dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyConnectionHandler.java

@@ -26,7 +26,6 @@
 import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
-import io.netty.channel.EventLoop;
 import io.netty.util.Attribute;
 import io.netty.util.AttributeKey;
 
@@ -71,16 +70,14 @@ public void reconnect(Object channel) {
         if (!(channel instanceof Channel)) {
             return;
         }
-        Channel nettyChannel = ((Channel) channel);
         if (LOGGER.isDebugEnabled()) {
             LOGGER.debug("Connection:{} is reconnecting, attempt={}", connectionClient, 1);
         }
-        EventLoop eventLoop = nettyChannel.eventLoop();
         if (connectionClient.isClosed()) {
             LOGGER.info("The connection {} has been closed and will not reconnect", connectionClient);
             return;
         }
-        eventLoop.schedule(connectionClient::doReconnect, 1, TimeUnit.SECONDS);
+        connectionClient.scheduleReconnect(1, TimeUnit.SECONDS);
     }
 
     @Override