httpCompression and websocketCompression settings added. #313

src/main/java/com/corundumstudio/socketio/Configuration.java

@@ -78,6 +78,10 @@ public class Configuration {
 
     private String origin;
 
+    private boolean httpCompression = true;
+
+    private boolean websocketCompression = true;
+
     public Configuration() {
     }
 
@@ -139,6 +143,9 @@ public class Configuration {
         setAddVersionHeader(conf.isAddVersionHeader());
         setOrigin(conf.getOrigin());
         setSSLProtocol(conf.getSSLProtocol());
+
+        setHttpCompression(conf.isHttpCompression());
+        setWebsocketCompression(conf.isWebsocketCompression());
     }
 
     public JsonSupport getJsonSupport() {
@@ -463,6 +470,7 @@ public class Configuration {
 
     /**
      * Adds <b>Server</b> header with lib version to http response.
+     * <p/>
      * Default is <code>true</code>
      *
      * @param addVersionHeader
@@ -513,7 +521,7 @@ public class Configuration {
      * Timeout between channel opening and first data transfer
      * Helps to avoid 'silent channel' attack and prevents
      * 'Too many open files' problem in this case
-     * 
+     *
      * @param firstDataTimeout
      */
     public void setFirstDataTimeout(int firstDataTimeout) {
@@ -523,4 +531,34 @@ public class Configuration {
         return firstDataTimeout;
     }
 
+    /**
+     * Activate http protocol compression. Uses {@code gzip} or
+     * {@code deflate} encoding choice depends on the {@code "Accept-Encoding"} header value.
+     * <p/>
+     * Default is <code>true</code>
+     *
+     * @param httpCompression
+     */
+    public void setHttpCompression(boolean httpCompression) {
+        this.httpCompression = httpCompression;
+    }
+    public boolean isHttpCompression() {
+        return httpCompression;
+    }
+
+    /**
+     * Activate websocket protocol compression.
+     * Uses {@code permessage-deflate} encoding only.
+     * <p/>
+     * Default is <code>true</code>
+     *
+     * @param websocketCompression
+     */
+    public void setWebsocketCompression(boolean websocketCompression) {
+        this.websocketCompression = websocketCompression;
+    }
+    public boolean isWebsocketCompression() {
+        return websocketCompression;
+    }
+
 }

src/main/java/com/corundumstudio/socketio/SocketIOChannelInitializer.java

@@ -178,14 +178,18 @@ public class SocketIOChannelInitializer extends ChannelInitializer<Channel> impl
         });
         pipeline.addLast(HTTP_ENCODER, new HttpResponseEncoder());
 
-        pipeline.addLast(HTTP_COMPRESSION, new HttpContentCompressor());
+        if (configuration.isHttpCompression()) {
+            pipeline.addLast(HTTP_COMPRESSION, new HttpContentCompressor());
+        }
 
         pipeline.addLast(PACKET_HANDLER, packetHandler);
 
         pipeline.addLast(AUTHORIZE_HANDLER, authorizeHandler);
         pipeline.addLast(XHR_POLLING_TRANSPORT, xhrPollingTransport);
         // TODO use single instance when https://github.com/netty/netty/issues/4755 will be resolved
-        pipeline.addLast(WEB_SOCKET_TRANSPORT_COMPRESSION, new WebSocketServerCompressionHandler());
+        if (configuration.isWebsocketCompression()) {
+            pipeline.addLast(WEB_SOCKET_TRANSPORT_COMPRESSION, new WebSocketServerCompressionHandler());
+        }
         pipeline.addLast(WEB_SOCKET_TRANSPORT, webSocketTransport);
 
         pipeline.addLast(SOCKETIO_ENCODER, encoderHandler);