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.nio.NioEventLoopGroup;
24 import io.netty.channel.socket.SocketChannel;
25 import io.netty.channel.socket.nio.NioServerSocketChannel;
26 import io.netty.example.util.ServerUtil;
27 import io.netty.handler.logging.LogLevel;
28 import io.netty.handler.logging.LoggingHandler;
29 import io.netty.handler.ssl.SslContext;
30
31
32
33
34 public final class DiscardServer {
35
36 static final int PORT = Integer.parseInt(System.getProperty("port", "8009"));
37
38 public static void main(String[] args) throws Exception {
39
40 final SslContext sslCtx = ServerUtil.buildSslContext();
41
42 EventLoopGroup group = new NioEventLoopGroup();
43 try {
44 ServerBootstrap b = new ServerBootstrap();
45 b.group(group)
46 .channel(NioServerSocketChannel.class)
47 .handler(new LoggingHandler(LogLevel.INFO))
48 .childHandler(new ChannelInitializer<SocketChannel>() {
49 @Override
50 public void initChannel(SocketChannel ch) {
51 ChannelPipeline p = ch.pipeline();
52 if (sslCtx != null) {
53 p.addLast(sslCtx.newHandler(ch.alloc()));
54 }
55 p.addLast(new DiscardServerHandler());
56 }
57 });
58
59
60 ChannelFuture f = b.bind(PORT).sync();
61
62
63
64
65 f.channel().closeFuture().sync();
66 } finally {
67 group.shutdownGracefully();
68 }
69 }
70 }