Bug fixed: WebSocketServerCompressionHandler invalid

Author: Tangshengbo

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>org.yeauty</groupId>
     <artifactId>netty-websocket-spring-boot-starter</artifactId>
-    <version>0.12.0</version>
+    <version>0.12.1</version>
 
     <name>netty-websocket-spring-boot-starter</name>
     <description>

src/main/java/org/yeauty/standard/HttpServerHandler.java

@@ -219,21 +219,23 @@ private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest req) {
                 subprotocols = ctx.channel().attr(subprotocolsAttrKey).get();
             }
         }
-
+        ChannelPipeline pipeline = ctx.pipeline();
+        if (config.isUseCompressionHandler()) {
+            // Add WebSocketServerCompressionHandler, but don't shake hands
+            pipeline.addLast(new WebSocketServerCompressionHandler());
+            // Let the request by WebSocketServerCompressionHandler forwarding to the next handler
+            ctx.fireChannelRead(req.retain());
+        }
         // Handshake
         WebSocketServerHandshakerFactory wsFactory = new WebSocketServerHandshakerFactory(getWebSocketLocation(req), subprotocols, true, config.getmaxFramePayloadLength());
         WebSocketServerHandshaker handshaker = wsFactory.newHandshaker(req);
         if (handshaker == null) {
             WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(channel);
         } else {
-            ChannelPipeline pipeline = ctx.pipeline();
             pipeline.remove(ctx.name());
             if (config.getReaderIdleTimeSeconds() != 0 || config.getWriterIdleTimeSeconds() != 0 || config.getAllIdleTimeSeconds() != 0) {
                 pipeline.addLast(new IdleStateHandler(config.getReaderIdleTimeSeconds(), config.getWriterIdleTimeSeconds(), config.getAllIdleTimeSeconds()));
             }
-            if (config.isUseCompressionHandler()) {
-                pipeline.addLast(new WebSocketServerCompressionHandler());
-            }
             pipeline.addLast(new WebSocketFrameAggregator(Integer.MAX_VALUE));
             if (config.isUseEventExecutorGroup()) {
                 pipeline.addLast(eventExecutorGroup, new WebSocketServerHandler(pojoEndpointServer));