From 1be2aff186eeee056f9cd75e7476887afad091a9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=94=BE=E7=89=9B=E7=8F=AD=E7=9A=84=E5=B0=8F=E5=9C=9F?=
 =?UTF-8?q?=E8=B1=86?= <fenglicheng1@163.com>
Date: Fri, 28 Feb 2025 09:07:41 +0000
Subject: [PATCH] =?UTF-8?q?fix:=20websocket=E5=BC=80=E5=90=AF=E5=8E=8B?=
 =?UTF-8?q?=E7=BC=A9=E5=A4=B1=E6=95=88=E9=97=AE=E9=A2=98=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: 放牛班的小土豆 <fenglicheng1@163.com>
---
 pom.xml                                                  | 2 +-
 src/main/java/org/yeauty/standard/HttpServerHandler.java | 4 +---
 src/main/java/org/yeauty/standard/WebsocketServer.java   | 3 +++
 3 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/pom.xml b/pom.xml
index 47ef3fb..a315bdf 100644
--- a/pom.xml
+++ b/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>
diff --git a/src/main/java/org/yeauty/standard/HttpServerHandler.java b/src/main/java/org/yeauty/standard/HttpServerHandler.java
index 820e61b..276ee7b 100755
--- a/src/main/java/org/yeauty/standard/HttpServerHandler.java
+++ b/src/main/java/org/yeauty/standard/HttpServerHandler.java
@@ -231,9 +231,7 @@ class HttpServerHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
             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));
diff --git a/src/main/java/org/yeauty/standard/WebsocketServer.java b/src/main/java/org/yeauty/standard/WebsocketServer.java
index 4a26007..4a15f6e 100755
--- a/src/main/java/org/yeauty/standard/WebsocketServer.java
+++ b/src/main/java/org/yeauty/standard/WebsocketServer.java
@@ -84,6 +84,9 @@ public class WebsocketServer {
                         }
                         pipeline.addLast(new HttpServerCodec());
                         pipeline.addLast(new HttpObjectAggregator(65536));
+                        if (config.isUseCompressionHandler()) {
+                            pipeline.addLast(new WebSocketServerCompressionHandler());
+                        }
                         if (corsConfig != null) {
                             pipeline.addLast(new CorsHandler(corsConfig));
                         }
-- 
Gitee