netty: fix leak + disconnected websocket clients

- WebSocket onClose not called for Netty fix #3452
- Memory leak in jooby-netty fix #3453

Author: jknack

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyHandler.java

@@ -99,12 +99,17 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
         }
       }
     } else if (isLastHttpContent(msg)) {
-      // when decoder == null, chunk is always a LastHttpContent.EMPTY, ignore it
-      if (context.decoder != null) {
-        offer(context, (HttpContent) msg);
-        Router.Match route = router.match(context);
-        resetDecoderState(context, !route.matches());
-        route.execute(context);
+      var chunk = (HttpContent) msg;
+      try {
+        // when decoder == null, chunk is always a LastHttpContent.EMPTY, ignore it
+        if (context.decoder != null) {
+          offer(context, chunk);
+          Router.Match route = router.match(context);
+          resetDecoderState(context, !route.matches());
+          route.execute(context);
+        }
+      } finally {
+        release(chunk);
       }
     } else if (isHttpContent(msg)) {
       var chunk = (HttpContent) msg;

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyWebSocket.java

@@ -103,7 +103,9 @@ public NettyWebSocket(NettyContext ctx) {
     this.netty = ctx;
     this.key = ctx.getRoute().getPattern();
     this.dispatch = !ctx.isInIoThread();
-    this.netty.ctx.channel().attr(WS).set(this);
+    var channel = this.netty.ctx.channel();
+    channel.attr(WS).set(this);
+    channel.closeFuture().addListener(future -> handleClose(WebSocketCloseStatus.GOING_AWAY));
   }
 
   @NonNull @Override