1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.socksproxy;
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.socks.SocksInitRequestDecoder;
22 import io.netty.handler.codec.socks.SocksMessageEncoder;
23
24 public final class SocksServerInitializer extends ChannelInitializer<SocketChannel> {
25
26 private final SocksMessageEncoder socksMessageEncoder = new SocksMessageEncoder();
27 private final SocksServerHandler socksServerHandler = new SocksServerHandler();
28
29 @Override
30 public void initChannel(SocketChannel socketChannel) throws Exception {
31 ChannelPipeline p = socketChannel.pipeline();
32 p.addLast(new SocksInitRequestDecoder());
33 p.addLast(socksMessageEncoder);
34 p.addLast(socksServerHandler);
35 }
36 }