|
|
@ -55,7 +55,6 @@ import io.netty.handler.codec.http.HttpMessage; |
|
|
|
import io.netty.handler.codec.http.HttpObjectAggregator; |
|
|
|
import io.netty.handler.codec.http.HttpObjectAggregator; |
|
|
|
import io.netty.handler.codec.http.HttpRequestDecoder; |
|
|
|
import io.netty.handler.codec.http.HttpRequestDecoder; |
|
|
|
import io.netty.handler.codec.http.HttpResponseEncoder; |
|
|
|
import io.netty.handler.codec.http.HttpResponseEncoder; |
|
|
|
import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler; |
|
|
|
|
|
|
|
import io.netty.handler.ssl.SslHandler; |
|
|
|
import io.netty.handler.ssl.SslHandler; |
|
|
|
|
|
|
|
|
|
|
|
public class SocketIOChannelInitializer extends ChannelInitializer<Channel> implements DisconnectableHub { |
|
|
|
public class SocketIOChannelInitializer extends ChannelInitializer<Channel> implements DisconnectableHub { |
|
|
@ -186,7 +185,8 @@ public class SocketIOChannelInitializer extends ChannelInitializer<Channel> impl |
|
|
|
pipeline.addLast(XHR_POLLING_TRANSPORT, xhrPollingTransport); |
|
|
|
pipeline.addLast(XHR_POLLING_TRANSPORT, xhrPollingTransport); |
|
|
|
// TODO use single instance when https://github.com/netty/netty/issues/4755 will be resolved
|
|
|
|
// TODO use single instance when https://github.com/netty/netty/issues/4755 will be resolved
|
|
|
|
if (configuration.isWebsocketCompression()) { |
|
|
|
if (configuration.isWebsocketCompression()) { |
|
|
|
pipeline.addLast(WEB_SOCKET_TRANSPORT_COMPRESSION, new WebSocketServerCompressionHandler()); |
|
|
|
// TODO:richie 去掉了压缩
|
|
|
|
|
|
|
|
//pipeline.addLast(WEB_SOCKET_TRANSPORT_COMPRESSION, new WebSocketServerCompressionHandler());
|
|
|
|
} |
|
|
|
} |
|
|
|
pipeline.addLast(WEB_SOCKET_TRANSPORT, webSocketTransport); |
|
|
|
pipeline.addLast(WEB_SOCKET_TRANSPORT, webSocketTransport); |
|
|
|
|
|
|
|
|
|
|
|