blob: 9d0618ff1c49258c7d34c6ed3f67cd7ce4f8b0dd (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
package spark.network.netty;
import java.io.File;
import io.netty.buffer.BufType;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
import io.netty.handler.codec.Delimiters;
import io.netty.util.CharsetUtil;
import io.netty.handler.logging.LoggingHandler;
import io.netty.handler.logging.LogLevel;
public class FileServerChannelInitializer extends
ChannelInitializer<SocketChannel> {
PathResolver pResolver;
public FileServerChannelInitializer(PathResolver pResolver) {
this.pResolver = pResolver;
}
@Override
public void initChannel(SocketChannel channel) {
channel.pipeline()
.addLast("framer", new DelimiterBasedFrameDecoder(
8192, Delimiters.lineDelimiter()))
.addLast("strDecoder", new StringDecoder())
.addLast("handler", new FileServerHandler(pResolver));
}
}
|