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.HttpClientCodec;
22 import io.netty.handler.codec.http.HttpContentDecompressor;
23 import io.netty.handler.ssl.SslContext;
24 import io.netty.handler.stream.ChunkedWriteHandler;
25
26 public class HttpUploadClientInitializer extends ChannelInitializer<SocketChannel> {
27
28 private static final int MAX_CONTENT_LENGTH = 65536;
29
30 private final SslContext sslCtx;
31
32 public HttpUploadClientInitializer(SslContext sslCtx) {
33 this.sslCtx = sslCtx;
34 }
35
36 @Override
37 public void initChannel(SocketChannel ch) {
38 ChannelPipeline pipeline = ch.pipeline();
39
40 if (sslCtx != null) {
41 pipeline.addLast("ssl", sslCtx.newHandler(ch.alloc()));
42 }
43
44 pipeline.addLast("codec", new HttpClientCodec());
45
46
47 pipeline.addLast("inflater", new HttpContentDecompressor(MAX_CONTENT_LENGTH));
48
49
50 pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());
51
52 pipeline.addLast("handler", new HttpUploadClientHandler());
53 }
54 }