Release netty ByteBuf after use (#2835)

core/src/main/java/com/taobao/arthas/core/command/basic1000/Base64Command.java

@@ -112,12 +112,12 @@ public class Base64Command extends AnnotatedCommand {
         }
 
         InputStream input = null;
+        ByteBuf convertResult = null;
 
         try {
             input = new FileInputStream(f);
             byte[] bytes = IOUtils.getBytes(input);
 
-            ByteBuf convertResult = null;
             if (this.decode) {
                 convertResult = Base64.decode(Unpooled.wrappedBuffer(bytes));
             } else {
@@ -138,6 +138,9 @@ public class Base64Command extends AnnotatedCommand {
             process.end(1, "read file error: " + e.getMessage());
             return;
         } finally {
+            if (convertResult != null) {
+                convertResult.release();
+            }
             IOUtils.close(input);
         }
 

tunnel-client/src/main/java/com/alibaba/arthas/tunnel/client/ProxyClient.java

@@ -134,7 +134,9 @@ public class ProxyClient {
             if (msg instanceof HttpContent) {
                 HttpContent content = (HttpContent) msg;
 
-                ByteBuf byteBuf = content.content();
+                ByteBuf byteBuf = null;
+                try{
+                    byteBuf = content.content();
                     byte[] bytes = new byte[byteBuf.readableBytes()];
                     byteBuf.readBytes(bytes);
 
@@ -145,6 +147,12 @@ public class ProxyClient {
                     if (content instanceof LastHttpContent) {
                         ctx.close();
                     }
+                }finally {
+                    if (byteBuf != null) {
+                        byteBuf.release();
+                    }
+                }
+
             }
         }
 

tunnel-client/src/main/java/com/alibaba/arthas/tunnel/client/TunnelClientSocketClientHandler.java

@@ -120,7 +120,9 @@ public class TunnelClientSocketClientHandler extends SimpleChannelInboundHandler
                     String targetUrl = targetUrls.get(0);
                     SimpleHttpResponse simpleHttpResponse = proxyClient.query(targetUrl);
 
-                    ByteBuf byteBuf = Base64
+                    ByteBuf byteBuf = null;
+                    try{
+                        byteBuf = Base64
                                 .encode(Unpooled.wrappedBuffer(SimpleHttpResponse.toBytes(simpleHttpResponse)));
                         String requestData = byteBuf.toString(CharsetUtil.UTF_8);
 
@@ -131,6 +133,11 @@ public class TunnelClientSocketClientHandler extends SimpleChannelInboundHandler
 
                         String url = queryEncoder.toString();
                         ctx.writeAndFlush(new TextWebSocketFrame(url));
+                    }finally {
+                        if (byteBuf != null) {
+                            byteBuf.release();
+                        }
+                    }
                 }
             }