diff --git a/pom.xml b/pom.xml
index 47ef3fbebd89aae778270c21e474f172221e4a6e..a315bdf55b4079cd6ab8c8780364b7dd7e6b4845 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 820e61b4caa269d3e133dff4d6b0e504dc2025b5..276ee7b6572c6d9ee0d1889bad458b16347181af 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 4a26007a05ae13cd939fb011adf0e54a2d73ff44..4a15f6e8d8d5db14feee8635aaa90b037bcac6da 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));
                         }