[Chore] Remove channelsLock on onChannelInactive to avoid deadlock (#17084)

Author: ruanwenjun

dolphinscheduler-extract/dolphinscheduler-extract-base/src/main/java/org/apache/dolphinscheduler/extract/base/client/NettyClientHandler.java

@@ -43,7 +43,8 @@ public NettyClientHandler(NettyRemotingClient nettyRemotingClient) {
 
     @Override
     public void channelInactive(ChannelHandlerContext ctx) {
-        nettyRemotingClient.closeChannel(ChannelUtils.toAddress(ctx.channel()));
+        log.info("Channel inactive: {}", ctx.channel());
+        nettyRemotingClient.onChannelInactive(ChannelUtils.toAddress(ctx.channel()));
         ctx.channel().close();
     }
 
@@ -65,8 +66,8 @@ private void processReceived(final Transporter transporter) {
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-        log.error("NettyClientHandler catch an exception : {}", cause.getMessage(), cause);
-        nettyRemotingClient.closeChannel(ChannelUtils.toAddress(ctx.channel()));
+        log.error("NettyClientHandler catch an exception on channel: {}", ctx.channel(), cause);
+        nettyRemotingClient.onChannelInactive(ChannelUtils.toAddress(ctx.channel()));
         ctx.channel().close();
     }
 

dolphinscheduler-extract/dolphinscheduler-extract-base/src/main/java/org/apache/dolphinscheduler/extract/base/client/NettyRemotingClient.java

@@ -247,20 +247,13 @@ private void closeChannels() {
         try {
             channelsLock.lock();
             channels.values().forEach(Channel::close);
+            channels.clear();
         } finally {
             channelsLock.unlock();
         }
     }
 
-    public void closeChannel(Host host) {
-        try {
-            channelsLock.lock();
-            Channel channel = this.channels.remove(host);
-            if (channel != null) {
-                channel.close();
-            }
-        } finally {
-            channelsLock.unlock();
-        }
+    public void onChannelInactive(final Host host) {
+        channels.remove(host);
     }
 }