fix mem leak

Author: qianye1001

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java

@@ -836,15 +836,9 @@ public CompletableFuture<ResponseFuture> invokeImpl(final Channel channel, final
                     LOGGER.info("Receive go away from channelId={}, channel={}", channel.id(), channel);
                     ChannelWrapper channelWrapper = RemotingHelper.getAttributeValue(CHANNEL_WRAPPER_ATTRIBUTE_KEY,
                         channel);
-                    if (channelWrapper != null) {
-                        try {
-                            if (channelWrapper.reconnect(channel)) {
-                                LOGGER.info("Receive go away from channelId={}, channel={}, recreate the "
-                                    + "channelId={}", channel.id(), channel, channelWrapper.getChannel().id());
-                            }
-                        } catch (Throwable t) {
-                            LOGGER.error("Channel {} reconnect error", channelWrapper, t);
-                        }
+                    if (channelWrapper != null && channelWrapper.reconnect(channel)) {
+                        LOGGER.info("Receive go away from channelId={}, channel={}, recreate the channelId={}",
+                            channel.id(), channel, channelWrapper.getChannel().id());
                     }
                     if (channelWrapper != null && !channelWrapper.isWrapperOf(channel)) {
                         RemotingCommand retryRequest = RemotingCommand.createRequestCommand(request.getCode(), request.readCustomHeader());
@@ -1065,6 +1059,8 @@ public boolean reconnect(Channel channel) {
                     } else {
                         LOGGER.warn("channelWrapper has reconnect, so do nothing, now channelId={}, input channelId={}",getChannel().id(), channel.id());
                     }
+                } catch (Throwable t) {
+                    LOGGER.error("ChannelWrapper {} reconnect error", this, t);
                 } finally {
                     lock.writeLock().unlock();
                 }