1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.portunification;
17
18 import io.netty.bootstrap.ServerBootstrap;
19 import io.netty.channel.ChannelInitializer;
20 import io.netty.channel.EventLoopGroup;
21 import io.netty.channel.nio.NioEventLoopGroup;
22 import io.netty.channel.socket.SocketChannel;
23 import io.netty.channel.socket.nio.NioServerSocketChannel;
24 import io.netty.handler.logging.LogLevel;
25 import io.netty.handler.logging.LoggingHandler;
26 import io.netty.handler.ssl.SslContext;
27 import io.netty.handler.ssl.SslContextBuilder;
28 import io.netty.handler.ssl.util.SelfSignedCertificate;
29
30
31
32
33
34
35
36
37 public final class PortUnificationServer {
38
39 static final int PORT = Integer.parseInt(System.getProperty("port", "8080"));
40
41 public static void main(String[] args) throws Exception {
42
43 SelfSignedCertificate ssc = new SelfSignedCertificate();
44 final SslContext sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey())
45 .build();
46
47 EventLoopGroup group = new NioEventLoopGroup();
48 try {
49 ServerBootstrap b = new ServerBootstrap();
50 b.group(group)
51 .channel(NioServerSocketChannel.class)
52 .handler(new LoggingHandler(LogLevel.INFO))
53 .childHandler(new ChannelInitializer<SocketChannel>() {
54 @Override
55 public void initChannel(SocketChannel ch) throws Exception {
56 ch.pipeline().addLast(new PortUnificationServerHandler(sslCtx));
57 }
58 });
59
60
61 b.bind(PORT).sync().channel().closeFuture().sync();
62 } finally {
63 group.shutdownGracefully();
64 }
65 }
66 }