1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.discard;
17
18 import io.netty.bootstrap.ServerBootstrap;
19 import io.netty.channel.ChannelFuture;
20 import io.netty.channel.ChannelInitializer;
21 import io.netty.channel.ChannelPipeline;
22 import io.netty.channel.EventLoopGroup;
23 import io.netty.channel.MultiThreadIoEventLoopGroup;
24 import io.netty.channel.nio.NioIoHandler;
25 import io.netty.channel.socket.SocketChannel;
26 import io.netty.channel.socket.nio.NioServerSocketChannel;
27 import io.netty.example.util.ServerUtil;
28 import io.netty.handler.logging.LogLevel;
29 import io.netty.handler.logging.LoggingHandler;
30 import io.netty.handler.ssl.SslContext;
31
32
33
34
35 public final class DiscardServer {
36
37 static final int PORT = Integer.parseInt(System.getProperty("port", "8009"));
38
39 public static void main(String[] args) throws Exception {
40
41 final SslContext sslCtx = ServerUtil.buildSslContext();
42
43 EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
44 try {
45 ServerBootstrap b = new ServerBootstrap();
46 b.group(group)
47 .channel(NioServerSocketChannel.class)
48 .handler(new LoggingHandler(LogLevel.INFO))
49 .childHandler(new ChannelInitializer<SocketChannel>() {
50 @Override
51 public void initChannel(SocketChannel ch) {
52 ChannelPipeline p = ch.pipeline();
53 if (sslCtx != null) {
54 p.addLast(sslCtx.newHandler(ch.alloc()));
55 }
56 p.addLast(new DiscardServerHandler());
57 }
58 });
59
60
61 ChannelFuture f = b.bind(PORT).sync();
62
63
64
65
66 f.channel().closeFuture().sync();
67 } finally {
68 group.shutdownGracefully();
69 }
70 }
71 }