1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.http.upload;
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.HttpContentCompressor;
22 import io.netty.handler.codec.http.HttpRequestDecoder;
23 import io.netty.handler.codec.http.HttpResponseEncoder;
24 import io.netty.handler.ssl.SslContext;
25
26 public class HttpUploadServerInitializer extends ChannelInitializer<SocketChannel> {
27
28 private final SslContext sslCtx;
29
30 public HttpUploadServerInitializer(SslContext sslCtx) {
31 this.sslCtx = sslCtx;
32 }
33
34 @Override
35 public void initChannel(SocketChannel ch) {
36 ChannelPipeline pipeline = ch.pipeline();
37
38 if (sslCtx != null) {
39 pipeline.addLast(sslCtx.newHandler(ch.alloc()));
40 }
41
42 pipeline.addLast(new HttpRequestDecoder());
43 pipeline.addLast(new HttpResponseEncoder());
44
45
46 pipeline.addLast(new HttpContentCompressor());
47
48 pipeline.addLast(new HttpUploadServerHandler());
49 }
50 }