1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.http.file;
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.ssl.SslContext;
24 import io.netty.handler.stream.ChunkedWriteHandler;
25
26 public class HttpStaticFileServerInitializer extends ChannelInitializer<SocketChannel> {
27
28 private final SslContext sslCtx;
29
30 public HttpStaticFileServerInitializer(SslContext sslCtx) {
31 this.sslCtx = sslCtx;
32 }
33
34 @Override
35 public void initChannel(SocketChannel ch) {
36 ChannelPipeline pipeline = ch.pipeline();
37 if (sslCtx != null) {
38 pipeline.addLast(sslCtx.newHandler(ch.alloc()));
39 }
40 pipeline.addLast(new HttpServerCodec());
41 pipeline.addLast(new HttpObjectAggregator(65536));
42 pipeline.addLast(new ChunkedWriteHandler());
43 pipeline.addLast(new HttpStaticFileServerHandler());
44 }
45 }