1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.http.websocketx.server;
17
18 import io.netty.channel.ChannelInitializer;
19 import io.netty.channel.ChannelPipeline;
20 import io.netty.channel.socket.SocketChannel;
21 import io.netty.handler.codec.http.HttpObjectAggregator;
22 import io.netty.handler.codec.http.HttpServerCodec;
23 import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
24 import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler;
25 import io.netty.handler.ssl.SslContext;
26
27
28
29 public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {
30
31 private static final String WEBSOCKET_PATH = "/websocket";
32
33 private static final int MAX_CONTENT_LENGTH = 65536;
34
35 private final SslContext sslCtx;
36
37 public WebSocketServerInitializer(SslContext sslCtx) {
38 this.sslCtx = sslCtx;
39 }
40
41 @Override
42 public void initChannel(SocketChannel ch) throws Exception {
43 ChannelPipeline pipeline = ch.pipeline();
44 if (sslCtx != null) {
45 pipeline.addLast(sslCtx.newHandler(ch.alloc()));
46 }
47 pipeline.addLast(new HttpServerCodec());
48 pipeline.addLast(new HttpObjectAggregator(MAX_CONTENT_LENGTH));
49 pipeline.addLast(new WebSocketIndexPageHandler(WEBSOCKET_PATH));
50 pipeline.addLast(new WebSocketServerCompressionHandler(MAX_CONTENT_LENGTH));
51 pipeline.addLast(new WebSocketServerProtocolHandler(WEBSOCKET_PATH, null, true));
52 pipeline.addLast(new WebSocketFrameHandler());
53 }
54 }