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 bossGroup = new NioEventLoopGroup(1);
48 EventLoopGroup workerGroup = new NioEventLoopGroup();
49 try {
50 ServerBootstrap b = new ServerBootstrap();
51 b.group(bossGroup, workerGroup)
52 .channel(NioServerSocketChannel.class)
53 .handler(new LoggingHandler(LogLevel.INFO))
54 .childHandler(new ChannelInitializer<SocketChannel>() {
55 @Override
56 public void initChannel(SocketChannel ch) throws Exception {
57 ch.pipeline().addLast(new PortUnificationServerHandler(sslCtx));
58 }
59 });
60
61
62 b.bind(PORT).sync().channel().closeFuture().sync();
63 } finally {
64 bossGroup.shutdownGracefully();
65 workerGroup.shutdownGracefully();
66 }
67 }
68 }